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

Class PubsubReadSchemaTransformConfiguration.Builder

java.lang.Object

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

Enclosing class:

PubsubReadSchemaTransformConfiguration

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

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract PubsubReadSchemaTransformConfiguration	build()
abstract PubsubReadSchemaTransformConfiguration.Builder	setAttributes(java.util.List<java.lang.String> attributes)
abstract PubsubReadSchemaTransformConfiguration.Builder	setAttributesMap(java.lang.String attributesMap)
abstract PubsubReadSchemaTransformConfiguration.Builder	setClientFactory(PubsubTestClient.PubsubTestClientFactory clientFactory)
abstract PubsubReadSchemaTransformConfiguration.Builder	setClock(com.google.api.client.util.Clock clock)
abstract PubsubReadSchemaTransformConfiguration.Builder	setErrorHandling(PubsubReadSchemaTransformConfiguration.ErrorHandling errorHandling)
abstract PubsubReadSchemaTransformConfiguration.Builder	setFormat(java.lang.String format)
abstract PubsubReadSchemaTransformConfiguration.Builder	setIdAttribute(java.lang.String schema)
abstract PubsubReadSchemaTransformConfiguration.Builder	setSchema(java.lang.String schema)
abstract PubsubReadSchemaTransformConfiguration.Builder	setSubscription(java.lang.String subscription)
abstract PubsubReadSchemaTransformConfiguration.Builder	setTimestampAttribute(java.lang.String schema)
abstract PubsubReadSchemaTransformConfiguration.Builder	setTopic(java.lang.String topic)

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 PubsubReadSchemaTransformConfiguration.Builder setTopic(@Nullable
                                                                        java.lang.String topic)

setSubscription

public abstract PubsubReadSchemaTransformConfiguration.Builder setSubscription(@Nullable
                                                                               java.lang.String subscription)

setFormat

public abstract PubsubReadSchemaTransformConfiguration.Builder setFormat(java.lang.String format)

setSchema

public abstract PubsubReadSchemaTransformConfiguration.Builder setSchema(java.lang.String schema)

setAttributes

public abstract PubsubReadSchemaTransformConfiguration.Builder setAttributes(@Nullable
                                                                             java.util.List<java.lang.String> attributes)

setAttributesMap

public abstract PubsubReadSchemaTransformConfiguration.Builder setAttributesMap(@Nullable
                                                                                java.lang.String attributesMap)

setIdAttribute

public abstract PubsubReadSchemaTransformConfiguration.Builder setIdAttribute(@Nullable
                                                                              java.lang.String schema)

setTimestampAttribute

public abstract PubsubReadSchemaTransformConfiguration.Builder setTimestampAttribute(@Nullable
                                                                                     java.lang.String schema)

setErrorHandling

public abstract PubsubReadSchemaTransformConfiguration.Builder setErrorHandling(@Nullable
                                                                                PubsubReadSchemaTransformConfiguration.ErrorHandling errorHandling)

setClientFactory

public abstract PubsubReadSchemaTransformConfiguration.Builder setClientFactory(@Nullable
                                                                                PubsubTestClient.PubsubTestClientFactory clientFactory)

setClock

public abstract PubsubReadSchemaTransformConfiguration.Builder setClock(@Nullable
                                                                        com.google.api.client.util.Clock clock)

build

public abstract PubsubReadSchemaTransformConfiguration build()