Package com.rpl.rama.ops

Interface RamaOperation1<T0>

All Superinterfaces:
RamaOperation, RamaSerializable, Serializable
public interface RamaOperation1<T0> extends RamaOperation
Interface for custom operation implementation of one argument. An operation emits zero or more times to any number of output streams.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    invoke(T0 arg0, OutputCollector collector)
    Executes operation and emits results by calling methods on the provided OutputCollector

  • Method Details

    • invoke

      void invoke(T0 arg0, OutputCollector collector)
      Executes operation and emits results by calling methods on the provided OutputCollector
      Parameters:
      collector - Emits results back to caller of operation