@VisibleForTesting protected static class StatusWatermarkValve.InputChannelStatus extends Object
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:
Modifier and Type | Field and Description |
---|---|
protected boolean |
isWatermarkAligned |
protected long |
watermark |
protected WatermarkStatus |
watermarkStatus |
Modifier | Constructor and Description |
---|---|
protected |
InputChannelStatus() |
protected long watermark
protected WatermarkStatus watermarkStatus
protected boolean isWatermarkAligned
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.