弗林克一批ReadCSV - zip文件

Question

我基于 https://github.com/dataArtisans/flink-training-exercises/blob/master/src/main/java/com/dataartisans/flinktraining/exercises/dataset_java/mail_count/MailCount.java

在下面的代码，输入必须为.csv写一个批处理，否则我得到的错误。我尝试了一个带有csv的.zip文件。在MailCount.java中，我看到readCsvFile接受.gz文件作为输入并正常工作。能否请你帮忙？

env.readCsvFile（输入） .ignoreFirstLine（） .includeFields（字段） .types（String.class，String.class）;

感谢 阿鲁娜

Answer 1

弗林克支持读取压缩文件开箱，如果文件有一个适当延长。但是，并非所有类型的压缩都受支持。您可以在[1]中找到支持的压缩类型列表。

例如，.gz被支持，这就是为什么这个例子有效，但.zip不是，所以你得到一个错误。

此致 康斯坦丁

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/index.html#read-compressed-files