Package org.apache.nemo.common.ir.vertex.transform
-
Interface Summary Interface Description Transform<I,O> Interface for specifying 'What' to do with data.Transform.Context Context of the transform. -
Class Summary Class Description LatencymarkEmitTransform<I,O> This transform emitsLatencyMark
.MessageAggregatorTransform<K,V,O> ATransform
that aggregates statistics generated by theMessageGeneratorTransform
.MessageGeneratorTransform<I,K,V> ATransform
for the message generator vertex.NoWatermarkEmitTransform<I,O> This transform does not emit watermarks.SignalTransform This class evokes run-time pass when there's no need to transfer any run-time information.StreamTransform<T> ATransform
relays input data from upstream vertex to downstream vertex promptly.