That's using the old interfaces so that won't be merged. New Flink connectors need to end up in their own repository
π 2
s
Sergey G
08/04/2022, 7:41 PM
@Martijn Visser could you tell me please, if I get data from StreamSource, then for each entity from streaming I need to do table queries (using query parameters from entity), then union/minus/intersect tables, and resulting table write to StreamSink. Do you know how to create TableEnvironment in Batch mode from StreamExectutionEnvironment?