Package 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 Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract PubsubReadSchemaTransformConfiguration	build()
abstract PubsubReadSchemaTransformConfiguration.Builder	setAttributes(List<String> attributes)
abstract PubsubReadSchemaTransformConfiguration.Builder	setAttributesMap(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(String format)
abstract PubsubReadSchemaTransformConfiguration.Builder	setIdAttribute(String schema)
abstract PubsubReadSchemaTransformConfiguration.Builder	setSchema(String schema)
abstract PubsubReadSchemaTransformConfiguration.Builder	setSubscription(String subscription)
abstract PubsubReadSchemaTransformConfiguration.Builder	setTimestampAttribute(String schema)
abstract PubsubReadSchemaTransformConfiguration.Builder	setTopic(String topic)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

setTopic

public abstract PubsubReadSchemaTransformConfiguration.Builder setTopic(@Nullable
 String topic)

setSubscription

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

setFormat

public abstract PubsubReadSchemaTransformConfiguration.Builder setFormat(String format)

setSchema

public abstract PubsubReadSchemaTransformConfiguration.Builder setSchema(String schema)

setAttributes

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

setAttributesMap

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

setIdAttribute

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

setTimestampAttribute

public abstract PubsubReadSchemaTransformConfiguration.Builder setTimestampAttribute(@Nullable
 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()