Class | Description |
---|---|
StatusWatermarkValve |
A
StatusWatermarkValve embodies the logic of how Watermark and WatermarkStatus are propagated to downstream outputs, given a set of one or multiple input
channels that continuously receive them. |
StatusWatermarkValve.InputChannelStatus |
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. |
WatermarkStatus |
A Watermark Status element informs stream tasks whether or not they should continue to expect
watermarks from the input stream that sent them.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.