Class TuplifyArgs

All Implemented Interfaces:
Serializable, EachOperation, Function, Operation

public class TuplifyArgs extends BaseFunction
See Also:
  • Constructor Details

    • TuplifyArgs

      public TuplifyArgs()
  • Method Details

    • execute

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