Hi Devs, Weijie Guo and I would like to initiate a discussion about FLIP-500: Support Join Extension in DataStream V2 API [1].
In relational algebra, Join are used to co-group two datasets and combine the data based on specific conditions. For stream computing systems, the data of the two streams is cached (usually through State) when the Join operation is performed. When data from either stream arrives, it can be matched with data from another stream. Therefore, Join has been widely used in multi-stream aggregate scenarios. To make it easy for users to use Join in DataStream V2, this FLIP will implement the Join extension in DataStream V2. For more details, please refer to FLIP-500 [1]. We look forward to your feedback. Best, Xu Huang [1] https://cwiki.apache.org/confluence/x/ywz0Ew
