Flink使用java實現讀取csv文件簡單實例

Flink使用java實現讀取csv文件簡單實例 首先咱們來看官方文檔中給出的幾種方法： 首先咱們來看官方文檔中給出的幾種方法： 第一種： DataSet<Tuple3<Integer, String, Double>> csvInput = env.readCsvFile(「hdfs:///the/CSV/file」) .types(Integer.class, String.class, Do

>>阅读原文<<