上传者: 43943806
|
上传时间: 2021-03-11 17:07:15
|
文件大小: 5.44MB
|
文件类型: JAR
flink连接redis自定义连接器
eg: "CREATE TABLE redis_dim (\n" +
"key String,\n" +
"res String\n" +
") WITH (\n" +
" 'connector.type' = 'redis', \n" +
" 'redis.ip' = '10.100.1.15', \n" +
" 'database.num' = '0', \n"+//不起作用,不知道是不是只有一个数据库的原因
" 'operate.tpye' = 'hash', \n" +
" 'redis.password' = 'hl.Data2018', \n" +
" 'redis.version' = '2.6' \n" +
")";