Sink plugin: TiDb [Spark]
Write data to TiDB.
name | type | required | default value |
---|---|---|---|
spark.tispark.pd.addresses | string | yes | - |
spark.sql.extensions | string | yes | org.apache.spark.sql.TiExtensions |
TiDB Pd Address
Spark Sql Extensions
name | type | required | default value |
---|---|---|---|
addr | string | yes | - |
port | string | yes | - |
user | string | yes | - |
password | string | yes | - |
table | string | yes | - |
database | string | yes |
TiDB address, which currently only supports one instance
TiDB port
TiDB user
TiDB password
TiDB table name
TiDB database name
Refer to TiSpark Configurations
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 = "***********"
}