StreamCQL 介绍
StreamCQL作为华为FusionInsight产品的重要组件,提供了在分布式流处理平台上的类SQL查询能力,包括窗口计算等高级特性,在开源之前已经在电信、金融等多个行业成功应用,简化开发工作量数倍。此次StreamCQL的开源可以看做是华为FusionInsight产品对大数据开源的积极拥抱,目的是让更多的社区开发爱好者、包括华为合作方、认证伙伴加入到项目的开源贡献和应用中,以更好的开源项目和产品来服务客户,发展社区。
StreamCQL是一个类sql的声明式语言,它用于在流(streams)和可更新关系(updatable
relation)上的可持续查询,目的是在流处理平台分布式计算能力之上,通过使用简易通用的类sql语言,使得业务逻辑的开发变得统一和简易。在架构上,除了支持主流的流处理平台Storm,它支持扩展到多种流处理引擎之上,如Flink。在功能上,StreamCQL弥补了传统流处理平台上一些基本业务功能的缺失,除了过滤、转换等基本sql能力之外,
还引入基于内存窗口的计算、统计、关联等能力,以及流数据的拆分、合并等功能。后期StreamCQL的发展方向包括:模式匹配、CQLServer(CQL远程提交,多语言接口,JDBC接口)、可靠性增强等。
StreamCQL 官网
https://github.com/HuaweiBigData/StreamCQL
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。