Springboot整合Flink
1,引入Flink相关依赖包
2,项目启动的时候实现Flink持续处理数据的过程
3,创建类MySink继承RichSinkFunction类,实现处理数据的方法
4,综上所述即为springboot整合Flink的步骤,实现了从接收数据到处理数据的全过程。
1,引入Flink相关依赖包
2,项目启动的时候实现Flink持续处理数据的过程
3,创建类MySink继承RichSinkFunction类,实现处理数据的方法
4,综上所述即为springboot整合Flink的步骤,实现了从接收数据到处理数据的全过程。