Class ChainedAggregatorImpl
java.lang.Object
org.apache.storm.trident.operation.impl.ChainedAggregatorImpl
- All Implemented Interfaces:
Serializable,Aggregator<ChainedResult>,Operation
- See Also:
-
Constructor Summary
ConstructorsConstructorDescriptionChainedAggregatorImpl(Aggregator[] aggs, Fields[] inputFields, ComboList.Factory fact) -
Method Summary
Modifier 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
-
prepare
Description copied from interface:OperationCalled when the `Operation` is first initialized.- Specified by:
preparein interfaceOperation- Parameters:
conf- the Storm configuration mapcontext- 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 interfaceAggregator<ChainedResult>
-
aggregate
- Specified by:
aggregatein interfaceAggregator<ChainedResult>
-
complete
- Specified by:
completein interfaceAggregator<ChainedResult>
-
cleanup
public void cleanup()Description copied from interface:OperationWhen running in local mode, called when the local cluster is being shut down.
-