TiDB
TiDB sink connector
Description
Write data to TiDB.
提示
Engine Supported and plugin name
- Spark: TiDB
- Flink
Env Options
name | type | required | default value |
---|---|---|---|
spark.tispark.pd.addresses | string | yes | - |
spark.sql.extensions | string | yes | org.apache.spark.sql.TiExtensions |
spark.tispark.pd.addresses [string]
TiDB Pd Address
spark.sql.extensions [string]
Spark Sql Extensions
Options
name | type | required | default value |
---|---|---|---|
addr | string | yes | - |
port | string | yes | - |
user | string | yes | - |
password | string | yes | - |
table | string | yes | - |
database | string | yes |
addr [string]
TiDB address, which currently only supports one instance
port [string]
TiDB port
user [string]
TiDB user
password [string]
TiDB password
table [string]
TiDB table name
database [string]
TiDB database name
options
Refer to TiSpark Configurations
Examples
env {
spark.tispark.pd.addresses = "127.0.0.1:2379"
spark.sql.extensions = "org.apache.spark.sql.TiExtensions"
}
tidb {
addr = "127.0.0.1",
port = "4000"
database = "database",
table = "tableName",
user = "userName",
password = "***********"
}