Package org.apache.beam.sdk.testing
Class TestStream.WatermarkEvent<T>
- java.lang.Object
-
- org.apache.beam.sdk.testing.TestStream.WatermarkEvent<T>
-
- All Implemented Interfaces:
TestStream.Event<T>
- Enclosing class:
- TestStream<T>
public abstract static class TestStream.WatermarkEvent<T> extends java.lang.Object implements TestStream.Event<T>
ATestStream.Event
that advances the watermark.
-
-
Constructor Summary
Constructors Constructor Description WatermarkEvent()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description static <T> TestStream.Event<T>
advanceTo(org.joda.time.Instant newWatermark)
For internal use only: no backwards compatibility guarantees.abstract org.joda.time.Instant
getWatermark()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.beam.sdk.testing.TestStream.Event
getType
-
-
-
-
Method Detail
-
getWatermark
public abstract org.joda.time.Instant getWatermark()
-
advanceTo
@Internal public static <T> TestStream.Event<T> advanceTo(org.joda.time.Instant newWatermark)
For internal use only: no backwards compatibility guarantees.
-
-