Package org.apache.flink.streaming.runtime.streamstatus

Interface Summary

Interface	Description
StatusWatermarkValve.ValveOutputHandler	Usages of StatusWatermarkValve should implement a ValveOutputHandler to handle watermark and stream status outputs from the valve.
StreamStatusMaintainer	Interface that allows toggling the current StreamStatus as well as retrieving it.
StreamStatusProvider	Interface for retrieving the current StreamStatus.

Class Summary

Class	Description
StatusWatermarkValve	A StatusWatermarkValve embodies the logic of how Watermark and StreamStatus 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.
StreamStatus	A Stream Status element informs stream tasks whether or not they should continue to expect records and watermarks from the input stream that sent them.