简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
camunda工作流引擎开发之旅01
camunda工作流引擎开发之旅01背景:后端项目使用springboot+camunda来搭建,如果有微服务需求的,可以自己加上eureka和springcloud等大家庭。
Flink项目开发记录之合并数据流
Flink项目开发记录之合并数据流项目目前的jar包环境:flink1.9.0这边就是常用jar,就不列出了,合并流我这边选择是使用相同的key流然后设置时间的上下限,进行合流项目背景:由于业务需求,将原本的从kafka接收的数据流,经过业务A处理,变成了a,b两个dataStream,a、b两个流分别经过若干个业务处理后,需要合并到一个流中接着经过业务B、C、D等处理在Sink到ES中,所...
Flink项目开发记录之将日志输出到kafka
Flink项目开发记录之将日志输出到kafka老规矩,我们先上传所需要的jar包<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka_2.11</artifactId>...
Flink KeyedProcessFunction 定时器、State用例
基于flink1.7+scala+kafka直接上代码吧第一个是自定义的一个ProcessFunction 继承KeyedProcessFunctionclass SensorCountTimeOutProcess extends KeyedProcessFunction[Tuple,(GroupInfo,String, String, String),(GroupInfo,String, ...
到底了