public class StreamedAccumulatedTapsHashJoinPipelinePartitioner extends ExpressionRulePartitioner
The rule leverages the ability to not capture some matched edges, that represent paths that should not be included in the result pipeline.
RulePartitioner.PartitionSource
graphPartitioner, logLevel, partitionSource, phase
Constructor and Description |
---|
StreamedAccumulatedTapsHashJoinPipelinePartitioner() |
addAnnotation, addAnnotationExclude, createExpressionGraphPartitioner, getAnnotationExcludes, setAnnotationExcludes, setAnnotations, setPhase, setRuleExpression
getGraphPartitioner, getPartitionSource, getRuleName, getRulePhase, partition, partition, performPartition, toString
public StreamedAccumulatedTapsHashJoinPipelinePartitioner()
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.