Hi, I want to create an abstraction over N source tables (streams), and unify them into 1 table. I know UNION and UNION ALL exist, but I'm looking for DataStream.connect like semantics in regards to watermark control. I don't want to take the minimum watermark over all N streams, as I know for sure there won't be any time based calculations over the result table and I don't want data to be delayed as the different tables composing the stream highly vary in times of events flowing into the stream (one stream can receive events once an hour, the other only once a day).
I don't want to turn the Table into a DataStream, since I want to leverage predicate pushdown for the definition of the result table. Does anything like this currently exist? -- Best Regards, Yuval Itzchakov.
