logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

camunda工作流引擎开发之旅01

camunda工作流引擎开发之旅01背景:后端项目使用springboot+camunda来搭建,如果有微服务需求的,可以自己加上eureka和springcloud等大家庭。

#java#spring boot
Flink项目开发记录之合并数据流

Flink项目开发记录之合并数据流项目目前的jar包环境:flink1.9.0这边就是常用jar,就不列出了,合并流我这边选择是使用相同的key流然后设置时间的上下限,进行合流项目背景:由于业务需求,将原本的从kafka接收的数据流,经过业务A处理,变成了a,b两个dataStream,a、b两个流分别经过若干个业务处理后,需要合并到一个流中接着经过业务B、C、D等处理在Sink到ES中,所...

#flink
Flink项目开发记录之将日志输出到kafka

Flink项目开发记录之将日志输出到kafka老规矩,我们先上传所需要的jar包<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka_2.11</artifactId>...

#kafka#flink
Flink KeyedProcessFunction 定时器、State用例

基于flink1.7+scala+kafka直接上代码吧第一个是自定义的一个ProcessFunction 继承KeyedProcessFunctionclass SensorCountTimeOutProcess extends KeyedProcessFunction[Tuple,(GroupInfo,String, String, String),(GroupInfo,String, ...

#flink#scala
到底了