Apache Flink:无法将表对象转换为数据集对象

Question

我在 Flink 1.4.0 上使用 Table API。我有一些Table对象要转换为 Row 类型的DataSet。该项目是使用 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);

最后一条语句导致错误

"无法解析为数据集(( 方法">

Answer 1

您可能不会导入正确的BatchTableEnvironment。

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

Answer 2

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

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

更多关于这个： https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/batch/#data-sources