public class WatermarkManager.TransformWatermarks
extends java.lang.Object
AppliedPTransform
.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() |
public Instant getInputWatermark()
AppliedPTransform
.public Instant getOutputWatermark()
AppliedPTransform
.public Instant getSynchronizedProcessingInputTime()
AppliedPTransform
.
The returned value is guaranteed to be monotonically increasing, and outside of the presence of holds, will increase as the system time progresses.
public Instant getSynchronizedProcessingOutputTime()
AppliedPTransform
.
The returned value is guaranteed to be monotonically increasing, and outside of the presence of holds, will increase as the system time progresses.
public java.lang.String toString()
toString
in class java.lang.Object