@Internal public interface WatermarkHoldState extends GroupingState<Instant,Instant>
State accepting and aggregating timestamps according to a
holding the output watermark to the resulting timestamp.
|Modifier and Type||Method and Description|
Indicate that the value will be read later.
TimestampCombinerwhich will be used to determine a watermark hold time given an element timestamp, and to combine watermarks from windows which are about to be merged.
This allows an implementation to start an asynchronous prefetch or to include this state in the next batch of reads.