GroupedAggregator (storm-core-java-api 0.11.0 API)

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

Methods
Modifier and Type	Method and Description
`void`	`aggregate(Object[] arr, TridentTuple tuple, TridentCollector collector)`
`void`	`cleanup()`
`void`	`complete(Object[] arr, TridentCollector collector)`
`Object[]`	`init(Object batchId, TridentCollector collector)`
`void`	`prepare(Map conf, TridentOperationContext context)`

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

public void prepare(Map conf,
           TridentOperationContext context)

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

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

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

Class GroupedAggregator