Springboot整合Flink

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