WatermarkHoldState (core 2.44.0 API)

All Superinterfaces:

GroupingState<org.joda.time.Instant,org.joda.time.Instant>, ReadableState<org.joda.time.Instant>, State
```
@Internal
public interface WatermarkHoldState
extends GroupingState<org.joda.time.Instant,org.joda.time.Instant>
```
For internal use only; no backwards-compatibility guarantees.
A State accepting and aggregating timestamps according to a TimestampCombiner, holding the output watermark to the resulting timestamp.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`TimestampCombiner`	`getTimestampCombiner()`	Return the `TimestampCombiner` which 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.
`WatermarkHoldState`	`readLater()`	Indicate that the value will be read later.

Methods inherited from interface org.apache.beam.sdk.state.GroupingState
add, isEmpty

Methods inherited from interface org.apache.beam.sdk.state.ReadableState
read

Methods inherited from interface org.apache.beam.sdk.state.State
clear

- Method Detail
  - getTimestampCombiner
```
TimestampCombiner getTimestampCombiner()
```
    Return the TimestampCombiner which 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.
  - readLater
```
WatermarkHoldState readLater()
```
    Description copied from interface: ReadableState
    
    Indicate that the value will be read later.
    This allows an implementation to start an asynchronous prefetch or to include this state in the next batch of reads.
    
    Specified by:
    
    readLater in interface GroupingState<org.joda.time.Instant,org.joda.time.Instant>
    
    Specified by:
    
    readLater in interface ReadableState<org.joda.time.Instant>
    
    Returns:
    
    this for convenient chaining