
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
flink写入redis(续)
参照源码:https://github.com/apache/bahir-flink/tree/master/flink-connector-redis先分析,后修改。flink-connector-redis代码目录:着重看RedisSink类:1. 包含如下几个私有对象:private String additionalKey;private Integer ad...
在intellj中使用mockito(依赖maven)
1、新建maven项目2、pom文件中添加如下依赖(使用的是最新的版本)注:此处使用junit5.3.2,使用junit4.1.2亦可<dependencies><!-- https://mvnrepository.com/artifact/org.mockito/mockito-core --><depend...
flink写入redis
使用 Flink Redis Connector支持三种Redis连接方式Single Redis ServerRedis ClusterRedis Sentinel源码:https://github.com/apache/bahir-flink添加依赖:<dependency><groupId>org.apache.bahir</g...
到底了







