Re: How are custom keys compared during joins

2019-12-08 Thread Guozhang Wang
Hello Sachin, Thanks for the detailed description. Your find is right that for stream-table join the table-side updates would not trigger a join since stream records are not "materialized" or buffered during the processing. The community has requested similar semantics to improve as table-table j

Re: How are custom keys compared during joins

2019-12-07 Thread Sachin Mittal
I figured out the issue. Basically my table2Mapped which is created from stream2 has some messages that arrive later than they arrive at stream1 for same key. After checking stream to table semantics I found that the left side is joined to right side only for the record that exist for that key tha

How are custom keys compared during joins

2019-12-06 Thread Sachin Mittal
Hi, I am facing some weird problems when joining two streams or a stream/table. The joined stream does not contain all the joined records. Also note that my keys are custom keys for which I have implemented equals and hashcode method Is there something else also I need to do to ensure key1 === key