com.google.cloud.dataflow.sdk.util.state

Interface WatermarkStateInternal

All Superinterfaces:

MergeableState<org.joda.time.Instant,org.joda.time.Instant>, State

@Experimental(value=STATE)
public interface WatermarkStateInternal
extends MergeableState<org.joda.time.Instant,org.joda.time.Instant>

State for holding up the watermark to the minimum of input Instants.

This is intended for internal use only. The watermark will be held up based on the values that are added and only released when items are cleared.

Method Summary

Methods inherited from interface com.google.cloud.dataflow.sdk.util.state.MergeableState

add, get, isEmpty

Methods inherited from interface com.google.cloud.dataflow.sdk.util.state.State

clear