Class StreamTransform<T>
- java.lang.Object
-
- org.apache.nemo.common.ir.vertex.transform.StreamTransform<T>
-
- Type Parameters:
T
- input/output type.
- All Implemented Interfaces:
Serializable
,Transform<T,T>
public final class StreamTransform<T> extends Object implements Transform<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.void
prepare(Transform.Context context, OutputCollector<T> oc)
Prepare the transform.String
toString()
-
-
-
Method Detail
-
prepare
public void prepare(Transform.Context context, OutputCollector<T> oc)
Description copied from interface:Transform
Prepare the transform.
-
onData
public void onData(T element)
Description copied from interface:Transform
On 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.- Specified by:
onWatermark
in interfaceTransform<T,T>
- Parameters:
watermark
- watermark
-
close
public void close()
Description copied from interface:Transform
Close the transform.
-
-