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

Class PubsubSchemaTransformWriteConfiguration.Builder

java.lang.Object

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

Enclosing class:

PubsubSchemaTransformWriteConfiguration

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

Builder for PubsubSchemaTransformWriteConfiguration.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract PubsubSchemaTransformWriteConfiguration	build() Builds a PubsubSchemaTransformWriteConfiguration instance.
abstract PubsubSchemaTransformWriteConfiguration.Builder	setFormat(java.lang.String value) The expected format of the Pub/Sub message.
abstract PubsubSchemaTransformWriteConfiguration.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 PubsubSchemaTransformWriteConfiguration.Builder	setTimestampAttribute(java.lang.String value) When writing to Cloud Pub/Sub where record timestamps are configured as Pub/Sub message attributes, specifies the name of the attribute that contains the timestamp.
abstract PubsubSchemaTransformWriteConfiguration.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

setTopic

public abstract PubsubSchemaTransformWriteConfiguration.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 PubsubSchemaTransformWriteConfiguration.Builder setFormat(java.lang.String value)

The expected format of the Pub/Sub message.

Used to retrieve the PayloadSerializer from PayloadSerializers.

setTimestampAttribute

public abstract PubsubSchemaTransformWriteConfiguration.Builder setTimestampAttribute(java.lang.String value)

When writing to Cloud Pub/Sub where record timestamps are configured as Pub/Sub message attributes, specifies the name of the attribute that contains the timestamp.

setIdAttribute

public abstract PubsubSchemaTransformWriteConfiguration.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 PubsubSchemaTransformWriteConfiguration build()

Builds a PubsubSchemaTransformWriteConfiguration instance.