Class CombinerAggregatorInitImpl
java.lang.Object
org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl
- All Implemented Interfaces:
Serializable
,EachOperation
,Function
,Operation
- See Also:
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
cleanup()
When running in local mode, called when the local cluster is being shut down.void
execute
(TridentTuple tuple, TridentCollector collector) Performs the function logic on an individual tuple and emits 0 or more tuples.void
prepare
(Map<String, Object> conf, TridentOperationContext context) Called when the `Operation` is first initialized.
-
Constructor Details
-
CombinerAggregatorInitImpl
-
-
Method Details
-
execute
Description copied from interface:Function
Performs the function logic on an individual tuple and emits 0 or more tuples. -
prepare
Description copied from interface:Operation
Called when the `Operation` is first initialized.- Specified by:
prepare
in 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:Operation
When running in local mode, called when the local cluster is being shut down.
-