Class ConsumerExecutor

java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.operation.impl.ConsumerExecutor
All Implemented Interfaces:
Serializable, EachOperation, Function, Operation

public class ConsumerExecutor extends BaseOperation implements Function
See Also:
  • Constructor Details

    • ConsumerExecutor

      public ConsumerExecutor(Consumer consumer)
  • Method Details

    • 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