org.apache.beam.sdk.util.construction

Class TestStreamTranslation

java.lang.Object

org.apache.beam.sdk.util.construction.TestStreamTranslation

public class TestStreamTranslation
extends java.lang.Object

Utility methods for translating a TestStream to and from RunnerApi representations.

Constructor Summary

Constructors

Constructor and Description
TestStreamTranslation()

Method Summary

Modifier and Type	Method and Description
static <T> TestStream<T>	getTestStream(AppliedPTransform<PBegin,PCollection<T>,PTransform<PBegin,PCollection<T>>> application) Converts an AppliedPTransform, which may be a rehydrated transform or an original TestStream, to a TestStream.
static <T> TestStream<T>	testStreamFromProtoPayload(org.apache.beam.model.pipeline.v1.RunnerApi.TestStreamPayload testStreamPayload, Coder<T> coder)
static <T> TestStream<T>	testStreamFromProtoPayload(org.apache.beam.model.pipeline.v1.RunnerApi.TestStreamPayload testStreamPayload, RehydratedComponents components)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestStreamTranslation

public TestStreamTranslation()

Method Detail

testStreamFromProtoPayload

public static <T> TestStream<T> testStreamFromProtoPayload(org.apache.beam.model.pipeline.v1.RunnerApi.TestStreamPayload testStreamPayload,
                                                           RehydratedComponents components)
                                                    throws java.io.IOException

Throws:

java.io.IOException

testStreamFromProtoPayload

public static <T> TestStream<T> testStreamFromProtoPayload(org.apache.beam.model.pipeline.v1.RunnerApi.TestStreamPayload testStreamPayload,
                                                           Coder<T> coder)
                                                    throws java.io.IOException

Throws:

java.io.IOException

getTestStream

public static <T> TestStream<T> getTestStream(AppliedPTransform<PBegin,PCollection<T>,PTransform<PBegin,PCollection<T>>> application)
                                       throws java.io.IOException

Converts an AppliedPTransform, which may be a rehydrated transform or an original TestStream, to a TestStream.

Throws:

java.io.IOException