logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

flink写入redis(续)

参照源码:https://github.com/apache/bahir-flink/tree/master/flink-connector-redis先分析,后修改。flink-connector-redis代码目录:着重看RedisSink类:1. 包含如下几个私有对象:private String additionalKey;private Integer ad...

#flink#redis#java
在intellj中使用mockito(依赖maven)

1、新建maven项目2、pom文件中添加如下依赖(使用的是最新的版本)注:此处使用junit5.3.2,使用junit4.1.2亦可<dependencies><!-- https://mvnrepository.com/artifact/org.mockito/mockito-core --><depend...

#maven#java#test
flink写入redis

使用 Flink Redis Connector支持三种Redis连接方式Single Redis ServerRedis ClusterRedis Sentinel源码:https://github.com/apache/bahir-flink添加依赖:<dependency><groupId>org.apache.bahir</g...

#flink#redis#java
到底了