org.apache.beam.sdk.util.construction

Class PCollectionViewTranslation

java.lang.Object

org.apache.beam.sdk.util.construction.PCollectionViewTranslation

public class PCollectionViewTranslation
extends java.lang.Object

Utilities for interacting with PCollection view protos.

Constructor Summary

Constructors

Constructor and Description
PCollectionViewTranslation()

Method Summary

Modifier and Type	Method and Description
static ViewFn<?,?>	viewFnFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec viewFn) Converts a RunnerApi.FunctionSpec into a ViewFn using the URN.
static PCollectionView<?>	viewFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.SideInput sideInput, java.lang.String localName, PCollection<?> pCollection, org.apache.beam.model.pipeline.v1.RunnerApi.PTransform parDoTransform, RehydratedComponents components) Create a PCollectionView from a side input spec and an already-deserialized PCollection that should be wired up.
static WindowMappingFn<?>	windowMappingFnFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec windowMappingFn) Converts a RunnerApi.FunctionSpec into a WindowMappingFn using the URN.

Methods inherited from class java.lang.Object

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

Constructor Detail

PCollectionViewTranslation

public PCollectionViewTranslation()

Method Detail

viewFromProto

public static PCollectionView<?> viewFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.SideInput sideInput,
                                               java.lang.String localName,
                                               PCollection<?> pCollection,
                                               org.apache.beam.model.pipeline.v1.RunnerApi.PTransform parDoTransform,
                                               RehydratedComponents components)
                                        throws java.io.IOException

Create a PCollectionView from a side input spec and an already-deserialized PCollection that should be wired up.

Throws:

java.io.IOException

viewFnFromProto

public static ViewFn<?,?> viewFnFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec viewFn)
                                   throws org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.InvalidProtocolBufferException

Converts a RunnerApi.FunctionSpec into a ViewFn using the URN.

Throws:

org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.InvalidProtocolBufferException

windowMappingFnFromProto

public static WindowMappingFn<?> windowMappingFnFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec windowMappingFn)
                                                   throws org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.InvalidProtocolBufferException

Converts a RunnerApi.FunctionSpec into a WindowMappingFn using the URN.

Throws:

org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.InvalidProtocolBufferException