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 java.lang.Object implements TestStream.Event<T>
ATestStream.Event
that produces elements.
-
-
Constructor Summary
Constructors Constructor Description ElementEvent()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method 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
-
-
-
-
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.
-
-