Uses of Interface
org.apache.flink.api.common.eventtime.WatermarkOutput

Packages that use WatermarkOutput

Package	Description
org.apache.flink.api.common.eventtime
org.apache.flink.api.connector.source

Uses of WatermarkOutput in org.apache.flink.api.common.eventtime

Methods in org.apache.flink.api.common.eventtime that return WatermarkOutput

Modifier and Type	Method	Description
WatermarkOutput	WatermarkOutputMultiplexer.getDeferredOutput(String outputId)	Returns a deferred WatermarkOutput for the given output ID.
WatermarkOutput	WatermarkOutputMultiplexer.getImmediateOutput(String outputId)	Returns an immediate WatermarkOutput for the given output ID.

Methods in org.apache.flink.api.common.eventtime with parameters of type WatermarkOutput

Modifier and Type	Method	Description
void	BoundedOutOfOrdernessWatermarks.onEvent(T event, long eventTimestamp, WatermarkOutput output)
void	NoWatermarksGenerator.onEvent(E event, long eventTimestamp, WatermarkOutput output)
void	WatermarkGenerator.onEvent(T event, long eventTimestamp, WatermarkOutput output)	Called for every event, allows the watermark generator to examine and remember the event timestamps, or to emit a watermark based on the event itself.
void	WatermarksWithIdleness.onEvent(T event, long eventTimestamp, WatermarkOutput output)
void	BoundedOutOfOrdernessWatermarks.onPeriodicEmit(WatermarkOutput output)
void	NoWatermarksGenerator.onPeriodicEmit(WatermarkOutput output)
void	WatermarkGenerator.onPeriodicEmit(WatermarkOutput output)	Called periodically, and might emit a new watermark, or not.
void	WatermarksWithIdleness.onPeriodicEmit(WatermarkOutput output)

Constructors in org.apache.flink.api.common.eventtime with parameters of type WatermarkOutput

Constructor	Description
WatermarkOutputMultiplexer(WatermarkOutput underlyingOutput)	Creates a new WatermarkOutputMultiplexer that emits combined updates to the given WatermarkOutput.

Uses of WatermarkOutput in org.apache.flink.api.connector.source

Subinterfaces of WatermarkOutput in org.apache.flink.api.connector.source

Modifier and Type	Interface	Description
interface	ReaderOutput<T>	The interface provided by the Flink runtime to the SourceReader to emit records, and optionally watermarks, to downstream operators for message processing.
interface	SourceOutput<T>	The SourceOutput is the gateway for a SourceReader) to emit the produced records and watermarks.