flink 1.14 自定义 redis sink 与维表

原文出自flink sql 知其所以然（二）| 自定义 redis 数据维表（附源码）

（侵权删）

我是拿来主义，自己将原来1.13.2版本改为1.14.0,注意事项：

RedisRowDataLookupFunction 类中的

import org.apache.flink.shaded.guava18.com.google.common.cache.Cache;
import org.apache.flink.shaded.guava18.com.google.common.cache.CacheBuilder;

修改为

import org.apache.flink.shaded.guava30.com.google.common.cache.Cache;
import org.apache.flink.shaded.guava30.com.google.common.cache.CacheBuilder;

即可。

项目引用时，直接使用非依赖Jar包就成。

再加上个依赖项：

       
            org.apache.bahir
            flink-connector-redis_2.10
            1.0
       

即可