public class PCollectionTranslation
extends java.lang.Object
PCollections
to and from Runner API protos.Modifier and Type | Method and Description |
---|---|
static PCollection<?> |
fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.PCollection pCollection,
Pipeline pipeline,
RehydratedComponents components) |
static PCollection.IsBounded |
isBounded(org.apache.beam.model.pipeline.v1.RunnerApi.PCollection pCollection) |
static org.apache.beam.model.pipeline.v1.RunnerApi.PCollection |
toProto(PCollection<?> pCollection,
SdkComponents components) |
public static org.apache.beam.model.pipeline.v1.RunnerApi.PCollection toProto(PCollection<?> pCollection, SdkComponents components) throws java.io.IOException
java.io.IOException
public static PCollection<?> fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.PCollection pCollection, Pipeline pipeline, RehydratedComponents components) throws java.io.IOException
java.io.IOException
public static PCollection.IsBounded isBounded(org.apache.beam.model.pipeline.v1.RunnerApi.PCollection pCollection)