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-2015 Xplenty, Inc. All Rights Reserved.