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
