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

Packages that use Watermark

Package	Description
org.apache.flink.connector.file.table.stream
org.apache.flink.state.api.output.operators
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.co
org.apache.flink.streaming.api.operators.python
org.apache.flink.streaming.api.operators.python.embedded
org.apache.flink.streaming.api.operators.python.process
org.apache.flink.streaming.api.operators.sorted.state
org.apache.flink.streaming.api.watermark
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.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.runtime.watermarkstatus
org.apache.flink.table.runtime.operators
org.apache.flink.table.runtime.operators.aggregate.window
org.apache.flink.table.runtime.operators.bundle
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.multipleinput.input
org.apache.flink.table.runtime.operators.multipleinput.output
org.apache.flink.table.runtime.operators.sink
org.apache.flink.table.runtime.operators.source
org.apache.flink.table.runtime.operators.window.slicing
org.apache.flink.table.runtime.operators.wmassigners
org.apache.flink.table.sources.wmstrategies

Uses of Watermark in org.apache.flink.connector.file.table.stream

Methods in org.apache.flink.connector.file.table.stream with parameters of type Watermark

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

Uses of Watermark in org.apache.flink.state.api.output.operators

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

Modifier and Type	Method and Description
void	StateBootstrapWrapperOperator.processWatermark(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) Deprecated. Asks this implementation if it wants to emit a watermark.
Watermark	AssignerWithPeriodicWatermarks.getCurrentWatermark() Deprecated. Returns the current watermark.
Watermark	IngestionTimeExtractor.getCurrentWatermark() Deprecated.

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	BoundedOutOfOrdernessTimestampExtractor.getCurrentWatermark()
Watermark	AscendingTimestampExtractor.getCurrentWatermark() Deprecated.

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	InternalTimeServiceManagerImpl.advanceWatermark(Watermark watermark)
void	InternalTimeServiceManager.advanceWatermark(Watermark watermark) Advances the Watermark of all managed timer services, potentially firing event time timers.
void	TimestampedCollector.emitWatermark(Watermark mark)
void	Output.emitWatermark(Watermark mark) Emits a Watermark from an operator.
void	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	AbstractInput.processWatermark(Watermark mark)
void	Input.processWatermark(Watermark mark) Processes a Watermark that arrived on the first input of this two-input operator.
void	AbstractStreamOperator.processWatermark(Watermark mark)
void	AbstractStreamOperatorV2.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)
protected void	AbstractStreamOperatorV2.reportWatermark(Watermark mark, int inputId)

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.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.operators.python

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

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

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

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

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

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

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

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

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

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

Modifier and Type	Method and Description
void	BatchExecutionInternalTimeServiceManager.advanceWatermark(Watermark watermark)

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.
static Watermark	Watermark.UNINITIALIZED The watermark that signifies is used before any actual watermark has been generated.

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	PushingAsyncDataInput.DataOutput.emitWatermark(Watermark watermark)
void	RecordWriterOutput.emitWatermark(Watermark mark)
void	FinishedDataOutput.emitWatermark(Watermark watermark)

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	TimestampsAndWatermarksOperator.processWatermark(Watermark mark) Override the base implementation to completely ignore watermarks propagated from upstream, except for the "end of time" watermark.

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

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

Modifier and Type	Method and Description
void	SourceOperatorStreamTask.AsyncDataOutputToOutput.emitWatermark(Watermark watermark)
void	FinishedOnRestoreMainOperatorOutput.emitWatermark(Watermark mark)
void	FinishedOnRestoreInput.processWatermark(Watermark watermark)

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

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

Modifier and Type	Method and Description
void	StatusWatermarkValve.inputWatermark(Watermark watermark, int channelIndex, PushingAsyncDataInput.DataOutput<?> output) Feed a Watermark into the valve.

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

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

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

Uses of Watermark in org.apache.flink.table.runtime.operators.aggregate.window

Methods in org.apache.flink.table.runtime.operators.aggregate.window with parameters of type Watermark

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

Uses of Watermark in org.apache.flink.table.runtime.operators.bundle

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

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

Uses of Watermark in org.apache.flink.table.runtime.operators.join

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

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

Uses of Watermark in org.apache.flink.table.runtime.operators.multipleinput.input

Methods in org.apache.flink.table.runtime.operators.multipleinput.input with parameters of type Watermark

Modifier and Type	Method and Description
void	OneInput.processWatermark(Watermark mark)
void	FirstInputOfTwoInput.processWatermark(Watermark mark)
void	SecondInputOfTwoInput.processWatermark(Watermark mark)

Uses of Watermark in org.apache.flink.table.runtime.operators.multipleinput.output

Methods in org.apache.flink.table.runtime.operators.multipleinput.output with parameters of type Watermark

Modifier and Type	Method and Description
void	OneInputStreamOperatorOutput.emitWatermark(Watermark mark)
void	CopyingSecondInputOfTwoInputStreamOperatorOutput.emitWatermark(Watermark mark)
void	BroadcastingOutput.emitWatermark(Watermark mark)
void	FirstInputOfTwoInputStreamOperatorOutput.emitWatermark(Watermark mark)
void	SecondInputOfTwoInputStreamOperatorOutput.emitWatermark(Watermark mark)

Uses of Watermark in org.apache.flink.table.runtime.operators.sink

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

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

Uses of Watermark in org.apache.flink.table.runtime.operators.source

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

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

Uses of Watermark in org.apache.flink.table.runtime.operators.window.slicing

Methods in org.apache.flink.table.runtime.operators.window.slicing with parameters of type Watermark

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

Uses of Watermark in org.apache.flink.table.runtime.operators.wmassigners

Methods in org.apache.flink.table.runtime.operators.wmassigners that return Watermark

Modifier and Type	Method and Description
Watermark	PunctuatedWatermarkAssignerWrapper.checkAndGetNextWatermark(RowData row, long extractedTimestamp)
Watermark	PeriodicWatermarkAssignerWrapper.getCurrentWatermark()

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

Modifier and Type	Method and Description
void	RowTimeMiniBatchAssginerOperator.processWatermark(Watermark mark)
void	WatermarkAssignerOperator.processWatermark(Watermark mark) Override the base implementation to completely ignore watermarks propagated from upstream (we rely only on the WatermarkGenerator to emit watermarks from here).
void	ProcTimeMiniBatchAssignerOperator.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).

Uses of Watermark in org.apache.flink.table.sources.wmstrategies

Methods in org.apache.flink.table.sources.wmstrategies that return Watermark

Modifier and Type	Method and Description
Watermark	AscendingTimestamps.getWatermark()
Watermark	BoundedOutOfOrderTimestamps.getWatermark()
abstract Watermark	PeriodicWatermarkAssigner.getWatermark() Returns the current watermark.
abstract Watermark	PunctuatedWatermarkAssigner.getWatermark(Row row, long timestamp) Returns the watermark for the current row or null if no watermark should be generated.