Flink批处理ReadCSV-zip文件


0

我正在写一批基于

在下面的代码中,输入必须是.csv,否则会出错。我尝试了一个.zip文件,里面有一个csv。在邮件计数.java,我看到readCsvFile接受.gz文件作为输入, job 正常。你能帮忙吗?

环境readCsvFile(输入)

谢谢

1 答案


0

如果文件的扩展名正确,Flink支持直接读取压缩文件。但是,并非所有类型的压缩都受支持。您可以在[1]中找到支持的压缩类型列表。

例如,支持.gz,这就是为什么该示例有效,而.zip不支持,因此会出现一个错误。

谨致问候,

[1]https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/index.html ead-压缩文件


我来回答

写文章

提问题

面试题