Uses of Class
org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus

Packages that use WatermarkStatus

Package	Description
org.apache.flink.runtime.asyncprocessing.operators
org.apache.flink.state.api.output.operators
org.apache.flink.streaming.api.operators
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.multipleinput.input
org.apache.flink.table.runtime.operators.multipleinput.output
org.apache.flink.table.runtime.operators.wmassigners

Uses of WatermarkStatus in org.apache.flink.runtime.asyncprocessing.operators

Methods in org.apache.flink.runtime.asyncprocessing.operators with parameters of type WatermarkStatus

Modifier and Type	Method	Description
void	AbstractAsyncStateStreamOperator.processWatermarkStatus(WatermarkStatus watermarkStatus)
void	AbstractAsyncStateStreamOperatorV2.processWatermarkStatus(WatermarkStatus watermarkStatus, int inputId)

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

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

Modifier and Type	Method	Description
void	StateBootstrapWrapperOperator.processWatermarkStatus(WatermarkStatus watermarkStatus)

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

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

Modifier and Type	Method	Description
void	CountingOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	Output.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	TimestampedCollector.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	AbstractInput.processWatermarkStatus(WatermarkStatus watermarkStatus)
void	AbstractStreamOperator.processWatermarkStatus(WatermarkStatus watermarkStatus)
void	AbstractStreamOperatorV2.processWatermarkStatus(WatermarkStatus watermarkStatus, int inputId)
void	Input.processWatermarkStatus(WatermarkStatus watermarkStatus)	Processes a WatermarkStatus that arrived on this input of the MultipleInputStreamOperator.
void	AbstractStreamOperator.processWatermarkStatus1(WatermarkStatus watermarkStatus)
void	TwoInputStreamOperator.processWatermarkStatus1(WatermarkStatus watermarkStatus)	Processes a WatermarkStatus that arrived on the first input of this two-input operator.
void	AbstractStreamOperator.processWatermarkStatus2(WatermarkStatus watermarkStatus)
void	TwoInputStreamOperator.processWatermarkStatus2(WatermarkStatus watermarkStatus)	Processes a WatermarkStatus that arrived on the second input of this two-input operator.

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

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

Modifier and Type	Method	Description
void	FinishedDataOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	PushingAsyncDataInput.DataOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	RecordWriterOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)

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

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

Modifier and Type	Method	Description
void	TimestampsAndWatermarksOperator.processWatermarkStatus(WatermarkStatus watermarkStatus)	Override the base implementation to completely ignore statuses propagated from upstream.

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

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

Modifier and Type	Method	Description
WatermarkStatus	StreamElement.asWatermarkStatus()	Casts this element into a WatermarkStatus.

Uses of WatermarkStatus in org.apache.flink.streaming.runtime.tasks

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

Modifier and Type	Method	Description
void	FinishedOnRestoreMainOperatorOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	SourceOperatorStreamTask.AsyncDataOutputToOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	FinishedOnRestoreInput.processWatermarkStatus(WatermarkStatus watermarkStatus)

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

Fields in org.apache.flink.streaming.runtime.watermarkstatus declared as WatermarkStatus

Modifier and Type	Field	Description
static WatermarkStatus	WatermarkStatus.ACTIVE
static WatermarkStatus	WatermarkStatus.IDLE
protected WatermarkStatus	StatusWatermarkValve.SubpartitionStatus.watermarkStatus

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

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

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

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

Modifier and Type	Method	Description
void	FirstInputOfTwoInput.processWatermarkStatus(WatermarkStatus watermarkStatus)
void	OneInput.processWatermarkStatus(WatermarkStatus watermarkStatus)
void	SecondInputOfTwoInput.processWatermarkStatus(WatermarkStatus watermarkStatus)

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

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

Modifier and Type	Method	Description
void	BroadcastingOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	CopyingSecondInputOfTwoInputStreamOperatorOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	FirstInputOfTwoInputStreamOperatorOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	OneInputStreamOperatorOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)
void	SecondInputOfTwoInputStreamOperatorOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus)

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

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

Modifier and Type	Method	Description
void	WatermarkAssignerOperator.processWatermarkStatus(WatermarkStatus watermarkStatus)