Hello Xingcan, Thanks for the proposal. It seems (I may miss something) the proposed semantics&approach for unbounded inner join is similar as the one proposed in FLINK-5878. I did not create the PR for FLINK-5878, as the implementation for inner join is closely associated with "Retract" (proposed in FLINK-6047). I have not completely read through your doc, but the window-joins that you mentioned are definitely the topics that we are also interested. Will read it carefully and left comments on your doc. Thanks!
Regards, Shaoxuan On Wed, May 17, 2017 at 8:56 PM, Xingcan Cui <xingc...@gmail.com> wrote: > Hi everyone, > > Recently, I drafted a proposal about inner join in Flink ( > http://goo.gl/4AdR7h). > > This document reviews some related work on the Table/SQL topic and it > provides a relatively complete view about the inner join semantics and > implementation. Besides, I also share my (objective) thoughts about > unifying the batch/stream query processing. > > I know there are lots of developers who are interested in this subject. > Please share your ideas and all suggestions are welcome. > > Thanks, > Xingcan >
