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

Class ReducerAggStateUpdater

java.lang.Object

org.apache.storm.trident.operation.impl.ReducerAggStateUpdater

All Implemented Interfaces:

Serializable, Operation, StateUpdater<Snapshottable>

public class ReducerAggStateUpdater
extends Object
implements StateUpdater<Snapshottable>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ReducerAggStateUpdater(ReducerAggregator agg)

Method Summary

Modifier and Type	Method	Description
void	cleanup()	When running in local mode, called when the local cluster is being shut down.
void	prepare(Map<String,Object> conf, TridentOperationContext context)	Called when the `Operation` is first initialized.
void	updateState(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ReducerAggStateUpdater

public ReducerAggStateUpdater(ReducerAggregator agg)

Method Details

updateState

public void updateState(Snapshottable state,
 List<TridentTuple> tuples,
 TridentCollector collector)

Specified by:

updateState in interface StateUpdater<Snapshottable>

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

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