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

public class CombinerAggregatorCombineImpl
extends Object
implements Aggregator<Result>

Constructors
Constructor and Description
`CombinerAggregatorCombineImpl(CombinerAggregator agg)`

Methods
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)`

public CombinerAggregatorCombineImpl(CombinerAggregator agg)

public void prepare(Map conf,
           TridentOperationContext context)

public Result init(Object batchId,
          TridentCollector collector)

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

public void complete(Result val,
            TridentCollector collector)

Class CombinerAggregatorCombineImpl