Class TridentWordCount.Split

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

public static class TridentWordCount.Split extends BaseFunction
See Also:
  • Constructor Details

    • Split

      public Split()
  • 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