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 SummaryNested Classes
- 
Constructor SummaryConstructorsConstructorDescriptionSingleEmitAggregator(Aggregator agg, SingleEmitAggregator.BatchToPartition batchToPartition) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidaggregate(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 Details- 
SingleEmitAggregator
 
- 
- 
Method Details- 
initpublic org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState init(Object batchId, TridentCollector collector) - Specified by:
- initin interface- Aggregator<org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>
 
- 
aggregatepublic void aggregate(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentTuple tuple, TridentCollector collector) - Specified by:
- aggregatein interface- Aggregator<org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>
 
- 
completepublic void complete(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentCollector collector) - Specified by:
- completein interface- Aggregator<org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>
 
- 
prepareDescription copied from interface:OperationCalled when the `Operation` is first initialized.- Specified by:
- preparein interface- Operation
- Parameters:
- conf- the Storm configuration map
- context- 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:
 
- 
cleanuppublic void cleanup()Description copied from interface:OperationWhen running in local mode, called when the local cluster is being shut down.
 
-