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:
-
Nested Class Summary
-
Constructor Summary
ConstructorDescriptionSingleEmitAggregator
(Aggregator agg, SingleEmitAggregator.BatchToPartition batchToPartition) -
Method Summary
Modifier and TypeMethodDescriptionvoid
aggregate
(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentTuple tuple, TridentCollector collector) void
cleanup()
When running in local mode, called when the local cluster is being shut down.void
complete
(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentCollector collector) org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState
init
(Object batchId, TridentCollector collector) void
prepare
(Map<String, Object> conf, TridentOperationContext context) Called when the `Operation` is first initialized.
-
Constructor Details
-
SingleEmitAggregator
-
-
Method Details
-
init
public org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState init(Object batchId, TridentCollector collector) - Specified by:
init
in 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:
aggregate
in 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:
complete
in interfaceAggregator<org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>
-
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:
-
cleanup
public void cleanup()Description copied from interface:Operation
When running in local mode, called when the local cluster is being shut down.
-