Class ChainedAggregatorImpl
java.lang.Object
org.apache.storm.trident.operation.impl.ChainedAggregatorImpl
- All Implemented Interfaces:
- Serializable,- Aggregator<ChainedResult>,- Operation
- See Also:
- 
Constructor SummaryConstructorsConstructorDescriptionChainedAggregatorImpl(Aggregator[] aggs, Fields[] inputFields, ComboList.Factory fact) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidaggregate(ChainedResult val, TridentTuple tuple, TridentCollector collector) voidcleanup()When running in local mode, called when the local cluster is being shut down.voidcomplete(ChainedResult val, TridentCollector collector) init(Object batchId, TridentCollector collector) voidprepare(Map<String, Object> conf, TridentOperationContext context) Called when the `Operation` is first initialized.
- 
Constructor Details- 
ChainedAggregatorImpl
 
- 
- 
Method Details- 
prepareDescription copied from interface:OperationCalled when the `Operation` is first initialized.- Specified by:
- preparein interface- Operation
- Parameters:
- conf- the Storm configuration map
- context- the operation context which provides information such as the number of partitions in the stream, and the current partition index. It also provides methods for registering operation-specific metrics.
- See Also:
 
- 
init- Specified by:
- initin interface- Aggregator<ChainedResult>
 
- 
aggregate- Specified by:
- aggregatein interface- Aggregator<ChainedResult>
 
- 
complete- Specified by:
- completein interface- Aggregator<ChainedResult>
 
- 
cleanuppublic void cleanup()Description copied from interface:OperationWhen running in local mode, called when the local cluster is being shut down.
 
-