跳到主要内容
版本:2.1.2

Redis

Description

Write Rows to a Redis.

提示

Engine Supported and plugin name

  • Spark: Redis
  • Flink

Options

nametyperequireddefault value
hoststringno"localhost"
portintno6379
authstringno
db_numintno0
data_typestringno"KV"
hash_namestringno
list_namestringno
set_namestringno
zset_namestringno
timeoutintno2000
ttlintno0

host [string]

Redis server address, default "localhost"

port [int]

Redis service port, default 6379

auth [string]

Redis authentication password

db_num [int]

Redis database index ID. It is connected to db 0 by default

redis_timeout [int]

Redis timeout

data_type [string]

Redis data type eg: KV HASH LIST SET ZSET

hash_name [string]

if redis data type is HASH must config hash name

list_name [string]

if redis data type is LIST must config list name

zset_name [string]

if redis data type is ZSET must config zset name

set_name [string]

if redis data type is SET must config set name

ttl [int]

redis data expiration ttl, 0 means no expiration.

Examples

redis {
host = "localhost"
port = 6379
auth = "myPassword"
db_num = 1
data_type = "HASH"
hash_name = "test"
}