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>

A TestStream.Event that advances the watermark.

Constructor Summary

Constructors

Constructor and Description
WatermarkEvent()

Method Summary

Modifier and Type	Method and Description
static <T> TestStream.Event<T>	advanceTo(Instant newWatermark) For internal use only: no backwards compatibility guarantees.
abstract 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

Constructor Detail

WatermarkEvent

public WatermarkEvent()

Method Detail

getWatermark

public abstract Instant getWatermark()

advanceTo

@Internal
public static <T> TestStream.Event<T> advanceTo(Instant newWatermark)

For internal use only: no backwards compatibility guarantees.