Package org.apache.nemo.compiler.frontend.beam.transform

Class FlattenTransform<T>

java.lang.Object

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

org.apache.nemo.compiler.frontend.beam.transform.FlattenTransform<T>

Type Parameters:

T - input/output type.

All Implemented Interfaces:

java.io.Serializable, Transform<T,T>

public final class FlattenTransform<T>
extends LatencymarkEmitTransform<T,T>

Flatten transform implementation.

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
FlattenTransform()	FlattenTransform Constructor.

Method Summary

Modifier and Type	Method	Description
void	close()	Close the transform.
void	onData(T element)	On data received.
void	onWatermark(Watermark watermark)	On watermark received.
java.lang.String	toString()

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

getOutputCollector, onLatencymark, prepare

Methods inherited from class java.lang.Object

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

Constructor Detail

FlattenTransform

public FlattenTransform()

FlattenTransform Constructor.

Method Detail

onData

public void onData(T element)

Description copied from interface: Transform

On data received.

Parameters:

element - 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.

Parameters:

watermark - watermark

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