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

Class TDBSourceOptions

java.lang.Object

org.apache.flink.cdc.connectors.tidb.TDBSourceOptions

public class TDBSourceOptions
extends Object

Configurations for TiDBSource.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<String>	DATABASE_NAME
static org.apache.flink.configuration.ConfigOption<String>	HOST_MAPPING
static org.apache.flink.configuration.ConfigOption<String>	PD_ADDRESSES
static org.apache.flink.configuration.ConfigOption<String>	SCAN_STARTUP_MODE
static org.apache.flink.configuration.ConfigOption<String>	TABLE_NAME
static org.apache.flink.configuration.ConfigOption<Integer>	TIKV_BATCH_GET_CONCURRENCY
static org.apache.flink.configuration.ConfigOption<Integer>	TIKV_BATCH_SCAN_CONCURRENCY
static org.apache.flink.configuration.ConfigOption<Long>	TIKV_GRPC_SCAN_TIMEOUT
static org.apache.flink.configuration.ConfigOption<Long>	TIKV_GRPC_TIMEOUT

Method Summary

Modifier and Type	Method	Description
static org.tikv.common.TiConfiguration	getTiConfiguration(String pdAddrsStr, String hostMapping, Map<String,String> options)

Methods inherited from class java.lang.Object

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

Field Detail

DATABASE_NAME

public static final org.apache.flink.configuration.ConfigOption<String> DATABASE_NAME

TABLE_NAME

public static final org.apache.flink.configuration.ConfigOption<String> TABLE_NAME

SCAN_STARTUP_MODE

public static final org.apache.flink.configuration.ConfigOption<String> SCAN_STARTUP_MODE

PD_ADDRESSES

public static final org.apache.flink.configuration.ConfigOption<String> PD_ADDRESSES

HOST_MAPPING

public static final org.apache.flink.configuration.ConfigOption<String> HOST_MAPPING

TIKV_GRPC_TIMEOUT

public static final org.apache.flink.configuration.ConfigOption<Long> TIKV_GRPC_TIMEOUT

TIKV_GRPC_SCAN_TIMEOUT

public static final org.apache.flink.configuration.ConfigOption<Long> TIKV_GRPC_SCAN_TIMEOUT

TIKV_BATCH_GET_CONCURRENCY

public static final org.apache.flink.configuration.ConfigOption<Integer> TIKV_BATCH_GET_CONCURRENCY

TIKV_BATCH_SCAN_CONCURRENCY

public static final org.apache.flink.configuration.ConfigOption<Integer> TIKV_BATCH_SCAN_CONCURRENCY

Method Detail

getTiConfiguration

public static org.tikv.common.TiConfiguration getTiConfiguration(String pdAddrsStr,
                                                                 String hostMapping,
                                                                 Map<String,String> options)