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 withHeapPriorityQueue
.StatusWatermarkValve AStatusWatermarkValve
embodies the logic of howWatermark
andWatermarkStatus
are propagated to downstream outputs, given a set of one or multiple subpartitions that continuously receive them.StatusWatermarkValve.SubpartitionStatus AnSubpartitionStatus
keeps track of a subpartition's last watermark, stream status, and whether or not the subpartition'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.