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" + ")";
2021-03-11 17:07:15 5.44MB flink redis
1
flink本身DDL的方式目前还不支持clickhouse,本jar添加对clickhouse的支持,导入到flink/lib下即可使用
2021-02-25 09:02:34 194KB flink clickhouse
flink是新一代的流式计算引擎,它需要从不同的第三方存储引擎读取数据,进行一定的处理,写出到不同的存储引擎,Connector就相当于是一个连接器,连接flink系统和外界存储系统。
2021-01-28 04:27:37 79KB Flink
1
flink是新一代的流式计算引擎,它需要从不同的第三方存储引擎读取数据,进行一定的处理,写出到不同的存储引擎,Connector就相当于是一个连接器,连接flink系统和外界存储系统。
2021-01-28 04:27:36 107KB Flink
1