Uses of Class
org.apache.flink.streaming.api.watermark.Watermark

Packages that use Watermark

Package	Description
org.apache.flink.streaming.api.collector.selector
org.apache.flink.streaming.api.functions
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.functions.timestamps
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.api.operators.async.queue
org.apache.flink.streaming.api.operators.co
org.apache.flink.streaming.api.watermark
org.apache.flink.streaming.connectors.kafka.internals
org.apache.flink.streaming.kafka.test.base
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.operators	This package contains the operators that perform the stream transformations.
org.apache.flink.streaming.runtime.streamrecord
org.apache.flink.streaming.runtime.streamstatus

Uses of Watermark in org.apache.flink.streaming.api.collector.selector

Methods in org.apache.flink.streaming.api.collector.selector with parameters of type Watermark

Modifier and Type	Method and Description
void	DirectedOutput.emitWatermark(Watermark mark)

Uses of Watermark in org.apache.flink.streaming.api.functions

Methods in org.apache.flink.streaming.api.functions that return Watermark

Modifier and Type	Method and Description
Watermark	AssignerWithPunctuatedWatermarks.checkAndGetNextWatermark(T lastElement, long extractedTimestamp) Asks this implementation if it wants to emit a watermark.
Watermark	IngestionTimeExtractor.getCurrentWatermark()
Watermark	AssignerWithPeriodicWatermarks.getCurrentWatermark() Returns the current watermark.

Uses of Watermark in org.apache.flink.streaming.api.functions.source

Methods in org.apache.flink.streaming.api.functions.source with parameters of type Watermark

Modifier and Type	Method and Description
void	SourceFunction.SourceContext.emitWatermark(Watermark mark) Emits the given Watermark.
void	ContinuousFileReaderOperator.processWatermark(Watermark mark)

Uses of Watermark in org.apache.flink.streaming.api.functions.timestamps

Methods in org.apache.flink.streaming.api.functions.timestamps that return Watermark

Modifier and Type	Method and Description
Watermark	AscendingTimestampExtractor.getCurrentWatermark()
Watermark	BoundedOutOfOrdernessTimestampExtractor.getCurrentWatermark()

Uses of Watermark in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators with parameters of type Watermark

Modifier and Type	Method and Description
void	InternalTimeServiceManager.advanceWatermark(Watermark watermark)
void	Output.emitWatermark(Watermark mark) Emits a Watermark from an operator.
void	AbstractStreamOperator.CountingOutput.emitWatermark(Watermark mark)
void	OnWatermarkCallback.onWatermark(KEY key, Watermark watermark) The action to be triggered upon reception of a watermark.
void	ProcessOperator.processWatermark(Watermark mark)
void	StreamSink.processWatermark(Watermark mark)
void	OneInputStreamOperator.processWatermark(Watermark mark) Processes a Watermark.
void	AbstractStreamOperator.processWatermark(Watermark mark)
void	TwoInputStreamOperator.processWatermark1(Watermark mark) Processes a Watermark that arrived on the first input of this two-input operator.
void	AbstractStreamOperator.processWatermark1(Watermark mark)
void	TwoInputStreamOperator.processWatermark2(Watermark mark) Processes a Watermark that arrived on the second input of this two-input operator.
void	AbstractStreamOperator.processWatermark2(Watermark mark)

Uses of Watermark in org.apache.flink.streaming.api.operators.async

Methods in org.apache.flink.streaming.api.operators.async with parameters of type Watermark

Modifier and Type	Method and Description
void	AsyncWaitOperator.processWatermark(Watermark mark)

Uses of Watermark in org.apache.flink.streaming.api.operators.async.queue

Methods in org.apache.flink.streaming.api.operators.async.queue that return Watermark

Modifier and Type	Method and Description
Watermark	AsyncWatermarkResult.getWatermark() Get the resulting watermark.
Watermark	WatermarkQueueEntry.getWatermark()

Methods in org.apache.flink.streaming.api.operators.async.queue that return types with arguments of type Watermark

Modifier and Type	Method and Description
protected CompletableFuture<Watermark>	WatermarkQueueEntry.getFuture()

Constructors in org.apache.flink.streaming.api.operators.async.queue with parameters of type Watermark

Constructor and Description
WatermarkQueueEntry(Watermark watermark)

Uses of Watermark in org.apache.flink.streaming.api.operators.co

Methods in org.apache.flink.streaming.api.operators.co with parameters of type Watermark

Modifier and Type	Method and Description
void	CoProcessOperator.processWatermark(Watermark mark)
void	CoBroadcastWithNonKeyedOperator.processWatermark(Watermark mark)

Uses of Watermark in org.apache.flink.streaming.api.watermark

Fields in org.apache.flink.streaming.api.watermark declared as Watermark

Modifier and Type	Field and Description
static Watermark	Watermark.MAX_WATERMARK The watermark that signifies end-of-event-time.

Uses of Watermark in org.apache.flink.streaming.connectors.kafka.internals

Methods in org.apache.flink.streaming.connectors.kafka.internals that return Watermark

Modifier and Type	Method and Description
Watermark	KafkaTopicPartitionStateWithPunctuatedWatermarks.checkAndGetNewWatermark(T record, long timestamp)

Uses of Watermark in org.apache.flink.streaming.kafka.test.base

Methods in org.apache.flink.streaming.kafka.test.base that return Watermark

Modifier and Type	Method and Description
Watermark	CustomWatermarkExtractor.getCurrentWatermark()

Uses of Watermark in org.apache.flink.streaming.runtime.io

Methods in org.apache.flink.streaming.runtime.io with parameters of type Watermark

Modifier and Type	Method and Description
void	RecordWriterOutput.emitWatermark(Watermark mark)

Uses of Watermark in org.apache.flink.streaming.runtime.operators

Methods in org.apache.flink.streaming.runtime.operators with parameters of type Watermark

Modifier and Type	Method and Description
void	ExtractTimestampsOperator.processWatermark(Watermark mark) Deprecated.
void	TimestampsAndPeriodicWatermarksOperator.processWatermark(Watermark mark) Override the base implementation to completely ignore watermarks propagated from upstream (we rely only on the AssignerWithPeriodicWatermarks to emit watermarks from here).
void	TimestampsAndPunctuatedWatermarksOperator.processWatermark(Watermark mark) Override the base implementation to completely ignore watermarks propagated from upstream (we rely only on the AssignerWithPunctuatedWatermarks to emit watermarks from here).

Uses of Watermark in org.apache.flink.streaming.runtime.streamrecord

Methods in org.apache.flink.streaming.runtime.streamrecord that return Watermark

Modifier and Type	Method and Description
Watermark	StreamElement.asWatermark() Casts this element into a Watermark.

Uses of Watermark in org.apache.flink.streaming.runtime.streamstatus

Methods in org.apache.flink.streaming.runtime.streamstatus with parameters of type Watermark

Modifier and Type	Method and Description
void	StatusWatermarkValve.ValveOutputHandler.handleWatermark(Watermark watermark)
void	StatusWatermarkValve.inputWatermark(Watermark watermark, int channelIndex) Feed a Watermark into the valve.