Package org.apache.flink.cdc.connectors.tidb

Class TiDBSource.Builder<T>

java.lang.Object

org.apache.flink.cdc.connectors.tidb.TiDBSource.Builder<T>

Enclosing class:

TiDBSource

public static class TiDBSource.Builder<T>
extends Object

Builder class of TiDBSource.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction<T>	build()
TiDBSource.Builder<T>	changeEventDeserializer(TiKVChangeEventDeserializationSchema<T> changeEventDeserializationSchema)	The deserializer used to convert from consumed change event from TiKV.
TiDBSource.Builder<T>	database(String database)	Database name to be monitored.
TiDBSource.Builder<T>	snapshotEventDeserializer(TiKVSnapshotEventDeserializationSchema<T> snapshotEventDeserializationSchema)	The deserializer used to convert from consumed snapshot event from TiKV.
TiDBSource.Builder<T>	startupOptions(StartupOptions startupOptions)	Specifies the startup options.
TiDBSource.Builder<T>	tableName(String tableName)	TableName name to be monitored.
TiDBSource.Builder<T>	tiConf(org.tikv.common.TiConfiguration tiConf)	TIDB config.

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

database

public TiDBSource.Builder<T> database(String database)

Database name to be monitored.

tableName

public TiDBSource.Builder<T> tableName(String tableName)

TableName name to be monitored.

snapshotEventDeserializer

public TiDBSource.Builder<T> snapshotEventDeserializer(TiKVSnapshotEventDeserializationSchema<T> snapshotEventDeserializationSchema)

The deserializer used to convert from consumed snapshot event from TiKV.

changeEventDeserializer

public TiDBSource.Builder<T> changeEventDeserializer(TiKVChangeEventDeserializationSchema<T> changeEventDeserializationSchema)

The deserializer used to convert from consumed change event from TiKV.

startupOptions

public TiDBSource.Builder<T> startupOptions(StartupOptions startupOptions)

Specifies the startup options.

tiConf

public TiDBSource.Builder<T> tiConf(org.tikv.common.TiConfiguration tiConf)

TIDB config.

build

public org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction<T> build()