Class ChainedAggregatorImpl
- java.lang.Object
-
- org.apache.storm.trident.operation.impl.ChainedAggregatorImpl
-
- All Implemented Interfaces:
Serializable,Aggregator<ChainedResult>,Operation
public class ChainedAggregatorImpl extends Object implements Aggregator<ChainedResult>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ChainedAggregatorImpl(Aggregator[] aggs, Fields[] inputFields, ComboList.Factory fact)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaggregate(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)ChainedResultinit(Object batchId, TridentCollector collector)voidprepare(Map<String,Object> conf, TridentOperationContext context)Called when the `Operation` is first initialized.
-
-
-
Constructor Detail
-
ChainedAggregatorImpl
public ChainedAggregatorImpl(Aggregator[] aggs, Fields[] inputFields, ComboList.Factory fact)
-
-
Method Detail
-
prepare
public void prepare(Map<String,Object> conf, TridentOperationContext context)
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:
TridentOperationContext
-
init
public ChainedResult init(Object batchId, TridentCollector collector)
- Specified by:
initin interfaceAggregator<ChainedResult>
-
aggregate
public void aggregate(ChainedResult val, TridentTuple tuple, TridentCollector collector)
- Specified by:
aggregatein interfaceAggregator<ChainedResult>
-
complete
public void complete(ChainedResult val, TridentCollector collector)
- Specified by:
completein interfaceAggregator<ChainedResult>
-
-