Package com.rpl.rama.ops

Interface RamaOperation0

All Superinterfaces:
RamaOperation, RamaSerializable, Serializable
public interface RamaOperation0 extends RamaOperation
Interface for custom operation implementation of zero arguments. An operation emits zero or more times to any number of output streams.

  • Method Summary

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

  • Method Details

    • invoke

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