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