我在flink1.4.0上使用表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（）方法”
2条答案
按热度按时间lawou6xi1#
如果你想读一本书
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-来源gwo2fgha2#
您可能无法导入正确的
BatchTableEnvironment.请检查是否导入
org.apache.flink.table.api.java.BatchTableEnvironment而不是org.apache.flink.table.api.BatchTableEnvironment. 前者是java和scala变体的公共基类。