科技排头@高级应用模式第二辑：应用模式的动态更新，Flink( 三 )
在将规则存储在广播MapState中时 ， DynamicAlertFunction遵循相同的逻辑 。 如第一部分中所述 ， processElement输入中的每个消息会由一个特定规则处理 ， 并通过DynamicKeyFunction带有相应ID的“预标记” 。 我们需要做的就是使用提供的ID从BroadcastState中检索相应规则的定义 ， 并根据该规则所需的逻辑对其进行处理 。 在这一阶段 ， 我们还将消息添加到内部函数状态 ， 以便在所需的数据时间窗口上执行计算 。 我们将在欺诈检测系列的最后一篇文章中探讨如何做到这一点 。
小结
本文 ， 我们继续研究了使用ApacheFlink构建的欺诈检测系统的用例 。 我们研究了在并行运算符实例之间分配数据的各种方式 ， 而最重要的是探讨了广播状态 。 我们演示了如何通过广播状态模式提供的功能来配合和增强动态分区（本系列第一部分中介绍的一种模式） 。 在运行时发送动态更新的能力是ApacheFlink的强大功能 ， 适用于其他多种用例 ， 例如控制状态（清除/插入/修复）、运行A/B实验或执行ML模型系数的更新等 。
关注我并转发此篇文章 ， 私信我“领取资料” ， 即可免费获得InfoQ价值4999元迷你书！
推荐阅读
- 小米科技▲卢伟冰再次发力，全球首发骁龙768G，5G新机将在两天后发布！
- 快科技最贵或达5000元，苹果头戴耳机更多细节曝光：包含两款
- 科技迷7nm版年底流片，要放弃美国代工？国产x86转向三星台积电代工
- 骊微电子科技PD充电器应用方案，PN8161+PN8307H高集成18W
- 快科技小米高管都是外人？雷军透露了一个秘密
- 靓科技解读Thing，a16z、5.15亿美金的数据加密股票基金：找寻下一个Big
- 王伯伯说科技流畅用三年，即将开学的学生党准备好了吗？三款高配低价千元机
- 知叔达科技中芯国际早已料到，成功绕开了光刻机，怒了！荷兰ASML再次失约
- 小熊带你玩科技数据成粤企生产新要素，工业互联网深调研〡从经验依赖到数据驱动
- 每日科技果粉大批华人再掀归国潮，美利坚的钱“不香了”？，硅谷科技人才流失