Flink < --> how to use redis +with parameter

Introduce

Redis Connector Provide for the right to Redis Write support .

Using range

It can be used as Tuple、Upsert Destination table of data flow .

Example

set command （ String key ）

-- The first 1 As a key, The first 2 As a value.Redis The order is set key value CREATE TABLE `DataOutput` (  `key` STRING, `value` STRING ) WITH (  'connector' = 'redis',     -- Output to Redis  'command' = 'set',         -- set command  'nodes' = '<host>:<port>', -- redis Connection address  'password' = '<password>',  'database' = '<database>'  );

lpush command （ List key ）

-- The first 1 As a key, The first 2 As a value.Redis The order is lpush key value CREATE TABLE `DataOutput` (  `key` STRING, `value` STRING ) WITH (  'connector' = 'redis',     -- Output to Redis  'command' = 'lpush',       -- lpush command  'nodes' = '<host>:<port>', -- redis Connection address  'password' = '<password>',  'database' = '<database>'  );

sadd command （ Set key ）

-- The first 1 As a key, The first 2 As a value.Redis The order is sadd key value CREATE TABLE `DataOutput` (  `key`   STRING, `value` STRING ) WITH ( 'connector' = 'redis',     -- Output to Redis 'command' = 'sadd',        -- sadd command 'nodes' = '<host>:<port>', -- redis Connection address 'password' = '<password>', 'database' = '<database>'  );

hset command （ Hash key ）

-- The first 1 As a hash_key, The first 2 As a hash_value.Redis The order is hset key hash_key hash_value. CREATE TABLE `DataOutput` (  `hash_key`   STRING, `hash_value` STRING ) WITH ( 'connector' = 'redis',     -- Output to Redis 'command' = 'hset',        -- hset command 'nodes' = '<host>:<port>', -- redis Connection address 'password' = '<password>', 'database' = '<database>', 'additional-key' = '<key>' -- Hash key );

zadd command （ Ordered set key ）

-- The first 1 As a hash_key, The first 2 As a hash_value.zadd key score value. CREATE TABLE `DataOutput` (  `value` STRING, `score` DOUBLE ) WITH ( 'connector' = 'redis',     -- Output to Redis 'command' = 'zadd',        -- zadd command 'nodes' = '<host>:<port>', -- redis Connection address 'password' = '<password>', 'database' = '<database>', 'additional-key' = '<key>' -- Ordered set key );

Universal WITH Parameters

Parameter values	Required	The default value is	describe
connector	yes	-	The fixed value is redis
command	yes	-	Operation command . The values and corresponding key types are as follows ： set： String key lpush： Category key sadd： Set key hset： Hash key zadd： Ordered set key
nodes	yes	-	redis server Connection address , Example ：127.0.0.1:6379. Under the cluster architecture, multiple nodes use ',' Separate
password	no	empty	redis password , The default value is empty , No permission validation
database	no	0	Of the database to be operated DB number, The default value is 0
redis-mode	no	standalone	redis Deployment mode standalone： Standard Architecture , stand-alone cluster： Cluster architecture , Distributed
ignore-delete	no	false	Whether to ignore Retraction news
additional-ttl	no	-	Expiration time , Company ： second . Example ：60, Set the expiration time to 60 second . Only set The command supports setting the expiration time
additional-key	-	-	Is used to specify the hset and zadd Of key. perform hset and zadd Command must be set

Fabulous