Package org.apache.flink.streaming.runtime.watermarkstatus

Class Summary

Class	Description
HeapPriorityQueue<T extends org.apache.flink.streaming.runtime.watermarkstatus.HeapPriorityQueue.HeapPriorityQueueElement>	This class has similar functions with HeapPriorityQueue.
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.