Package org.apache.beam.sdk.testing
Class TestStream.ProcessingTimeEvent<T>
- java.lang.Object
-
- org.apache.beam.sdk.testing.TestStream.ProcessingTimeEvent<T>
-
- All Implemented Interfaces:
TestStream.Event<T>
- Enclosing class:
- TestStream<T>
public abstract static class TestStream.ProcessingTimeEvent<T> extends java.lang.Object implements TestStream.Event<T>
ATestStream.Event
that advances the processing time clock.
-
-
Constructor Summary
Constructors Constructor Description ProcessingTimeEvent()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description static <T> TestStream.Event<T>
advanceBy(org.joda.time.Duration amount)
For internal use only: no backwards compatibility guarantees.abstract org.joda.time.Duration
getProcessingTimeAdvance()
-
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
-
getProcessingTimeAdvance
public abstract org.joda.time.Duration getProcessingTimeAdvance()
-
advanceBy
@Internal public static <T> TestStream.Event<T> advanceBy(org.joda.time.Duration amount)
For internal use only: no backwards compatibility guarantees.
-
-