跳到主要内容
版本:2.3.0-beta

TiDB

TiDB sink connector

Description

Write data to TiDB.

提示

Engine Supported and plugin name

  • Spark: TiDB
  • Flink

Env Options

nametyperequireddefault value
spark.tispark.pd.addressesstringyes-
spark.sql.extensionsstringyesorg.apache.spark.sql.TiExtensions
spark.tispark.pd.addresses [string]

TiDB Pd Address

spark.sql.extensions [string]

Spark Sql Extensions

Options

nametyperequireddefault value
addrstringyes-
portstringyes-
userstringyes-
passwordstringyes-
tablestringyes-
databasestringyes
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 = "***********"
}