Package org.apache.beam.sdk.io.gcp.pubsub

Class ExternalRead.ReadBuilder

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsub.ExternalRead.ReadBuilder

All Implemented Interfaces:

ExternalTransformBuilder<ExternalRead.Configuration,PBegin,PCollection<byte[]>>

Enclosing class:

ExternalRead

public static class ExternalRead.ReadBuilder
extends Object
implements ExternalTransformBuilder<ExternalRead.Configuration,PBegin,PCollection<byte[]>>

Constructor Summary

Constructors

Constructor	Description
ReadBuilder()

Method Summary

Modifier and Type	Method	Description
PTransform<PBegin,PCollection<byte[]>>	buildExternal(ExternalRead.Configuration config)	Builds the transform after it has been configured.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.transforms.ExternalTransformBuilder

getDependencies

Constructor Details

ReadBuilder

public ReadBuilder()

Method Details

buildExternal

public PTransform<PBegin,PCollection<byte[]>> buildExternal(ExternalRead.Configuration config)

Description copied from interface: ExternalTransformBuilder

Builds the transform after it has been configured.

Specified by:

buildExternal in interface ExternalTransformBuilder<ExternalRead.Configuration,PBegin,PCollection<byte[]>>