目前开源版本的Flink 是不支持 动态CEP的,后续阿里有计划将这块贡献出来吗?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
动态 CEP (Complex Event Processing) 是一种流处理技术,允许在连续的数据流中检测复杂事件模式。目前 Flink 社区并没有包含对动态 CEP 的支持。
对于您提出的问题,我无法代表阿里巴巴官方做出承诺,因为这取决于公司的决策和发展策略。然而,作为一个全球知名的开源贡献者,阿里巴巴一直致力于推动 Flink 社区的发展,并已在过去的几年中做出了很多重大贡献。
如果您对动态 CEP 功能感兴趣,建议关注 Flink 社区的相关讨论或提出自己的建议。如果您所在的组织有意参与相关项目的开发,也可以考虑与 Alibaba Cloud 团队取得联系,共同探讨合作的可能性。
目前,Apache Flink 社区还没有官方计划将动态 CEP(Dynamic Complex Event Processing)功能贡献给社区。但是,很多公司已经实现了类似的功能,其中包括阿里云。
目前开源版本的Flink确实不支持动态CEP,但阿里云已经在Flink上实现了CEP相关的高度抽象,解耦了CEP规则和CEP执行节点,使得规则可以存在于RDS、Hologres等外部第三方存储里,CEP作业发布上去之后,就可以加载数据库中的CEP规则来做到动态替换。这一功能在阶段三已经实现。至于是否会将这块功能贡献给开源版本,我无法确定。您可以关注阿里云后续的更新和贡献情况。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。