更新时间:2025-02-12 GMT+08:00

FlinkSQL Redis表开发规则

Flink Redis作业参数规范

Flink Redis作业参数配置规范如下表所示。

表1 Flink Redis作业参数规范

配置项

是否必选

类型

描述

zSetScoreColumn

可选

String

Redis作为维表时,ZSet格式score字段对应的列名。

hashKeyColumn

可选

String

Hash格式,Hash字段对应的列名。

host

必选

String

Redis集群连接IP,为Redis集群的实例IP(业务平面)。

port

必选

String

端口为对应的Redis实例的端口。

Redis实例的端口计算方式为:22400+该实例的ID-1。

实例ID可以通过在FusionInsight Manager中选择“集群 > 服务 > Redis > Redis管理”,单击Redis集群名称查看。

例如Redis集群内角色R1对应的Redis实例的端口为22400+1-1=22400。

separator

可选

String

Redis作为维表时,value中的字段分割符,示例:“(,)”、“(\u200b)”。

key-ttl-mode

可选

String

Redis数据过期策略:

  • no-ttl:数据不过期。
  • expire-msec: 指定多长时间之后数据过期,以毫秒为单位。
  • expire-at-date:到指定时间数据过期,精确到秒。
  • expire-at-timestamp:到指定时间数据过期,精确到毫秒。

key-ttl

可选

String

配置“key-ttl-mode”参数为非“no-ttl”时需设置该值,该值不需要带单位。

isSSLMode

可选

String

是否开启SSL模式:

  • true:开启SSL模式。
  • false:不开启SSL模式。

keyPrefix

可选

String

Redis key的前缀。