cascading.flow.tez.planner.rule.partitioner

Class ConsecutiveGroupOrMergesNodePartitioner

java.lang.Object

cascading.flow.planner.rule.RulePartitioner

cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner

cascading.flow.tez.planner.rule.partitioner.ConsecutiveGroupOrMergesNodePartitioner

All Implemented Interfaces:

Rule

public class ConsecutiveGroupOrMergesNodePartitioner
extends ExpressionRulePartitioner

Merge -> (Merge or GroupBy)

Nested Class Summary

Nested classes/interfaces inherited from class cascading.flow.planner.rule.RulePartitioner

RulePartitioner.PartitionSource

Field Summary

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

graphPartitioner, logLevel, partitionSource, phase

Constructor Summary

Constructors

Constructor and Description
ConsecutiveGroupOrMergesNodePartitioner()

Method Summary

Methods inherited from class cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner

addAnnotation, addAnnotationExclude, createExpressionGraphPartitioner, getAnnotationExcludes, setAnnotationExcludes, setAnnotations, setPhase, setRuleExpression

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

getGraphPartitioner, getPartitionSource, getRuleName, getRulePhase, partition, partition, performPartition, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsecutiveGroupOrMergesNodePartitioner

public ConsecutiveGroupOrMergesNodePartitioner()