Flink动态业务规则的实现 - 码农知识堂 - 文章详情页

Flink动态业务规则的实现
Flink动态业务规则的实现
文章目录
- Flink动态业务规则的实现
- 一、需求
  
  二、监控配置变化
  
  2.1 FlinkCDC的实现
  
  2.2 Apollo的实现
  
  三、根据配置的变化修改逻辑
  
  3.1 简单的逻辑
  
  3.2 复杂的逻辑
  
  代码
一、需求

在不停止flink任务的情况下，在外部通过配置，来达到修改flink输出特征逻辑的变化、新增和删除。

碎碎念：
```
网上找了好久都没有，很多动态加载UDF，也是在启动的时候加载。我想要达到在运行过程中加载udf。
只能自己写了。

这是真的真的真的真的 动态业务规则。

还有一种方案是，在方法中调用接口，通过改变接口的实现逻辑来实现。
但是这种方法不符合分布式计算，把计算的工作全1
2
3
4
5
6
```
相关阅读:
B2B电子商务策略[在2022年发展您的业务]
函数中使用sizeof(arr) / sizeof(arr[0])求数组长度不正确的原因
 JavaScript中 slice, substr 和 substring 的区别
 SpringBoot项目--电脑商城【加入购物车】
什么是CRM系统？为什么现代企业都在使用？
python创建分类器小结
 C#word（2007）操作类
 Python——异常
 互联网是如何运作的？--互联网解释
 SLAM从入门到精通（robot上层软件开发）
原文地址：https://blog.csdn.net/weixin_44628586/article/details/126409004