All Superinterfaces: RamaOperation, RamaSerializable, Serializable


public interface RamaOperation3<T0,T1,T2> extends [RamaOperation](/content/javadoc/com/rpl/rama/ops/RamaOperation.html "interface in com.rpl.rama.ops"/index.html)

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

Method Summary

All MethodsInstance MethodsAbstract Methods

Modifier and Type Method Description
void invoke(T0 arg0, T1 arg1, T2 arg2, OutputCollector collector) Executes operation and emits results by calling methods on the provided [OutputCollector](/content/javadoc/com/rpl/rama/ops/OutputCollector.html "interface in com.rpl.rama.ops"/index.html)

Method Details

  • invoke )

void invoke([T0](/content/javadoc/com/rpl/rama/ops/RamaOperation3.html "type parameter in RamaOperation3"/index.html) arg0, [T1](/content/javadoc/com/rpl/rama/ops/RamaOperation3.html "type parameter in RamaOperation3"/index.html) arg1, [T2](/content/javadoc/com/rpl/rama/ops/RamaOperation3.html "type parameter in RamaOperation3"/index.html) arg2, [OutputCollector](/content/javadoc/com/rpl/rama/ops/OutputCollector.html "interface in com.rpl.rama.ops"/index.html) collector)

Executes operation and emits results by calling methods on the provided [OutputCollector](/content/javadoc/com/rpl/rama/ops/OutputCollector.html "interface in com.rpl.rama.ops"/index.html)

Parameters:

collector - Emits results back to caller of operation