Package org.apache.flink.table.runtime.operators.join

Class Summary

Class	Description
HashJoinOperator	Hash join base operator.
JoinConditionWithNullFilters	Utility to take null filters into consideration when apply join condition.
KeyedCoProcessOperatorWithWatermarkDelay<K,IN1,IN2,OUT>	A KeyedCoProcessOperator that supports holding back watermarks with a static delay.
NullAwareJoinHelper	Helper for null aware join.
OuterJoinPaddingUtil	An utility to generate reusable padding results for outer joins.
SortMergeFullOuterJoinIterator	Gets two matched rows for full outer join.
SortMergeInnerJoinIterator	Gets probeRow and match rows for inner join.
SortMergeJoinFunction	This function is used to process the main logic of sort merge join.
SortMergeJoinIterator	Gets probeRow and match rows for inner/left/right join.
SortMergeJoinOperator	An implementation that realizes the joining through a sort-merge join strategy. 1.In most cases, its performance is weaker than HashJoin. 2.It is more stable than HashJoin, and most of the data can be sorted stably. 3.SortMergeJoin should be the best choice if sort can be omitted in the case of multi-level join cascade with the same key.
SortMergeOneSideOuterJoinIterator	Gets probeRow and match rows for left/right join.

Enum Summary

Enum	Description
FlinkJoinType	Join type for join.
HashJoinType	Join type for hash table.