storm.trident.operation.impl
Class CombinerAggregatorInitImpl

java.lang.Object
  storm.trident.operation.impl.CombinerAggregatorInitImpl

All Implemented Interfaces:

java.io.Serializable, EachOperation, Function, Operation

public class CombinerAggregatorInitImpl
extends java.lang.Object
implements Function

See Also:

Serialized Form

Constructor Summary

CombinerAggregatorInitImpl(CombinerAggregator agg)

Method Summary

void	cleanup()
void	execute(TridentTuple tuple, 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

CombinerAggregatorInitImpl

public CombinerAggregatorInitImpl(CombinerAggregator agg)

Method Detail

execute

public void execute(TridentTuple tuple,
                    TridentCollector collector)

Specified by:

execute in interface Function

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