Skip to content

Commit 1e2db49

Browse files
committed
update redis维表文档
1 parent b264114 commit 1e2db49

File tree

2 files changed

+30
-18
lines changed

2 files changed

+30
-18
lines changed

docs/config.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ sh submit.sh -key1 val1 -key2 val2
7373
* savePointPath:任务恢复点的路径(默认无)
7474
* allowNonRestoredState:指示保存点是否允许非还原状态的标志(默认false)
7575
* logLevel: 日志级别动态配置(默认info)
76-
* [prometheus 相关参数](docs/prometheus.md) per_job可指定metric写入到外部监控组件,以prometheus pushgateway举例
76+
* [prometheus 相关参数](./prometheus.md) per_job可指定metric写入到外部监控组件,以prometheus pushgateway举例
7777

7878

7979
* **flinkconf**

docs/plugin/redisSide.md

Lines changed: 29 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -22,29 +22,31 @@
2222
redis5.0
2323

2424
## 3.表结构定义
25+
注意:redis中没有表和schema的概念,参数中tableName是指符合命名规则的key,具体规则请看[缓存redis的存储命名规则]
2526

2627
|参数名称|含义|
2728
|----|---|
28-
| tableName | 注册到flink的表名称(可选填;不填默认和redis对应的表名称相同)|
29-
| colName | 列名称,维表列名格式 表名:主键名:主键值:列名]|
29+
| tableName | 注册到flinkStreamSql的表名称(可选填;不填默认和redis对应的"表"名称相同)|
30+
| colName | 列名称,对应redis对应"表"的field|
3031
| colType | 列类型,当前只支持varchar|
31-
| PRIMARY KEY |主键,多个字段做为联合主键时以逗号分隔
32-
| PERIOD FOR SYSTEM_TIME | 关键字表明该定义的表为维表信息|
32+
| PRIMARY KEY |主键,多个字段做为联合主键时以逗号分隔|
33+
| PERIOD FOR SYSTEM_TIME | 关键字,表明该定义的表为维表信息|
3334

3435
## 4.参数
3536

37+
参数详细说明请看[参数详细说明]()
38+
3639
|参数名称|含义|是否必填|默认值|
3740
|----|---|---|----|
3841
| type | 表明维表的类型[hbase|mysql|redis]|||
3942
| url | redis 的地址;格式ip:port[,ip:port]|||
40-
| password | redis 的密码 |||
43+
| password | redis 的密码 |||
4144
| redisType | redis模式(1 单机,2 哨兵, 3 集群)||
4245
| masterName | 主节点名称(哨兵模式下为必填项) ||
43-
| database | reids 的数据库地址|||
44-
| tableName | redis 的表名称|||
46+
| database | reids 的数据库地址||0|
47+
| tableName | redis 的“表”名称|||
4548
| cache | 维表缓存策略(NONE/LRU/ALL)||NONE|
4649
| partitionedJoin | 是否在維表join之前先根据 設定的key 做一次keyby操作(可以減少维表的数据缓存量)||false|
47-
4850
--------------
4951
> 缓存策略
5052
* NONE: 不做内存缓存
@@ -55,27 +57,37 @@
5557

5658
## 5.样例
5759
```
58-
create table sideTable(
59-
channel varchar,
60-
xccount varchar,
61-
PRIMARY KEY(channel),
60+
CREATE TABLE MyRedis(
61+
id varchar,
62+
message varchar,
63+
PRIMARY KEY(id),
6264
PERIOD FOR SYSTEM_TIME
63-
)WITH(
65+
)WITH(
6466
type='redis',
6567
url='172.16.10.79:6379',
6668
password='abc123',
6769
database='0',
6870
redisType = '1',
69-
tableName='sidetest',
71+
tableName = 'sideTable',
7072
cache = 'LRU',
7173
cacheTTLMs='10000'
72-
);
74+
);
7375
7476
```
75-
## 6.缓存redis的存储结构规则
76-
```
77+
## 6.redis的存储命名规则
78+
7779
redis使用散列类型 hash 数据结构,key=tableName_primaryKey1_primaryKey2,value={column1=value1, column2=value2}
7880
如果以班级class表为例,id和name作为联合主键,那么redis的结构为 <class_1_john ,{id=1, name=john, age=12}>
81+
82+
在样例中,tableName为sideTable,主键为id,column为id,message,所以对应的redis数据插入语句为<hset sideTable_5 id 5 message redis>
83+
84+
数据在redis中对应的数据存储情况为:
85+
```
86+
192.168.80.105:6379> hgetall sideTable_5
87+
1) "id"
88+
2) "5"
89+
3) "message"
90+
4) "redis"
7991
```
8092

8193

0 commit comments

Comments
 (0)