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.
|
SortMergeOneSideOuterJoinIterator |
Gets probeRow and match rows for left/right join.
|
Enum | Description |
---|---|
FlinkJoinType |
Join type for join.
|
HashJoinType |
Join type for hash table.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.