自定义flink的RedisSource,实现数据写入redis,这里借鉴了flink-connector-redis_2.11的实现逻辑,实现对redis读取的逻辑封装,flink-connector-redis_2.11的使用和介绍可参考之前的博客:
Flink读写Redis(三)-读取redis数据
原文:https://www.cnblogs.com/darange/p/13928534.html