Class TridentReach.ExpandList

All Implemented Interfaces:
Serializable, EachOperation, Function, Operation
Enclosing class:
TridentReach

public static class TridentReach.ExpandList extends BaseFunction
See Also:
  • Constructor Details

    • ExpandList

      public ExpandList()
  • 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.
      Parameters:
      tuple - The incoming tuple
      collector - A collector instance that can be used to emit tuples