CODEWITHSUNDEEP
apache-flinkflink-streamingflink-sqlpyflink
Alfred
Alfred

Reputation: 1841

how to consume two source stream with table API in Flink

I have a Flink Job that use the python table api. Now my application is going to consume an additional source stream. I am curious what the recommended way to consume multiple source stream with table API.

Additional information:

The two input streams are just two source of events. I want to aggregate them together with window operation. It is like union operation in DataStream

Thanks!

Upvotes: 0

Views: 739

Answers (1)

David Anderson
David Anderson

Reputation: 43499

The Table/SQL equivalent to DataStream union is the Table union operation or the SQL union operation.

Upvotes: 2

Related Questions