Re: Approach to match join streams to create unique streams.

2019-09-24 Thread srikanth flink
Fabian, Thanks, already implemented the left join. Srikanth On Tue, Sep 24, 2019 at 2:12 PM Fabian Hueske wrote: > Hi, > > AFAIK, Flink SQL Temporal table function joins are only supported as inner > equality joins. > An extension to left outer joins would be great, but is not on the > immedia

Re: Approach to match join streams to create unique streams.

2019-09-24 Thread Fabian Hueske
Hi, AFAIK, Flink SQL Temporal table function joins are only supported as inner equality joins. An extension to left outer joins would be great, but is not on the immediate roadmap AFAIK. If you need the inverse, I'd recommend to implement the logic in a DataStream program with a KeyedCoProcessFun

Approach to match join streams to create unique streams.

2019-09-23 Thread srikanth flink
Hi there, I've two streams source Kafka. Stream1 is a continuous data and stream2 is a periodic update. Stream2 contains only one column. *Use case*: Every entry from stream1 should verify if the stream2 has any match. The matched and unmatched records should be separated into new unique streams