故障代碼:

DataSet<Sales> ds2=env.readCsvFile(inPath).lineDelimiter("\n").fieldDelimiter(",").ignoreFirstLine().includeFields("1111")//四列字段都要.pojoType(Sales.class, "transacitonId","customerId", "itemId", "amountPaid");((DataSource<Sales>) ds2).setParallelism(1).writeAsCsv(outPath, "\n","|", FileSystem.WriteMode.OVERWRITE);env.execute();

完整報錯信息如下:

Exception in thread "main" java.lang.IllegalArgumentException: The writeAsCsv() method can only be used on data sets of tuples.
?? ?at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:139)
?? ?at org.apache.flink.api.java.DataSet.internalWriteAsCsv(DataSet.java:1630)
?? ?at org.apache.flink.api.java.DataSet.writeAsCsv(DataSet.java:1625)
?? ?at HDFS_Read.main(HDFS_Read.java:38)

解決方案:

講人話就是，這個 writeAsCsv是個半成品，只能寫入

DataSet<Tuple3<String,String,Integer>> ds2

這種類型的數據，不支持pojo類型的數據寫入

總結

以上是生活随笔為你收集整理的The writeAsCsv() method can only be used on data sets of tuples.的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。