Class MapReducerAggStateUpdater
java.lang.Object
org.apache.storm.trident.state.map.MapReducerAggStateUpdater
- All Implemented Interfaces:
Serializable,Operation,StateUpdater<MapState>
- See Also:
-
Constructor Summary
ConstructorsConstructorDescriptionMapReducerAggStateUpdater(ReducerAggregator agg, Fields groupFields, Fields inputFields) -
Method Summary
Modifier and TypeMethodDescriptionvoidcleanup()When running in local mode, called when the local cluster is being shut down.voidprepare(Map<String, Object> conf, TridentOperationContext context) Called when the `Operation` is first initialized.voidupdateState(MapState map, List<TridentTuple> tuples, TridentCollector collector)
-
Constructor Details
-
MapReducerAggStateUpdater
-
-
Method Details
-
updateState
- Specified by:
updateStatein interfaceStateUpdater<MapState>
-
prepare
Description copied from interface:OperationCalled when the `Operation` is first initialized.- Specified by:
preparein interfaceOperation- Parameters:
conf- the Storm configuration mapcontext- 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:
-
cleanup
public void cleanup()Description copied from interface:OperationWhen running in local mode, called when the local cluster is being shut down.
-