Class FlatMapFunctionExecutor
java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.operation.impl.FlatMapFunctionExecutor
- All Implemented Interfaces:
- Serializable,- EachOperation,- Function,- Operation
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidcleanup()No-op implemnation.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) No-op implementation.
- 
Constructor Details- 
FlatMapFunctionExecutor
 
- 
- 
Method Details- 
prepareDescription copied from class:BaseOperationNo-op implementation.- Specified by:
- preparein interface- Operation
- Overrides:
- preparein class- BaseOperation
- 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:
 
- 
cleanuppublic void cleanup()Description copied from class:BaseOperationNo-op implemnation.- Specified by:
- cleanupin interface- Operation
- Overrides:
- cleanupin class- BaseOperation
 
- 
executeDescription copied from interface:FunctionPerforms the function logic on an individual tuple and emits 0 or more tuples.
 
-