Apache Flink：无法将Table对象转换为DataSet对象

Question

我在Flink 1.4.0上使用Table API。我有一些Table对象要转换为DataSet类型的Row。该项目使用Maven构建并在IntelliJ上导入。我有以下代码，IDE无法解析方法tableenv.toDataSet()方法。请帮帮我。谢谢。

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
BatchTableEnvironment tableEnvironment = TableEnvironment.getTableEnvironment(env);
...
tableEnvironment.registerTableSource("table1",csvSource);
Table table1 = tableEnvironment.scan("table1");
DataSet<Row> result = tableEnvironment.toDataSet(table1, Row.class);

最后一个语句导致错误

“无法解析toDataSet（）方法”

Answer 1

您可能无法导入正确的BatchTableEnvironment。

请检查您导入org.apache.flink.table.api.java.BatchTableEnvironment而不是org.apache.flink.table.api.BatchTableEnvironment。前者是Java和Scala变体的通用基类。

Answer 2

如果你想从DataSet文件中读取csv，请执行以下操作：

DataSet<YourType> csvInput = env.readCsvFile("hdfs:///the/CSV/file") ...

更多相关信息：https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/batch/#data-sources