Package org.apache.nemo.common.test
Class EmptyComponents.EmptyTransform<I,O>
- java.lang.Object
-
- org.apache.nemo.common.ir.vertex.transform.NoWatermarkEmitTransform<I,O>
-
- org.apache.nemo.common.test.EmptyComponents.EmptyTransform<I,O>
-
- Type Parameters:
I
- input type.O
- output type.
- All Implemented Interfaces:
java.io.Serializable
,Transform<I,O>
- Enclosing class:
- EmptyComponents
public static class EmptyComponents.EmptyTransform<I,O> extends NoWatermarkEmitTransform<I,O>
An empty transform.- 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 EmptyTransform(java.lang.String name)
Default constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Close the transform.void
onData(I element)
On data received.void
prepare(Transform.Context context, OutputCollector<O> outputCollector)
Prepare the transform.java.lang.String
toString()
-
Methods inherited from class org.apache.nemo.common.ir.vertex.transform.NoWatermarkEmitTransform
onLatencymark, onWatermark
-
-
-
-
Method Detail
-
toString
public final java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
prepare
public void prepare(Transform.Context context, OutputCollector<O> outputCollector)
Description copied from interface:Transform
Prepare the transform.- Parameters:
context
- of the transform.outputCollector
- that collects outputs.
-
onData
public void onData(I element)
Description copied from interface:Transform
On data received.- Parameters:
element
- data received.
-
close
public void close()
Description copied from interface:Transform
Close the transform.
-
-