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

Class ExternalWrite.WriteBuilder

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsub.ExternalWrite.WriteBuilder

All Implemented Interfaces:

ExternalTransformBuilder<ExternalWrite.Configuration,PCollection<byte[]>,PDone>

Enclosing class:

ExternalWrite

public static class ExternalWrite.WriteBuilder
extends java.lang.Object
implements ExternalTransformBuilder<ExternalWrite.Configuration,PCollection<byte[]>,PDone>

Constructor Summary

Constructors

Constructor and Description
WriteBuilder()

Method Summary

Modifier and Type	Method and Description
PTransform<PCollection<byte[]>,PDone>	buildExternal(ExternalWrite.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 Detail

WriteBuilder

public WriteBuilder()

Method Detail

buildExternal

public PTransform<PCollection<byte[]>,PDone> buildExternal(ExternalWrite.Configuration config)

Description copied from interface: ExternalTransformBuilder

Builds the transform after it has been configured.

Specified by:

buildExternal in interface ExternalTransformBuilder<ExternalWrite.Configuration,PCollection<byte[]>,PDone>