public class StreamedAccumulatedTapsHashJoinPipelinePartitioner extends cascading.flow.planner.rule.partitioner.ExpressionRulePartitioner
The rule leverages the ability to not capture some matched edges, that represent paths that should not be included in the result pipeline.
Constructor and Description |
---|
StreamedAccumulatedTapsHashJoinPipelinePartitioner() |
addAnnotation, addAnnotationExclude, createExpressionGraphPartitioner, getAnnotationExcludes, setAnnotationExcludes, setAnnotations, setPhase, setRuleExpression
public StreamedAccumulatedTapsHashJoinPipelinePartitioner()
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.