org.apache.flink.streaming.runtime.operators

Class TimestampsAndWatermarksOperator.WatermarkEmitter

java.lang.Object

org.apache.flink.streaming.runtime.operators.TimestampsAndWatermarksOperator.WatermarkEmitter

All Implemented Interfaces:

WatermarkOutput

Enclosing class:

TimestampsAndWatermarksOperator<T>

public static final class TimestampsAndWatermarksOperator.WatermarkEmitter
extends Object
implements WatermarkOutput

Implementation of the WatermarkEmitter, based on the components that are available inside a stream operator.

Constructor Summary

Constructors

Constructor and Description
WatermarkEmitter(Output<?> output)

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

WatermarkEmitter

public WatermarkEmitter(Output<?> output)

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