public class ReadTranslation
extends java.lang.Object
SplittableParDo.PrimitiveBoundedRead
and SplittableParDo.PrimitiveUnboundedRead
PTransformTranslation
into RunnerApi.ReadPayload
protos.Modifier and Type | Class and Description |
---|---|
static class |
ReadTranslation.BoundedReadPayloadTranslator
|
static class |
ReadTranslation.Registrar
|
static class |
ReadTranslation.UnboundedReadPayloadTranslator
|
Constructor and Description |
---|
ReadTranslation() |
Modifier and Type | Method and Description |
---|---|
static BoundedSource<?> |
boundedSourceFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.ReadPayload payload) |
static <T> BoundedSource<T> |
boundedSourceFromTransform(AppliedPTransform<PBegin,PCollection<T>,PTransform<PBegin,PCollection<T>>> transform) |
static PCollection.IsBounded |
sourceIsBounded(AppliedPTransform<?,?,?> transform) |
static org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec |
toProto(Source<?> source) |
static org.apache.beam.model.pipeline.v1.RunnerApi.ReadPayload |
toProto(SplittableParDo.PrimitiveBoundedRead<?> read) |
static org.apache.beam.model.pipeline.v1.RunnerApi.ReadPayload |
toProto(SplittableParDo.PrimitiveUnboundedRead<?> read) |
static UnboundedSource<?,?> |
unboundedSourceFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.ReadPayload payload) |
static <T,CheckpointT extends UnboundedSource.CheckpointMark> |
unboundedSourceFromTransform(AppliedPTransform<PBegin,PCollection<T>,PTransform<PBegin,PCollection<T>>> transform) |
public static org.apache.beam.model.pipeline.v1.RunnerApi.ReadPayload toProto(SplittableParDo.PrimitiveBoundedRead<?> read)
public static org.apache.beam.model.pipeline.v1.RunnerApi.ReadPayload toProto(SplittableParDo.PrimitiveUnboundedRead<?> read)
public static org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec toProto(Source<?> source)
public static BoundedSource<?> boundedSourceFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.ReadPayload payload) throws org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.InvalidProtocolBufferException
org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.InvalidProtocolBufferException
public static <T> BoundedSource<T> boundedSourceFromTransform(AppliedPTransform<PBegin,PCollection<T>,PTransform<PBegin,PCollection<T>>> transform) throws java.io.IOException
java.io.IOException
public static <T,CheckpointT extends UnboundedSource.CheckpointMark> UnboundedSource<T,CheckpointT> unboundedSourceFromTransform(AppliedPTransform<PBegin,PCollection<T>,PTransform<PBegin,PCollection<T>>> transform) throws java.io.IOException
java.io.IOException
public static UnboundedSource<?,?> unboundedSourceFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.ReadPayload payload)
public static PCollection.IsBounded sourceIsBounded(AppliedPTransform<?,?,?> transform)