embodies the logic of how
are propagated to downstream outputs, given a set of one or multiple input
channels that continuously receive them.
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.
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.