Class ChainedAggregatorImpl
java.lang.Object
org.apache.storm.trident.operation.impl.ChainedAggregatorImpl
- All Implemented Interfaces:
Serializable
,Aggregator<ChainedResult>
,Operation
- See Also:
-
Constructor Summary
ConstructorDescriptionChainedAggregatorImpl
(Aggregator[] aggs, Fields[] inputFields, ComboList.Factory fact) -
Method Summary
Modifier and TypeMethodDescriptionvoid
aggregate
(ChainedResult val, TridentTuple tuple, TridentCollector collector) void
cleanup()
When running in local mode, called when the local cluster is being shut down.void
complete
(ChainedResult val, TridentCollector collector) init
(Object batchId, TridentCollector collector) void
prepare
(Map<String, Object> conf, TridentOperationContext context) Called when the `Operation` is first initialized.
-
Constructor Details
-
ChainedAggregatorImpl
-
-
Method Details
-
prepare
Description copied from interface:Operation
Called when the `Operation` is first initialized.- Specified by:
prepare
in 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:
init
in interfaceAggregator<ChainedResult>
-
aggregate
- Specified by:
aggregate
in interfaceAggregator<ChainedResult>
-
complete
- Specified by:
complete
in interfaceAggregator<ChainedResult>
-
cleanup
public void cleanup()Description copied from interface:Operation
When running in local mode, called when the local cluster is being shut down.
-