用于 Apache Kafka 的流数据 SQL 引擎 KSQL

用于 Apache Kafka 的流数据 SQL 引擎 KSQL

Apache
Java
跨平台
2017-08-29
王练

KSQL 

用于 Apache Kafka 的流数据 SQL 引擎

注意:项目还处于开发者预览版,请暂时勿用于生产集群中。

KSQL 是 Apache Kafka 的开源流 SQL 引擎。 它为 Kafka 的流处理提供了一个简单而完整的 SQL 界面; 不需要再用编程语言(如 Java 或 Python )编写代码。 KSQL 是分布式、可扩展、可靠的和实时的,支持多种流式操作,包括聚合(aggregate)、连接(join)、时间窗口(window)、会话(session)等等。基于 Apache 2.0 协议开源。

点此查看demo


KSQL 的两个核心概念是流(Stream)和表(Table),它将流和表集成在一起,允许将代表当前状态的表与代表当前发生事件的流连接在一起。

项目架构:

加载中

评论(0)

暂无评论

不想云厂商坐收渔翁之利,Kafka 团队修改 KSQL 开源许可

15 日,Confluent 宣布修改其平台部分组件的开源许可,从 Apache 2.0 切换到 Confluent Community License。 新的 Confluent 社区许可允许用户免费下载、修改和重新发行代码,这点类似于 Ap...

今天 08:16

没有更多内容

加载失败,请刷新页面

没有更多内容

暂无问答

Kafka 流数据 SQL 引擎 -- KSQL

KSQL 是什么? KSQL 是一个 Kafka 的 SQL 引擎,可以让我们在流数据上持续执行 SQL 查询 例如,有一个用户点击流的topic,和一个可持续更新的用户信息表,使用 KSQL 对点击流数据、用户表进行...

08/13 14:31
42
0
Kafka KSQL实战

背景 kafka早期作为一个日志消息系统,很受运维欢迎的,配合ELK玩起来很happy,在kafka慢慢的转向流式平台的过程中,开发也慢慢介入了,一些业务系统也开始和kafka对接起来了,也还是很受大家...

10/09 17:34
218
0
KSQL日期字段访问

日期常量用法 KSQL中用日期常量必须用{ts'" + dateTime.ToString("yyyy-M-d HH:mm:ss") + "'} 正确写法: INSERT INTO T_SEC_PASSWORDHISTORY (FHISTORYID, FUSERID, FPASSWORD, FCREATEDATE...

2016/04/07 15:21
40
1
X5的主从报表制作练习

X5的主从报表制作 这两天学习X5平台对照着手册练习主从报表的时候出现一些问题,所以写个博客记录下来,本篇博文重点放在创建主从报表上,对于其他步骤一代而过,所以如果有人看到的话不要喷...

2013/07/20 10:06
60
0
[K/3Cloud]ksql翻译札记

2011-11-16 又学一招,集合转化临时表的方法: var sql = string.Format(@"select b.FENTRYID,a.{2} from {0} a inner join {1} b on a.FID = b.FID inner join table(strSplit(@FENTRYID, ...

2016/04/07 15:23
20
1
金蝶BOS 7.5 SQL语句生成分析

金蝶BOS 7.5 SQL语句生成分析. 分析环境 Oracle 11.0.2 , 金蝶BOS 7.5.0

2014/11/23 01:17
1K
0
X5数据建模简单介绍

X5数据建模 数据建模实现概念与数据库的交互,完成数据的存取。其包括概念数据建模和物理数据建模两部分。 概念数据建模:屏蔽物理数据库之间差异低作用(这里我理解为:利用ksql语句根据配置...

2013/07/12 10:49
206
0
nclob字段遇到的一些问题

最近一同事在项目中遇到的一些问题记录一下: 在query中加上nclob字段后,运行时列表界面报错: Caused exception message is: ORA-00932: inconsistent datatypes: expected - got NCLOB 最...

2016/05/27 11:21
18
0
[K/3Cloud] KSQL日期常量用法注意

KSQL中用日期常量必须用{ts'" + dateTime.ToString("yyyy-M-d HH:mm:ss") + "'} 正确写法: INSERT INTO T_SEC_PASSWORDHISTORY (FHISTORYID, FUSERID, FPASSWORD, FCREATEDATE) VALUES ('2...

2016/04/07 15:24
12
1

没有更多内容

加载失败,请刷新页面

返回顶部
顶部