Package org.apache.beam.io.debezium

Class DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder

java.lang.Object

org.apache.beam.io.debezium.DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder

Enclosing class:

DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration

public abstract static class DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration	build()
abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder	setDatabase(String database)
abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder	setDebeziumConnectionProperties(List<String> debeziumConnectionProperties)
abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder	setHost(String host)
abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder	setPassword(String password)
abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder	setPort(Integer port)
abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder	setTable(String table)
abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder	setUsername(String username)

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

setUsername

public abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder setUsername(String username)

setPassword

public abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder setPassword(String password)

setHost

public abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder setHost(String host)

setPort

public abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder setPort(Integer port)

setDatabase

public abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder setDatabase(String database)

setTable

public abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder setTable(String table)

setDebeziumConnectionProperties

public abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder setDebeziumConnectionProperties(List<String> debeziumConnectionProperties)

build

public abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration build()