华为宣布开源流处理平台查询语言StreamCQL

华为在本周一开始的华为开发者大会上宣布开源其流处理平台查询语言StreamCQL&＃xff08;Stream Continuous Query Language&＃xff09;&＃xff0c;在Github网站上已能看到其项目代码和文档&＃xff0c;具体网页地址&＃xff1a;https://github.com/HuaweiBigData/StreamCQL

StreamCQL作为华为FusionInsight产品的重要组件&＃xff0c;提供了在分布式流处理平台上的类SQL查询能力&＃xff0c;包括窗口计算等高级特性&＃xff0c;在开源之前已经在电信、金融等多个行业成功应用&＃xff0c;简化开发工作量数倍。此次StreamCQL的开源可以看做是华为FusionInsight产品对大数据开源的积极拥抱&＃xff0c;目的是让更多的社区开发爱好者、包括华为合作方、认证伙伴加入到项目的开源贡献和应用中&＃xff0c;以更好的开源项目和产品来服务客户&＃xff0c;发展社区。

StreamCQL是一个类SQL的声明式语言&＃xff0c;它用于在流(streams)和可更新关系(updatable relation)上的可持续查询&＃xff0c;目的是在流处理平台分布式计算能力之上&＃xff0c;通过使用简易通用的类SQL语言&＃xff0c;使得业务逻辑的开发变得统一和简易。在架构上&＃xff0c;除了支持主流的流处理平台Storm&＃xff0c;它支持扩展到多种流处理引擎之上&＃xff0c;如Flink。在功能上&＃xff0c;StreamCQL弥补了传统流处理平台上一些基本业务功能的缺失&＃xff0c;除了过滤、转换等基本SQL能力之外, 还引入基于内存窗口的计算、统计、关联等能力&＃xff0c;以及流数据的拆分、合并等功能。后期StreamCQL的发展方向包括&＃xff1a;模式匹配、CQLServer(CQL远程提交&＃xff0c;多语言接口&＃xff0c;JDBC接口)、可靠性增强等。

文章转载自开源中国社区[https://www.oschina.net]