org.apache.beam.sdk.testing

Class TestStream.ElementEvent<T>

java.lang.Object

org.apache.beam.sdk.testing.TestStream.ElementEvent<T>

All Implemented Interfaces:

TestStream.Event<T>

Enclosing class:

TestStream<T>

public abstract static class TestStream.ElementEvent<T>
extends java.lang.Object
implements TestStream.Event<T>

A TestStream.Event that produces elements.

Constructor Summary

Constructors

Constructor and Description
ElementEvent()

Method Summary

Modifier and Type	Method and Description
static <T> TestStream.Event<T>	add(java.lang.Iterable<TimestampedValue<T>> elements) For internal use only: no backwards compatibility guarantees.
abstract java.lang.Iterable<TimestampedValue<T>>	getElements()

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

ElementEvent

public ElementEvent()

Method Detail

getElements

public abstract java.lang.Iterable<TimestampedValue<T>> getElements()

add

@Internal
public static <T> TestStream.Event<T> add(java.lang.Iterable<TimestampedValue<T>> elements)

For internal use only: no backwards compatibility guarantees.