storm.trident.operation.impl
Class GroupedAggregator

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

All Implemented Interfaces:

java.io.Serializable, Aggregator<java.lang.Object[]>, Operation

public class GroupedAggregator
extends java.lang.Object
implements Aggregator<java.lang.Object[]>

See Also:

Serialized Form

Constructor Summary

GroupedAggregator(Aggregator agg, Fields group, Fields input, int outSize)

Method Summary

void	aggregate(java.lang.Object[] arr, TridentTuple tuple, TridentCollector collector)
void	cleanup()
void	complete(java.lang.Object[] arr, TridentCollector collector)
java.lang.Object[]	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

GroupedAggregator

public GroupedAggregator(Aggregator agg,
                         Fields group,
                         Fields input,
                         int outSize)

Method Detail

prepare

public void prepare(java.util.Map conf,
                    TridentOperationContext context)

Specified by:

prepare in interface Operation

init

public java.lang.Object[] init(java.lang.Object batchId,
                               TridentCollector collector)

Specified by:

init in interface Aggregator<java.lang.Object[]>

aggregate

public void aggregate(java.lang.Object[] arr,
                      TridentTuple tuple,
                      TridentCollector collector)

Specified by:

aggregate in interface Aggregator<java.lang.Object[]>

complete

public void complete(java.lang.Object[] arr,
                     TridentCollector collector)

Specified by:

complete in interface Aggregator<java.lang.Object[]>

cleanup

public void cleanup()

Specified by:

cleanup in interface Operation