Class StreamTransform<T>
- java.lang.Object
-
- org.apache.nemo.common.ir.vertex.transform.LatencymarkEmitTransform<T,T>
-
- org.apache.nemo.common.ir.vertex.transform.StreamTransform<T>
-
- Type Parameters:
T
- input/output type.
- All Implemented Interfaces:
java.io.Serializable
,Transform<T,T>
public final class StreamTransform<T> extends LatencymarkEmitTransform<T,T>
ATransform
relays input data from upstream vertex to downstream vertex promptly. This transform can be used for merging input data into theOutputCollector
.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.nemo.common.ir.vertex.transform.Transform
Transform.Context
-
-
Constructor Summary
Constructors Constructor Description StreamTransform()
Default constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Close the transform.void
onData(T element)
On data received.void
onWatermark(Watermark watermark)
On watermark received.java.lang.String
toString()
-
Methods inherited from class org.apache.nemo.common.ir.vertex.transform.LatencymarkEmitTransform
getOutputCollector, onLatencymark, prepare
-
-
-
-
Method Detail
-
onData
public void onData(T element)
Description copied from interface:Transform
On data received.- Parameters:
element
- data received.
-
onWatermark
public void onWatermark(Watermark watermark)
Description copied from interface:Transform
On watermark received. This method should be called for the minimum watermark among input streams (input watermark). Transform may emit collected data after receiving watermarks.- Parameters:
watermark
- watermark
-
close
public void close()
Description copied from interface:Transform
Close the transform.
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-