关于Table和DataStream相互转化的问题

Classic

List

1 message

官网关于Table和DataStream相互转化部分：
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/data_stream_api/#converting-between-datastream-and-table

①样例代码中，
// interpret the insert-only Table as a DataStream again
DataStream<Row> resultStream = tableEnv.toDataStream(resultTable);

但是查询了StreamTableEnvironment中没有toDataStream(Table resultTable);这个方法

②样例代码中：https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/common/#emit-a-table

tableEnv.connect(new FileSystem().path("/path/to/file"))
.withFormat(new Csv().fieldDelimiter('|').deriveSchema())
.withSchema(schema)
.createTemporaryTable("CsvSinkTable");

我的依赖中没有new Csv()，如果我要这样使用，需要额外的引入什么依赖包吗

谢谢！！！

--
Sent from: http://apache-flink.147419.n8.nabble.com/