org.apache.beam.runners.direct

Class WatermarkManager.TransformWatermarks

java.lang.Object

org.apache.beam.runners.direct.WatermarkManager.TransformWatermarks

Enclosing class:

WatermarkManager<ExecutableT,CollectionT>

public class WatermarkManager.TransformWatermarks
extends java.lang.Object

A reference to the input and output watermarks of an AppliedPTransform.

Method Summary

Modifier and Type	Method and Description
Instant	getInputWatermark() Returns the input watermark of the AppliedPTransform.
Instant	getOutputWatermark() Returns the output watermark of the AppliedPTransform.
Instant	getSynchronizedProcessingInputTime() Returns the synchronized processing input time of the AppliedPTransform.
Instant	getSynchronizedProcessingOutputTime() Returns the synchronized processing output time of the AppliedPTransform.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

getInputWatermark

public Instant getInputWatermark()

Returns the input watermark of the AppliedPTransform.

getOutputWatermark

public Instant getOutputWatermark()

Returns the output watermark of the AppliedPTransform.

getSynchronizedProcessingInputTime

public Instant getSynchronizedProcessingInputTime()

Returns the synchronized processing input time of the AppliedPTransform.

The returned value is guaranteed to be monotonically increasing, and outside of the presence of holds, will increase as the system time progresses.

getSynchronizedProcessingOutputTime

public Instant getSynchronizedProcessingOutputTime()

Returns the synchronized processing output time of the AppliedPTransform.

The returned value is guaranteed to be monotonically increasing, and outside of the presence of holds, will increase as the system time progresses.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object