弗林克一批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