Interface RamaOperation6<T0,T1,T2,T3,T4,T5>

All Superinterfaces:
RamaOperation, RamaSerializable, Serializable

public interface RamaOperation6<T0,T1,T2,T3,T4,T5> extends RamaOperation
Interface for custom operation implementation of six arguments. An operation emits zero or more times to any number of output streams.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    invoke(T0 arg0, T1 arg1, T2 arg2, T3 arg3, T4 arg4, T5 arg5, OutputCollector collector)
    Executes operation and emits results by calling methods on the provided OutputCollector
  • Method Details

    • invoke

      void invoke(T0 arg0, T1 arg1, T2 arg2, T3 arg3, T4 arg4, T5 arg5, OutputCollector collector)
      Executes operation and emits results by calling methods on the provided OutputCollector
      Parameters:
      collector - Emits results back to caller of operation