Package org.apache.storm.trident.operation.impl

Class GroupedAggregator

java.lang.Object

org.apache.storm.trident.operation.impl.GroupedAggregator

All Implemented Interfaces:

Serializable, Aggregator<Object[]>, Operation

public class GroupedAggregator
extends Object
implements Aggregator<Object[]>

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	aggregate(Object[] arr, TridentTuple tuple, TridentCollector collector)
void	cleanup()	When running in local mode, called when the local cluster is being shut down.
void	complete(Object[] arr, TridentCollector collector)
Object[]	init(Object batchId, TridentCollector collector)
void	prepare(Map<String,Object> conf, TridentOperationContext context)	Called when the `Operation` is first initialized.

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(Map<String,Object> conf,
                    TridentOperationContext context)

Description copied from interface: Operation

Called when the `Operation` is first initialized.

Specified by:

prepare in interface Operation

Parameters:

conf - the Storm configuration map

context - the operation context which provides information such as the number of partitions in the stream, and the current partition index. It also provides methods for registering operation-specific metrics.

See Also:

TridentOperationContext

init

public Object[] init(Object batchId,
                     TridentCollector collector)

Specified by:

init in interface Aggregator<Object[]>

aggregate

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

Specified by:

aggregate in interface Aggregator<Object[]>

complete

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

Specified by:

complete in interface Aggregator<Object[]>

cleanup

public void cleanup()

Description copied from interface: Operation

When running in local mode, called when the local cluster is being shut down.

Specified by:

cleanup in interface Operation