how to use dataset api like dataset.output(outputFormat) in latest flink1.14 or flink1.15 table/sql api

liss bai 0
Viewed 18

I got a project use dataset api like dataset.output(outputFormat). The OutputFormat is userDefined(write batch data to neo4j) so I want to keep it, but I could not find any table/sql api in latest version in flink use outputFormat. Thanks for any help.

outputformat flink-sql dataset apache-flink
1 Answers

As of Flink 1.14, the implementation of the Table/SQL API no longer relies at all on the DataSet API. Those relational APIs now rely exclusively on the DataStream API for both batch and streaming use cases.

I suggest you ask on the Flink user mailing list for guidance. It may be possible to implement a custom OutputFormat to use with the Table API. Another possibility might be to convert the Table to a DataStream, and then use writeUsingOutputFormat (but that has been deprecated).

David Anderson0
Related