AccumulatedTapOnHashJoinExpression |
|
BalanceCheckpointWithTapExpression |
|
BalanceGroupBlockingHashJoinExpression |
|
BalanceGroupGroupExpression |
|
BalanceGroupMergeGroupExpression |
|
BalanceGroupNonBlockingHashJoinExpression |
This rule is a compliment to GroupNonBlockingHashJoinTransformRule and is intended
to prevent a HashJoin from landing in a Reducer until reduce side HashJoins are supported.
|
BalanceGroupSplitExpression |
|
BalanceGroupSplitJoinExpression |
|
BalanceGroupSplitMergeExpression |
|
BalanceGroupSplitMergeGroupExpression |
|
BalanceGroupSplitTriangleExpression |
|
BalanceHashJoinBlockingHashJoinExpression |
|
BalanceHashJoinSameSourceExpression |
|
BalanceHashJoinToHashJoinExpression |
|
BalanceNonSafePipeSplitExpression |
Captures a split against a non-safe Operation to prevent the operation from running
in parallel mappers.
|
BalanceNonSafeSplitExpression |
Captures a split against a non-safe Operation to prevent the operation from running
in parallel mappers
|
BalanceSameSourceStreamedAccumulatedExpression |
|
ConsecutiveTapsPartitionExpression |
|
DualStreamedAccumulatedExpression |
|
GroupTapPartitionExpression |
|
StreamedAccumulatedTapsExpressionGraph |
|
StreamedAccumulatedTapsHashJoinExpressionGraph |
|
StreamedAccumulatedTapsHashJoinPipelinePartitionExpression |
|
StreamedAccumulatedTapsPipelinePartitionExpression |
|
StreamedOnlySourcesPipelinePartitionExpression |
|
StreamedSelfJoinSourcesPipelinePartitionExpression |
|
TapGroupTapPartitionExpression |
|