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

Class NoWatermarkEmitTransform<I,O>

java.lang.Object

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

Type Parameters:

I - input type

O - output type

All Implemented Interfaces:

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

Direct Known Subclasses:

CombineFnFinalTransform, CombineFnPartialTransform, EmptyComponents.EmptyTransform, GroupByKeyTransform, MessageAggregatorTransform, MessageGeneratorTransform, SignalTransform

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

This transform does not emit watermarks. It may be a transform for batch operation that emits collected data when calling Transform.close().

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

Method Summary

Modifier and Type	Method	Description
void	onLatencymark(LatencyMark latencymark)	On latencymark received.
void	onWatermark(Watermark watermark)	On watermark received.

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, prepare

Constructor Detail

NoWatermarkEmitTransform

public NoWatermarkEmitTransform()

Method Detail

onWatermark

public final 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 interface Transform<I,O>

Parameters:

watermark - watermark

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.