storm.trident.operation.impl

Class SingleEmitAggregator

java.lang.Object

storm.trident.operation.impl.SingleEmitAggregator

All Implemented Interfaces:

Serializable, Aggregator<storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState>, Operation

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

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	SingleEmitAggregator.BatchToPartition

Constructor Summary

Constructors

Constructor and Description
SingleEmitAggregator(Aggregator agg, SingleEmitAggregator.BatchToPartition batchToPartition)

Method Summary

Methods

Modifier and Type	Method and Description
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(Object batchId, TridentCollector collector)
void	prepare(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(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(Map conf,
           TridentOperationContext context)

Specified by:

prepare in interface Operation

cleanup

public void cleanup()

Specified by:

cleanup in interface Operation