代码拉取完成，页面将自动刷新
CREATE TABLE tableName(
colName cloType,
...
PERIOD FOR SYSTEM_TIME
)WITH(
type ='redis',
url = 'ip:port',
password = 'redisPwd',
database = 'dbName',
tableName ='sideTableName',
cache ='LRU',
cacheSize ='10000',
cacheTTLMs ='60000'
);
redis5.0
| 参数名称 | 含义 |
|---|---|
| tableName | 注册到flink的表名称(可选填;不填默认和redis对应的表名称相同) |
| colName | 列名称，维表列名格式 表名:主键名:主键值:列名] |
| colType | 列类型，当前只支持varchar |
| PERIOD FOR SYSTEM_TIME | 关键字表明该定义的表为维表信息 |
| 参数名称 | 含义 | 是否必填 | 默认值 |
|---|---|---|---|
| type | 表明维表的类型[hbase|mysql|redis] | 是 | |
| url | redis 的地址;格式ip:port[,ip:port] | 是 | |
| password | redis 的密码 | 是 | |
| database | reids 的数据库地址 | 否 | |
| tableName | redis 的表名称 | 是 | |
| cache | 维表缓存策略(NONE/LRU/ALL) | 否 | NONE |
| partitionedJoin | 是否在維表join之前先根据 設定的key 做一次keyby操作(可以減少维表的数据缓存量) | 否 | false |
缓存策略
create table sideTable(
channel varchar,
xccount varchar,
PRIMARY KEY(channel),
PERIOD FOR SYSTEM_TIME
)WITH(
type='redis',
url='172.16.10.79:6379',
password='abc123',
database='0',
tableName='sidetest',
cache = 'LRU',
cacheTTLMs='10000'
);
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手