1 Star 1 Fork 0

MADAO77/flinkStreamSQL

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
redisSink.md 1.21 KB
一键复制 编辑 原始数据 按行查看 历史

1.格式:

CREATE TABLE tableName(
    colName colType,
    ...
    colNameX colType
 )WITH(
    type ='redis',
    url = 'ip:port',
    database ='dbName',
    password ='pwd',
    tableName ='tableName',
    parallelism ='parllNum'
 );


2.支持版本

redis5.0

3.表结构定义

参数名称 含义
tableName 在 sql 中使用的名称;即注册到flink-table-env上的名称
colName 列名称,redis中存储为 表名:主键名:主键值:列名]
colType 列类型,当前只支持varchar
PRIMARY KEY(keyInfo) 结果表主键定义;多个列之间用逗号隔开

4.参数:

参数名称 含义 是否必填 默认值
type 表明 输出表类型[mysql|hbase|elasticsearch|redis]
url redis 的地址;格式ip:port[,ip:port]
password redis 的密码
database reids 的数据库地址
tableName redis 的表名称
parallelism 并行度设置 1

5.样例:

 CREATE TABLE MyResult(
    channel varchar,
    pv varchar,
    PRIMARY KEY(channel)
 )WITH(
    type='redis',
    url='172.16.10.79:6379',
    password='abc123',
    database='0',
    tableName='sinktoredis',
 );

Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Java
1
https://gitee.com/madao77/flinkStreamSQL.git
git@gitee.com:madao77/flinkStreamSQL.git
madao77
flinkStreamSQL
flinkStreamSQL
master

搜索帮助