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

Class Summary

Class	Description
HashJoinOperator	Hash join base operator.
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.
ProcTimeBoundedStreamJoin	The function to execute processing time bounded stream inner-join.
RowTimeBoundedStreamJoin	The function to execute row(event) time bounded stream inner-join.
SortMergeFullOuterJoinIterator	Gets two matched rows for full outer join.
SortMergeInnerJoinIterator	Gets probeRow and match rows for inner 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.
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.