storm.trident.operation.impl

Class ReducerAggregatorImpl

java.lang.Object

storm.trident.operation.impl.ReducerAggregatorImpl

All Implemented Interfaces:

Serializable, Aggregator<Result>, Operation

public class ReducerAggregatorImpl
extends Object
implements Aggregator<Result>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ReducerAggregatorImpl(ReducerAggregator agg)

Method Summary

Modifier and Type	Method and Description
void	aggregate(Result val, TridentTuple tuple, TridentCollector collector)
void	cleanup()
void	complete(Result val, TridentCollector collector)
Result	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

ReducerAggregatorImpl

public ReducerAggregatorImpl(ReducerAggregator agg)

Method Detail

prepare

public void prepare(Map conf,
                    TridentOperationContext context)

Specified by:

prepare in interface Operation

init

public Result init(Object batchId,
                   TridentCollector collector)

Specified by:

init in interface Aggregator<Result>

aggregate

public void aggregate(Result val,
                      TridentTuple tuple,
                      TridentCollector collector)

Specified by:

aggregate in interface Aggregator<Result>

complete

public void complete(Result val,
                     TridentCollector collector)

Specified by:

complete in interface Aggregator<Result>

cleanup

public void cleanup()

Specified by:

cleanup in interface Operation