storm.trident.operation.impl
Class SingleEmitAggregator

java.lang.Object
  extended by storm.trident.operation.impl.SingleEmitAggregator
All Implemented Interfaces:
java.io.Serializable, Aggregator<storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>, Operation

public class SingleEmitAggregator
extends java.lang.Object
implements Aggregator<storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>

See Also:
Serialized Form

Nested Class Summary
static interface SingleEmitAggregator.BatchToPartition
           
 
Constructor Summary
SingleEmitAggregator(Aggregator agg, SingleEmitAggregator.BatchToPartition batchToPartition)
           
 
Method Summary
 void aggregate(storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentTuple tuple, TridentCollector collector)
           
 void cleanup()
           
 void complete(storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentCollector collector)
           
 storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState init(java.lang.Object batchId, TridentCollector collector)
           
 void prepare(java.util.Map conf, TridentOperationContext context)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SingleEmitAggregator

public SingleEmitAggregator(Aggregator agg,
                            SingleEmitAggregator.BatchToPartition batchToPartition)
Method Detail

init

public storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState init(java.lang.Object batchId,
                                                                              TridentCollector collector)
Specified by:
init in interface Aggregator<storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>

aggregate

public void aggregate(storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val,
                      TridentTuple tuple,
                      TridentCollector collector)
Specified by:
aggregate in interface Aggregator<storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>

complete

public void complete(storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val,
                     TridentCollector collector)
Specified by:
complete in interface Aggregator<storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>

prepare

public void prepare(java.util.Map conf,
                    TridentOperationContext context)
Specified by:
prepare in interface Operation

cleanup

public void cleanup()
Specified by:
cleanup in interface Operation