Esper事件处理引擎_14_EPL 语法_7_Patterns_1_模式匹配
2014-08-13 16:33
429 查看
Esper 事件引擎栏目:http://blog.csdn.net/xiaohulunb/article/category/2436609
EPL 语法代码见-GitHub代码地址:点击打开链接
涉及 Javabean,Listener,main 以 GitHub 包下为最新更,注释解释排版有问题可参考源码
EPL_7_Patterns_1语法
package com.framework_technology.esper.epl; import com.framework_technology.esper.javabean.Apple; import com.framework_technology.esper.javabean.Banana; import com.java.annotation.document.Faulty; import com.java.annotation.document.Unfinished; /** * api - Chapter 6. EPL Reference: Patterns * <p> * 模式表现形式包括原子模式和运算模式: * <p> * 1.原子模式的模式的基本构建块。原子是过滤表达式,观察员基于时间的事件和插件定制观察家认为没有观察引擎的控制下,外部事件。 * Pattern Atom Example * ==================================================================================================================== * 过滤器表达式 StockTick(symbol='ABC', price > 100) * 基于时间的间隔或者安排 timer:interval(10 seconds) timer:at(*, 16, *, *, *) * 自定义插件 myapplication:myobserver("http://someResource") * <p> * 2.运算模式控制表达的生命周期,并结合原子逻辑或时间 * <p> * 有4种模式操作符: * <p> * 1.运算模式控制子表达式重复: every, every-distinct, [num] and until * 2.逻辑运算符: and, or, not * 3.时态操作,操作事件顺序: -> (followed-by) * 4.守护where-conditions控制子表达式的生命周期。例子是 timer:within, timer:withinmax and while-expression.自定义插件也可以使用。 * * @author wei.Li by 14-8-13. */ public class EPL_7_Patterns_1 { /** * simple example * * @return epl1 */ protected static String inEPL() { //每进入一个Banana事件则输出跟随前面的Apple 事件 String epl1 = "select a.* from pattern[every a=" + Apple.CLASSNAME + " -> b=" + Banana.CLASSNAME + "]"; //查询 (每进入一个Banana事件则输出跟随的Apple 事件1分钟内id相等的数据)在过去的5分钟内id在 ('0' , '1' , '2')中 String epl2 = "select a.* from " + "pattern[every a=" + Apple.CLASSNAME + " -> b=" + Banana.CLASSNAME + "(a.id=b.id) where timer:within(1 min)]" + ".win:time(5 min) where a.id in ('0' , '1' , '2')"; @Unfinished(Description = "语句解析错误") String epl3 = "select * from pattern [every (" + Apple.CLASSNAME + " or " + Banana.CLASSNAME + ").win:length(10)]"; return epl2; } /** * 抑制相同的事件 API - 6.2.6. Suppressing Same-Event Matches * <p> * Patterns:[every a=A -> B] * <p> * 事件进入顺序 A1 A2 B1 : * 当事件B1到达模式为两者的组合{ A1,B1 }和组合{ A2,B1 }匹配。 * <p> * 使用@SuppressOverlappingMatches格局级别标注,指示引擎匹配到第一个后放弃后面所有。 * <p> * 该引擎只考虑用于检测重叠标记的事件。 * 禁止以多个同时发生的事件中发生的单一事件或抵达时间推进的结果。 * 部分完成的模式不会受到影响和现有模式状态不会改变,因为抑制的结果。 * 限制:注释不能用有模式的加入。 * * @return epl1 */ @Faulty(Description = "注解解析错误,API 6.2.6. Suppressing Same-Event Matches") protected static String SuppressingSame_EventMatches() { String epl1 = " select * from " + "pattern @SuppressOverlappingMatches [every a=" + Apple.CLASSNAME + " -> b=" + Banana.CLASSNAME + "]"; return epl1; } /** * 丢弃部分的匹配 API - 6.2.7. Discarding Partially Completed Patterns * <p> * Patterns:[every a=A -> B and C(id=a.id)] * <p> * 事件进入顺序 A1{id='id1'} A2{id='id2'} B1 * <p> * 根据上面的序列没有匹配。C模式部分完成等待事件。 * 正在等待一个C { id ="id1"}事件之后的模式匹配完成组合{ A1,B1 }。 * 正在等待一个C { id ="id2"}事件之后的模式匹配完成组合{ A2,B1 }。 * <p> * 假设事件C1 { id ="id1")到达模式输出组合{ A1、B1、C1 }。 * 假设事件C2 { id ="id2")到达模式输出组合{ A2、B1、C2 }。 * 请注意,事件B1 partially-completed模式的一部分。 * <p> * 使用@DiscardPartialsOnMatch pattern-level注释指示引擎,当任何匹配发生后丢弃部分完成模式的重叠事件的匹配(或匹配如果有多个匹配)。 * * @return epl */ protected static String discardingPartiallyCompletedPatterns() { /** * 当事件C1 { id =“id1”)到达模式输出匹配组合{ A1、B1、C1 }。 * 匹配引擎丢弃所有的指示partially-completed模式指的A1,B1和C1事件。 * 由于事件B1 partially-completed模式的一部分,等待C { id =“id2”},引擎丢弃partially-completed模式。 * 因此,当C2 { id =“id2”}到引擎输出不匹配。 */ String epl1 = "select * from pattern @DiscardPartialsOnMatch [every a=A -> B and C(id=a.id)]"; return epl1; } /** * 当指定@DiscardPartialsOnMatch和@SuppressOverlappingMatches引擎丢弃partially-completed重叠所有匹配包括抑制匹配的模式。 * @see #SuppressingSame_EventMatches() 抑制匹配 * @see #discardingPartiallyCompletedPatterns() 丢弃部分的匹配 */ /** * 匹配操作的优先级 * API - 6.3. Operator Precedence * 见图片 * 图1 有优先级的模式匹配 * 图2 级别相等的模式匹配 * 查考文档的 table */ /** * 模式条件中的过滤操作 * * @return epl */ protected static String filterExpressions() { /** * 每进入一个Banana事件则输出跟随前面的Apple 事件 * 多个 and 条件可以用,隔开 * 静态方法的调用 */ String epl1 = "select a.* from " + "pattern[every a=" + Apple.CLASSNAME + "(a.price > 5 , id in ('0','1','2'),a.getPriceByDiscount(price,discount) > 3) -> " + "b=com.framework_technology.esper.javabean.Banana(" + Banana.CLASSNAME + ".getPriceByDiscount2StaticMethod(price,discount) > 3)]"; return epl1; } /** * 控制事件的消耗匹配 API - 6.4.1. Controlling Event Consumption * <p> * Patterns:[ a=RfidEvent(zone='Z1') and b=RfidEvent(assetId='0001')] * 在这种模式,一个RfidEvent事件到达具有区"Z1"和assetId “0001” 。 * 模式也匹配,当两个RfidEvent事件到达,以任何顺序,其中,一个具有带"Z1" ,而另一个具有assetId “0001” 。 * <p> * 用@consume过滤器表达式来表示,如果一个到达的事件相匹配的引擎,匹配明显的过滤器表达式,不匹配任何其他过滤器表达式多重过滤表达式。 * 该@consume包括括号中的级别数。默认级别数是与同级别的数字1。多个过滤表达式@consume匹配所有的事件。 * <p> * Patterns修改为:[ a=RfidEvent(zone='Z1')@consume and b=RfidEvent(assetId='0001')] * 这种模式当单个RfidEvent到来,带Z1,assetId‘0001’,因为当第一个过滤器表达式匹配模式引擎使用事件。 * 在任何顺序模式只匹配两个RfidEvent事件到达时。一个事件必须带Z1,然后其他事件必须有一个带“Z1”和一个assetId‘0001’。 * * @return epl */ protected static String ControllingEventConsumption() { /** * 当RfidEvent zone="Z1"模式到达 。 * 在这种情况下,输出事件填充属性' A' ,但不是'B '和' C'内容 。 * 当RfidEvent zone="Z1"和“0001”=assetId的模式到达。 * 在这种情况下,输出事件填充属性' B' ,但不是'a'和'C'内容 。 * 当RfidEvent zone="Z1"和assetId=“0001”和类=“perishable”的模式到达。 * 在这种情况下,输出事件填充属性' C' ,但不是'A'和'B' 。 */ String epl1 = "a=RfidEvent(zone='Z1')@consume(2)" + " or b=RfidEvent(assetId='0001')@consume(1)" + " or c=RfidEvent(category='perishable'))"; return epl1; } /** * Use With Named Windows * API - 6.4.2. Use With Named Windows */ @Unfinished protected static String namedWindows() { /** * @see com.framework_technology.esper.epl.EPL_8_NamedWindow */ return null; } }
图1 有优先级的模式匹配
图2 级别相等的模式匹配
相关文章推荐
- Esper事件处理引擎_15_EPL 语法_7_Patterns_2_模式匹配
- Esper事件处理引擎_17_EPL 语法_9_Schema 声明数据类型
- Esper事件处理引擎_8_EPL 语法_2_Context 上下文_2_条件控制
- Esper事件处理引擎_5_EPL 语法_1_基本语法
- Esper事件处理引擎_7_EPL 语法_3_Output 输出条件语法
- Esper事件处理引擎_16_EPL 语法_8_NamedWindow
- Esper事件处理引擎_11_EPL 语法_4_InsertInto 流对流的插入操作
- Esper事件处理引擎_13_EPL 语法_6_Annotation注解使用
- Esper事件处理引擎_10_EPL 语法___View 窗口视图条件语法
- Esper事件处理引擎_6_EPL 语法_2_Context 上下文_1_simple
- Esper事件处理引擎_10_EPL 语法___View 窗口视图条件语法
- Esper事件处理引擎_9_EPL 语法_2_Context 上下文_3_过滤条件
- Esper事件处理引擎_12_EPL 语法_5_Subqueries子查询
- 复杂事件处理引擎—Esper 处理模型
- 高性能复杂事件处理---模式匹配
- 复杂事件处理引擎—Esper入门
- PHP扩展之文本处理(二)——PCRE正则表达式语法14——注释及递归模式
- #分布式系统架构之# 事件驱动模式以及与之匹配的长时间处理过程讨论
- 复杂事件处理引擎—Esper参考(事件部分)
- Esper事件处理引擎_4_XML 数据结构处理