Package org.apache.beam.io.debezium

Class DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration

java.lang.Object

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

Enclosing class:

DebeziumReadSchemaTransformProvider

@DefaultSchema(AutoValueSchema.class)
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 @Nullable Integer	getMaxNumberOfRecords()
abstract @Nullable Long	getMaxTimeToRun()
abstract String	getPassword()
abstract int	getPort()
abstract String	getTable()
abstract String	getUsername()
void	validate()

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

getMaxNumberOfRecords

@SchemaFieldDescription("Maximum number of records to read before stopping.")
public abstract @Nullable Integer getMaxNumberOfRecords()

getMaxTimeToRun

@SchemaFieldDescription("Maximum time in milliseconds to run before stopping.")
public abstract @Nullable Long getMaxTimeToRun()

getUsername

@SchemaFieldDescription("Username used to connect to the source database.")
public abstract String getUsername()

getPassword

@SchemaFieldDescription("Password used to connect to the source database.")
public abstract String getPassword()

getHost

@SchemaFieldDescription("Hostname of the source database.")
public abstract String getHost()

getPort

@SchemaFieldDescription("Port of the source database.")
public abstract int getPort()

getTable

@SchemaFieldDescription("Fully qualified table name included in the Debezium change stream.")
public abstract String getTable()

getDatabase

@SchemaFieldDescription("Debezium connector type. Supported values: MYSQL, POSTGRES, SQLSERVER, ORACLE, and DB2.")
public abstract @NonNull String getDatabase()

getDebeziumConnectionProperties

@SchemaFieldDescription("Additional Debezium connection properties in key=value format.")
public abstract @Nullable List<String> getDebeziumConnectionProperties()

validate

public void validate()

builder

public static DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder builder()