Flink高级应用模式第一辑:欺诈检测系统案例研究
在这个博客文章系列中,你将学习到三种用来构建流应用程序的强大的Flink模式:
动态更新应用程序逻辑
动态数据分区(混排),在运行时控制
基于自定义窗口逻辑的低延迟警报(不使用窗口API)
这些模式带来了更多使用静态定义的数据流实现的功能,并提供了满足复杂业务需求的构建块。
应用程序逻辑的动态更新允许Flink作业在运行时更改,而不会因停止和代码重新提交而导致停机。
动态数据分区提供了在运行时更改Flink分配事件和分组方式的能力。当使用可动态重新配置的应用程序逻辑构建作业时,往往会自然而然需求...