Apache Flink连接与连接

Question

在Apache Flink流处理中，连接操作与连接有何不同，因此CoProcessFunction和ProcessJoinFunction有何不同，这是CoProcessFunction提供的onTimer函数吗？您能否提供一个适用于以相互排斥的方式连接/连接的示例用例。

Answer 1

差异是相当显著的。在连接的情况下，它的工作原理或多或少类似于SQL内部连接，因此您需要提供将用于连接的字段，并且连接通过窗口进行计算。

因此，基本上，您定义了将用于联接的每个窗口的键以及将用于评估结果的窗口。ProcessJoinFunction 允许您在处理连接元素后对其进行处理，但您无法控制连接机制本身，即已连接元素对将被传递到 ProcessJoinFunction

在< code>connect的情况下，您还可以定义键(虽然您不必这样做)，但是这些键将不会用于连接，而是用于控制通过操作符的并行实例的流和键控状态。因此，在connect的情况下，没有逻辑负责如何连接元素，而是为来自stream1的每个元素调用< code>processElement1方法，为来自stream2的每个元素调用< code>processElement2方法。所以，如果你想执行某种连接，你必须自己实现逻辑。