Class SingleEmitAggregator
- java.lang.Object
-
- org.apache.storm.trident.operation.impl.SingleEmitAggregator
-
- All Implemented Interfaces:
Serializable,Aggregator<org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>,Operation
public class SingleEmitAggregator extends Object implements Aggregator<org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interfaceSingleEmitAggregator.BatchToPartition
-
Constructor Summary
Constructors Constructor Description SingleEmitAggregator(Aggregator agg, SingleEmitAggregator.BatchToPartition batchToPartition)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaggregate(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentTuple tuple, TridentCollector collector)voidcleanup()When running in local mode, called when the local cluster is being shut down.voidcomplete(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentCollector collector)org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitStateinit(Object batchId, TridentCollector collector)voidprepare(Map<String,Object> conf, TridentOperationContext context)Called when the `Operation` is first initialized.
-
-
-
Constructor Detail
-
SingleEmitAggregator
public SingleEmitAggregator(Aggregator agg, SingleEmitAggregator.BatchToPartition batchToPartition)
-
-
Method Detail
-
init
public org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState init(Object batchId, TridentCollector collector)
- Specified by:
initin interfaceAggregator<org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>
-
aggregate
public void aggregate(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentTuple tuple, TridentCollector collector)- Specified by:
aggregatein interfaceAggregator<org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>
-
complete
public void complete(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentCollector collector)- Specified by:
completein interfaceAggregator<org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>
-
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
-
-