public class StreamedAccumulatedTapsPipelinePartitioner extends ExpressionRulePartitioner
RulePartitioner.PartitionSource
graphPartitioner, logLevel, partitionSource, phase
Constructor and Description |
---|
StreamedAccumulatedTapsPipelinePartitioner() |
addAnnotation, addAnnotationExclude, createExpressionGraphPartitioner, getAnnotationExcludes, setAnnotationExcludes, setAnnotations, setPhase, setRuleExpression
getGraphPartitioner, getPartitionSource, getRuleName, getRulePhase, partition, partition, performPartition, toString
public StreamedAccumulatedTapsPipelinePartitioner()
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.