cascading.flow.tez.planner.rule.transformer

Class BoundaryBalanceSplitSplitToStreamedHashJoinTransformer

java.lang.Object

cascading.flow.planner.iso.transformer.GraphTransformer<cascading.flow.planner.graph.ElementGraph,cascading.flow.planner.graph.ElementGraph>

cascading.flow.planner.rule.RuleTransformer

cascading.flow.planner.rule.transformer.RuleInsertionTransformer

cascading.flow.tez.planner.rule.transformer.BoundaryBalanceSplitSplitToStreamedHashJoinTransformer

All Implemented Interfaces:

cascading.flow.planner.rule.Rule

public class BoundaryBalanceSplitSplitToStreamedHashJoinTransformer
extends cascading.flow.planner.rule.transformer.RuleInsertionTransformer

Inserts Boundary after split that joins back into a HashJoin by way of another split.

this allows testGroupBySplitSplitGroupByJoin to pass

Field Summary

Fields inherited from class cascading.flow.planner.rule.RuleTransformer

contractedTransformer, graphTransformer, ruleExpression, subGraphTransformer

Constructor Summary

Constructors

Constructor and Description
BoundaryBalanceSplitSplitToStreamedHashJoinTransformer()

Method Summary

Methods inherited from class cascading.flow.planner.rule.RuleTransformer

getRuleName, getRulePhase, performTransform, toString, transform

Methods inherited from class cascading.flow.planner.iso.transformer.GraphTransformer

transform

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BoundaryBalanceSplitSplitToStreamedHashJoinTransformer

public BoundaryBalanceSplitSplitToStreamedHashJoinTransformer()