Package org.apache.flink.table.runtime.operators.join.stream
-
Class Summary Class Description AbstractStreamingJoinOperator Abstract implementation for streaming unbounded Join operator which defines some member fields can be shared between different implementations.MiniBatchStreamingJoinOperator Streaming unbounded Join base operator which support mini-batch join.StreamingJoinOperator Streaming unbounded Join operator which supports INNER/LEFT/RIGHT/FULL JOIN.StreamingMultiJoinOperator Streaming multi-way join operator which supports inner join and left outer join, right joins are transformed into left joins by the optimizer.StreamingMultiJoinOperatorFactory Serializable factory for creatingStreamingMultiJoinOperator.StreamingSemiAntiJoinOperator Streaming unbounded Join operator which supports SEMI/ANTI JOIN.