將DataSet <Row>另存爲CSV

Question

是否可以將DataSet<Row>另存爲CSV輸出？ toDataSet API預計Row.class和writeAsCSV預計Tuple。能否請你幫忙？

DataSet<Row> finalResult = tEnv.toDataSet(flattenedTripByGender, Row.class); 
finalResult.writeAsCsv("../data/tripbygender.csv"); 

，這是一個錯誤：

Caused by: java.lang.ClassCastException: org.apache.flink.api.table.Row cannot be cast to org.apache.flink.api.java.tuple.Tuple at org.apache.flink.api.java.io.CsvOutputFormat.writeRecord(CsvOutputFormat.java:44) 

阿魯娜

Answer 1

您可以直接發出Table不使用TableSink將其轉換爲DataSet。

弗林克1.1.x版本帶有被用作遵循CsvTableSink：

// compute your result 
Table result = // ... 

// create a TableSink 
TableSink sink = new CsvTableSink("/path/to/file", fieldDelim = "|"); 
// write the result Table to the TableSink 
result.writeToSink(sink);