esper(复杂事件处理引擎)简介
2015-06-01 14:55
453 查看
Esper是一个复杂事件处理引擎,用于对同一类型的多个对象进行统计分析。
要统计的多个事件(一个事件通常对应着一个对象)会存储在一个队列中,这里叫它EQueue。
我的入门DEMO在 点击打开我的GitHub
详见该分类下的其他博文。
可以发送javaPojo,也可以发送map。
发送javaPojo时,直接创建epl = "select avg(price) from " + javaPojo.class.getName() + ".win:length_batch(2)";即可。
map
发送map时,可以注册表的类型,见下:
发送map时,也可以通过epl语句建立。
要统计的多个事件(一个事件通常对应着一个对象)会存储在一个队列中,这里叫它EQueue。
获得
<dependency> <groupId>com.espertech</groupId> <artifactId>esper</artifactId> <version>4.9.0</version> </dependency>
我的入门DEMO在 点击打开我的GitHub
EPL
EPL,Event Process Language,事件处理语言。类似于SQL,描述了esper要分析的内容。详见该分类下的其他博文。
事件类型
javaPojo可以发送javaPojo,也可以发送map。
发送javaPojo时,直接创建epl = "select avg(price) from " + javaPojo.class.getName() + ".win:length_batch(2)";即可。
map
发送map时,可以注册表的类型,见下:
//发送map时,可以注册表的类型 // Person定义 Map<String, Object> personTable = new HashMap<String, Object>(); personTable.put("name", String.class); personTable.put("age", Integer.class); // 注册Person到Esper admin.getConfiguration().addEventType("personEventTypeName",personTable);
发送map时,也可以通过epl语句建立。
//发送map时,也可以通过epl语句建立。 String createEpl="create schema appTable as (`id` int, `price` int, `color` string)"; admin.createEPL(createEpl);注意:如果把schema看成一张表,我们发送的map中列数少了不报错,列数多了不报错(esper只用能匹配得上的元素),列名对应的数据类型不匹配也不报错(esper不会帮你转换)。
例子
相关文章推荐
- parseSdkContent failed Could not initialize class android.graphics.Typeface异常
- 使用Micrisoft.net设计方案 第三章Web表示模式 Web模式集群详细介绍
- URAL 1018 Binary Apple Tree 树形DP 好题 经典
- IP包的协议字段
- Understanding CUDA grid dimensions, block dimensions and threads organization
- 关于innodb_file_per_table的一些理解
- YT02-简单数学课堂题-1002 Sort -(5.31日-烟台大学ACM预备队解题报告)
- 国内空气质量数据开源了
- 《实战Java虚拟机》,最简单的JVM入门书,京东活动,满200就减100了,该出手了
- 评教活动有感
- 计算机文化基础
- Ubuntu进入root权限命令——sudo和su命令详解
- 编译安装python2.7及相关模块(debian5.0.1)
- 关于视频后期美白的一些事
- YT02-简单数学课堂题-1001 Rightmost Digit-(5.31日-烟台大学ACM预备队解题报告)
- 软件公司的两种管理方式
- Mysql使用profiling分析慢sql语句的原因
- 【Android笔记】Android引用第三方依赖包library报错解决方法
- 设计模式基础
- 11GRAC CRS启动失败