Package org.apache.nemo.common.ir.vertex.transform

Class SignalTransform

java.lang.Object

org.apache.nemo.common.ir.vertex.transform.NoWatermarkEmitTransform<java.lang.Void,java.lang.Void>

org.apache.nemo.common.ir.vertex.transform.SignalTransform

All Implemented Interfaces:

java.io.Serializable, Transform<java.lang.Void,java.lang.Void>

public final class SignalTransform
extends NoWatermarkEmitTransform<java.lang.Void,java.lang.Void>

This class evokes run-time pass when there's no need to transfer any run-time information.

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
SignalTransform()

Method Summary

Modifier and Type	Method	Description
void	close()	Close the transform.
void	onData(java.lang.Void element)	On data received.
void	prepare(Transform.Context context, OutputCollector<java.lang.Void> oc)	Prepare the transform.
java.lang.String	toString()

Methods inherited from class org.apache.nemo.common.ir.vertex.transform.NoWatermarkEmitTransform

onLatencymark, onWatermark

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SignalTransform

public SignalTransform()

Method Detail

prepare

public void prepare(Transform.Context context,
                    OutputCollector<java.lang.Void> oc)

Description copied from interface: Transform

Prepare the transform.

Parameters:

context - of the transform.

oc - that collects outputs.

onData

public void onData(java.lang.Void 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.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object