com.rpl.rama.ops

Interface RamaOperation

All Superinterfaces:

RamaSerializable, java.io.Serializable

All Known Subinterfaces:

RamaOperation0, RamaOperation1<T0>, RamaOperation2<T0,T1>, RamaOperation3<T0,T1,T2>, RamaOperation4<T0,T1,T2,T3>, RamaOperation5<T0,T1,T2,T3,T4>, RamaOperation6<T0,T1,T2,T3,T4,T5>, RamaOperation7<T0,T1,T2,T3,T4,T5,T6>, RamaOperation8<T0,T1,T2,T3,T4,T5,T6,T7>

public interface RamaOperation
extends RamaSerializable

Base interface for custom operation implementations. An operation takes in input arguments and emits zero or more times to any number of output streams.