org.apache.flink.streaming.api.operators.source

Class WatermarkToDataOutput

java.lang.Object

org.apache.flink.streaming.api.operators.source.WatermarkToDataOutput

All Implemented Interfaces:

WatermarkOutput

@Internal
public final class WatermarkToDataOutput
extends Object
implements WatermarkOutput

An adapter that exposes a WatermarkOutput based on a PushingAsyncDataInput.DataOutput.

Constructor Summary

Constructors

Constructor and Description
WatermarkToDataOutput(PushingAsyncDataInput.DataOutput<?> output)
WatermarkToDataOutput(PushingAsyncDataInput.DataOutput<?> output, TimestampsAndWatermarks.WatermarkUpdateListener watermarkEmitted) Creates a new WatermarkOutput against the given DataOutput.

Method Summary

Modifier and Type	Method and Description
void	emitWatermark(Watermark watermark) Emits the given watermark.
void	markActive() Marks this output as active, meaning that downstream operations should wait for watermarks from this output.
void	markIdle() Marks this output as idle, meaning that downstream operations do not wait for watermarks from this output.

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkToDataOutput

@VisibleForTesting
public WatermarkToDataOutput(PushingAsyncDataInput.DataOutput<?> output)

WatermarkToDataOutput

public WatermarkToDataOutput(PushingAsyncDataInput.DataOutput<?> output,
                             TimestampsAndWatermarks.WatermarkUpdateListener watermarkEmitted)

Creates a new WatermarkOutput against the given DataOutput.

Method Detail

emitWatermark

public void emitWatermark(Watermark watermark)

Description copied from interface: WatermarkOutput

Emits the given watermark.

Emitting a watermark also implicitly marks the stream as active, ending previously marked idleness.

Specified by:

emitWatermark in interface WatermarkOutput

markIdle

public void markIdle()

Description copied from interface: WatermarkOutput

Marks this output as idle, meaning that downstream operations do not wait for watermarks from this output.

An output becomes active again as soon as the next watermark is emitted or WatermarkOutput.markActive() is explicitly called.

Specified by:

markIdle in interface WatermarkOutput

markActive

public void markActive()

Description copied from interface: WatermarkOutput

Marks this output as active, meaning that downstream operations should wait for watermarks from this output.

Specified by:

markActive in interface WatermarkOutput