Sorry for the noise, I completely missed this part of the documentation describing exactly how to do this: https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/data_stream_api/
________________________________ From: John Tipper <john_tip...@hotmail.com> Sent: 23 June 2022 21:35 To: user@flink.apache.org <user@flink.apache.org> Subject: Is it possible to use DataStream API keyBy followed by Table API SQL in PyFlink? Hi all, In PyFlink, is it possible to use the DataStream API to create a DataStream by means of StreamExecutionEnvironment's addSource(...), then perform transformations on this data stream using the DataStream API and then convert that stream into a form where SQL statements can be executed on it using the TableApi? It's not clear to me whether it's possible to mix and match the APIs, or under what circumstances you can (or should/should not) move between the 2. Many thanks, John
