org.apache.beam.runners.core.construction

Class PCollections

java.lang.Object

org.apache.beam.runners.core.construction.PCollections

public class PCollections
extends Object

Utility methods for translating PCollections to and from Runner API protos.

Method Summary

Modifier and Type	Method and Description
static Coder<?>	getCoder(RunnerApi.PCollection pCollection, RunnerApi.Components components)
static WindowingStrategy<?,?>	getWindowingStrategy(RunnerApi.PCollection pCollection, RunnerApi.Components components)
static PCollection.IsBounded	isBounded(RunnerApi.PCollection pCollection)
static RunnerApi.PCollection	toProto(PCollection<?> pCollection, org.apache.beam.runners.core.construction.SdkComponents components)

Methods inherited from class java.lang.Object

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

Method Detail

toProto

public static RunnerApi.PCollection toProto(PCollection<?> pCollection,
                                            org.apache.beam.runners.core.construction.SdkComponents components)
                                     throws IOException

Throws:

IOException

isBounded

public static PCollection.IsBounded isBounded(RunnerApi.PCollection pCollection)

getCoder

public static Coder<?> getCoder(RunnerApi.PCollection pCollection,
                                RunnerApi.Components components)
                         throws IOException

Throws:

IOException

getWindowingStrategy

public static WindowingStrategy<?,?> getWindowingStrategy(RunnerApi.PCollection pCollection,
                                                          RunnerApi.Components components)
                                                   throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException