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>

A TestStream.Event that advances the processing time clock.

Constructor Summary

Constructors

Constructor and Description
ProcessingTimeEvent()

Method Summary

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()

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

Constructor Detail

ProcessingTimeEvent

public ProcessingTimeEvent()

Method Detail

getProcessingTimeAdvance

public abstract Duration getProcessingTimeAdvance()

advanceBy

@Internal
public static <T> TestStream.Event<T> advanceBy(Duration amount)

For internal use only: no backwards compatibility guarantees.