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

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
public class FlatMapFunctionExecutor extends BaseOperation implements Function
See Also:

  • Constructor Details

    • FlatMapFunctionExecutor

      public FlatMapFunctionExecutor(FlatMapFunction function)

  • Method Details

    • prepare

      public void prepare(Map<String,Object> conf, TridentOperationContext context)
      Description copied from class: BaseOperation
      No-op implementation.
      Specified by:
      prepare in interface Operation
      Overrides:
      prepare in 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:

    • cleanup

      public void cleanup()
      Description copied from class: BaseOperation
      No-op implemnation.
      Specified by:
      cleanup in interface Operation
      Overrides:
      cleanup in class BaseOperation

    • execute

      public void execute(TridentTuple tuple, TridentCollector collector)
      Description copied from interface: Function
      Performs the function logic on an individual tuple and emits 0 or more tuples.
      Specified by:
      execute in interface Function
      Parameters:
      tuple - The incoming tuple
      collector - A collector instance that can be used to emit tuples