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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

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

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

setUsername

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

setPassword

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

setHost

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

setPort

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

setDatabase

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

setTable

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

setDebeziumConnectionProperties

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

build

public abstract DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration build()