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

Class LatencymarkEmitTransform<I,O>

java.lang.Object

org.apache.nemo.common.ir.vertex.transform.LatencymarkEmitTransform<I,O>

Type Parameters:

I - input type

O - output type

All Implemented Interfaces:

java.io.Serializable, Transform<I,O>

Direct Known Subclasses:

CreateViewTransform, FlattenTransform, SideInputTransform, StreamTransform, WindowFnTransform

public abstract class LatencymarkEmitTransform<I,O>
extends java.lang.Object
implements Transform<I,O>

This transform emits LatencyMark.

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

Method Summary

Modifier and Type	Method	Description
OutputCollector<O>	getOutputCollector()	get OutputCollector.
void	onLatencymark(LatencyMark latencymark)	On latencymark received.
void	prepare(Transform.Context context, OutputCollector<O> oc)	Prepare the transform.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nemo.common.ir.vertex.transform.Transform

close, onData, onWatermark

Constructor Detail

LatencymarkEmitTransform

public LatencymarkEmitTransform()

Method Detail

prepare

public void prepare(Transform.Context context,
                    OutputCollector<O> oc)

Description copied from interface: Transform

Prepare the transform.

Specified by:

prepare in interface Transform<I,O>

Parameters:

context - context for data transfer.

oc - OutputCollector to transfer data.

getOutputCollector

public OutputCollector<O> getOutputCollector()

get OutputCollector.

Returns:

the output collector.

onLatencymark

public final void onLatencymark(LatencyMark latencymark)

Description copied from interface: Transform

On latencymark received.

Specified by:

onLatencymark in interface Transform<I,O>

Parameters:

latencymark - latencymark