public class BoundaryBalanceSplitToStreamedHashJoinTransformer extends RuleInsertionTransformer
this allows testGroupBySplitGroupByJoin to pass, and simplifies testJoinSamePipeAroundGroupBy by preventing the upstream operations to duplicate processing in parallel nodes
contractedTransformer, graphTransformer, ruleExpression, subGraphTransformer
Constructor and Description |
---|
BoundaryBalanceSplitToStreamedHashJoinTransformer() |
getRuleName, getRulePhase, performTransform, toString, transform
transform
public BoundaryBalanceSplitToStreamedHashJoinTransformer()
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.