org.apache.flink.streaming.runtime.streamstatus

Class StatusWatermarkValve.InputChannelStatus

java.lang.Object

org.apache.flink.streaming.runtime.streamstatus.StatusWatermarkValve.InputChannelStatus

Enclosing class:

StatusWatermarkValve

@VisibleForTesting
protected static class StatusWatermarkValve.InputChannelStatus
extends Object

An InputChannelStatus keeps track of an input channel's last watermark, stream status, and whether or not the channel's current watermark is aligned with the overall watermark output from the valve.

There are 2 situations where a channel's watermark is not considered aligned:

• the current stream status of the channel is idle
• the stream status has resumed to be active, but the watermark of the channel hasn't caught up to the last output watermark from the valve yet.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	isWatermarkAligned
protected StreamStatus	streamStatus
protected long	watermark

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	InputChannelStatus()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

watermark

protected long watermark

streamStatus

protected StreamStatus streamStatus

isWatermarkAligned

protected boolean isWatermarkAligned

Constructor Detail

InputChannelStatus

protected InputChannelStatus()