Package org.apache.beam.io.debezium

Class DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration

java.lang.Object

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

Enclosing class:

DebeziumReadSchemaTransformProvider

public abstract static class DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
DebeziumReadSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method	Description
static DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder	builder()
abstract @NonNull String	getDatabase()
abstract @Nullable List<String>	getDebeziumConnectionProperties()
abstract String	getHost()
abstract String	getPassword()
abstract Integer	getPort()
abstract String	getTable()
abstract String	getUsername()

Methods inherited from class java.lang.Object

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

Constructor Details

DebeziumReadSchemaTransformConfiguration

public DebeziumReadSchemaTransformConfiguration()

Method Details

getUsername

public abstract String getUsername()

getPassword

public abstract String getPassword()

getHost

public abstract String getHost()

getPort

public abstract Integer getPort()

getTable

public abstract String getTable()

getDatabase

public abstract @NonNull String getDatabase()

getDebeziumConnectionProperties

public abstract @Nullable List<String> getDebeziumConnectionProperties()

builder

public static DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder builder()