Package 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 Object
implements TestStream.Event<T>

A TestStream.Event that produces elements.

Constructor Summary

Constructors

Constructor	Description
ElementEvent()

Method Summary

Modifier and Type	Method	Description
static <T> TestStream.Event<T>	add(Iterable<TimestampedValue<T>> elements)	For internal use only: no backwards compatibility guarantees.
abstract 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 Details

ElementEvent

public ElementEvent()

Method Details

getElements

public abstract Iterable<TimestampedValue<T>> getElements()

add

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

For internal use only: no backwards compatibility guarantees.