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

Class PubsubWriteSchemaTransformConfiguration.Builder

java.lang.Object

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

Enclosing class:

PubsubWriteSchemaTransformConfiguration

public abstract static class PubsubWriteSchemaTransformConfiguration.Builder
extends java.lang.Object

Builder for PubsubWriteSchemaTransformConfiguration.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract PubsubWriteSchemaTransformConfiguration	build()
abstract PubsubWriteSchemaTransformConfiguration.Builder	setFormat(java.lang.String value) The expected format of the Pub/Sub message.
abstract PubsubWriteSchemaTransformConfiguration.Builder	setIdAttribute(java.lang.String value) When reading from Cloud Pub/Sub where unique record identifiers are provided as Pub/Sub message attributes, specifies the name of the attribute containing the unique identifier.
abstract PubsubWriteSchemaTransformConfiguration.Builder	setSource(PubsubWriteSchemaTransformConfiguration.SourceConfiguration value) Configuration details of the source Row Schema.
abstract PubsubWriteSchemaTransformConfiguration.Builder	setTarget(PubsubWriteSchemaTransformConfiguration.TargetConfiguration value) Configuration details of the target PubsubMessage.
abstract PubsubWriteSchemaTransformConfiguration.Builder	setTopic(java.lang.String value) The topic to which to write Pub/Sub messages.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setSource

public abstract PubsubWriteSchemaTransformConfiguration.Builder setSource(PubsubWriteSchemaTransformConfiguration.SourceConfiguration value)

Configuration details of the source Row Schema.

setTarget

public abstract PubsubWriteSchemaTransformConfiguration.Builder setTarget(PubsubWriteSchemaTransformConfiguration.TargetConfiguration value)

Configuration details of the target PubsubMessage.

setTopic

public abstract PubsubWriteSchemaTransformConfiguration.Builder setTopic(java.lang.String value)

The topic to which to write Pub/Sub messages.

See PubsubIO.PubsubTopic.fromPath(String) for more details on the format of the topic string.

setFormat

public abstract PubsubWriteSchemaTransformConfiguration.Builder setFormat(java.lang.String value)

The expected format of the Pub/Sub message.

Used to retrieve the PayloadSerializer from PayloadSerializers. See list of supported values by invoking Providers.loadProviders(Class).

 Providers.loadProviders(PayloadSerializer.class).keySet()

setIdAttribute

public abstract PubsubWriteSchemaTransformConfiguration.Builder setIdAttribute(java.lang.String value)

When reading from Cloud Pub/Sub where unique record identifiers are provided as Pub/Sub message attributes, specifies the name of the attribute containing the unique identifier.

build

public abstract PubsubWriteSchemaTransformConfiguration build()