com.rpl.rama.ops

Interface RamaOperation8<T0,T1,T2,T3,T4,T5,T6,T7>

All Superinterfaces:

RamaOperation, RamaSerializable, java.io.Serializable

public interface RamaOperation8<T0,T1,T2,T3,T4,T5,T6,T7>
extends RamaOperation

Interface for custom operation implementation of eight arguments. An operation emits zero or more times to any number of output streams.

Method Summary

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

Method Detail

invoke

void invoke(T0 arg0,
            T1 arg1,
            T2 arg2,
            T3 arg3,
            T4 arg4,
            T5 arg5,
            T6 arg6,
            T7 arg7,
            OutputCollector collector)

Executes operation and emits results by calling methods on the provided OutputCollector

Parameters:

collector - Emits results back to caller of operation