public abstract static class TestStream.ProcessingTimeEvent<T> extends java.lang.Object implements TestStream.Event<T>
TestStream.Event
that advances the processing time clock.Constructor and Description |
---|
ProcessingTimeEvent() |
Modifier and Type | Method and Description |
---|---|
static <T> TestStream.Event<T> |
advanceBy(Duration amount)
For internal use only: no backwards compatibility guarantees.
|
abstract Duration |
getProcessingTimeAdvance() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getType
public abstract Duration getProcessingTimeAdvance()
@Internal public static <T> TestStream.Event<T> advanceBy(Duration amount)