Handling faults in a continuous event processing (CEP) system

    公开(公告)号:US09262258B2

    公开(公告)日:2016-02-16

    申请号:US14692674

    申请日:2015-04-21

    摘要: The concept of faults and fault handling are added to the execution of continuous event processing (CEP) queries. By introducing fault handling techniques to the processing of CEP queries, users are enabled to instruct a CEP query processor to respond to faults in a customized manner that does not necessarily involve the halting of the CEP query relative to which the faults occurred. For example, a fault might be due to a temporary problem. Under such circumstances, the CEP query processor can be instructed to ignore the fault and allow the execution of the CEP query to continue relative to the remainder of the event stream. Alternatively, if the fault is due to a problem with the CEP query itself, then the CEP query processor can be instructed to propagate the fault through the query processing system until the fault ultimately causes the problematic CEP query to be halted.

    Support for a parameterized query/view in complex event processing
    24.
    发明授权
    Support for a parameterized query/view in complex event processing 有权
    在复杂事件处理中支持参数化查询/视图

    公开(公告)号:US09110945B2

    公开(公告)日:2015-08-18

    申请号:US14077230

    申请日:2013-11-12

    IPC分类号: G06F17/30

    摘要: The present invention includes a method for providing parameterized queries in complex event processing (CEP). The method includes providing a query template which includes one or more bind variables, providing sets of parameters corresponding to the one or more bind variables, and parsing the query template to determine positions of the one or more bind variables. The method further includes scanning the provided sets of parameters to determine which of the sets of parameters are to be bound to the one or more bind variables, binding the one or more bind variables which are determined to be bound to the sets of parameters, and substituting the bound one or more bind variables with the corresponding sets of parameters. The method further includes injecting all incarnations of the parameterized queries into the system, and one template/parameterized query is configured to run them all.

    摘要翻译: 本发明包括一种在复杂事件处理(CEP)中提供参数化查询的方法。 该方法包括提供包括一个或多个绑定变量的查询模板,提供与一个或多个绑定变量相对应的参数集合,以及解析查询模板以确定一个或多个绑定变量的位置。 该方法还包括扫描所提供的参数集合以确定参数组中的哪一组要绑定到一个或多个绑定变量,将被确定为绑定的一个或多个绑定变量绑定到参数集合,以及 用绑定的一个或多个绑定变量替换相应的参数集。 该方法还包括将参数化查询的所有形式注入到系统中,并且一个模板/参数化查询被配置为全部运行它们。

    HANDLING FAULTS IN A CONTINUOUS EVENT PROCESSING (CEP) SYSTEM
    25.
    发明申请
    HANDLING FAULTS IN A CONTINUOUS EVENT PROCESSING (CEP) SYSTEM 有权
    连续事件处理(CEP)系统中的处理故障

    公开(公告)号:US20150227415A1

    公开(公告)日:2015-08-13

    申请号:US14692674

    申请日:2015-04-21

    IPC分类号: G06F11/07 G06F17/30

    摘要: The concept of faults and fault handling are added to the execution of continuous event processing (CEP) queries. By introducing fault handling techniques to the processing of CEP queries, users are enabled to instruct a CEP query processor to respond to faults in a customized manner that does not necessarily involve the halting of the CEP query relative to which the faults occurred. For example, a fault might be due to a temporary problem. Under such circumstances, the CEP query processor can be instructed to ignore the fault and allow the execution of the CEP query to continue relative to the remainder of the event stream. Alternatively, if the fault is due to a problem with the CEP query itself, then the CEP query processor can be instructed to propagate the fault through the query processing system until the fault ultimately causes the problematic CEP query to be halted.

    摘要翻译: 故障和故障处理的概念被添加到执行连续事件处理(CEP)查询。 通过将故障处理技术引入到CEP查询的处理中,用户能够指示CEP查询处理器以定制的方式响应故障,这些定制方式不一定涉及停止发生故障的CEP查询。 例如,故障可能是由于临时问题。 在这种情况下,可以指示CEP查询处理器忽略故障,并允许CEP查询的执行相对于事件流的其余部分继续执行。 或者,如果故障是由于CEP查询本身的问题,则可以指示CEP查询处理器通过查询处理系统传播故障,直到故障最终导致有问题的CEP查询被停止。

    Variable duration non-event pattern matching
    26.
    发明授权
    Variable duration non-event pattern matching 有权
    可变持续时间非事件模式匹配

    公开(公告)号:US09098587B2

    公开(公告)日:2015-08-04

    申请号:US13839288

    申请日:2013-03-15

    IPC分类号: G06F7/00 G06F17/30

    CPC分类号: G06F17/30864 G06F17/30286

    摘要: Techniques for performing non-event pattern matching on continuous event streams using variable duration. The duration value used in non-event pattern matching can be variable. Accordingly, a first pattern match candidate can have a different associated duration from a second pattern match candidate for matches arising from events received via an event stream. In certain embodiments, the duration for a candidate pattern match may be based upon one or more attributes of an event that started the candidate pattern match or based upon an expression (e.g., an arithmetic expression) involving one or more attributes of the event.

    摘要翻译: 使用可变持续时间在连续事件流上执行非事件模式匹配的技术。 在非事件模式匹配中使用的持续时间值可以是变量。 因此,第一模式匹配候选可以具有与从经由事件流接收的事件产生的匹配的第二模式匹配候选的不同的关联持续时间。 在某些实施例中,候选模式匹配的持续时间可以基于启动候选模式匹配的事件的一个或多个属性,或者基于涉及事件的一个或多个属性的表达式(例如,算术表达式)。

    PATTERN MATCHING ACROSS MULTIPLE INPUT DATA STREAMS
    27.
    发明申请
    PATTERN MATCHING ACROSS MULTIPLE INPUT DATA STREAMS 有权
    图形匹配多个输入数据流

    公开(公告)号:US20150161214A1

    公开(公告)日:2015-06-11

    申请号:US14559550

    申请日:2014-12-03

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30495 G06F17/30516

    摘要: A method for detecting patterns across multiple input data streams related to one or more applications is disclosed. The method includes receiving multiple input data streams and generating one or more dynamic data types for one or more attributes of the input data streams. In some embodiments, the method may include combining the input data streams to generate a combined input data stream based on the dynamic data types and processing a continuous query over the combined data stream to detect a pattern.

    摘要翻译: 公开了一种用于检测与一个或多个应用相关的多个输入数据流的模式的方法。 该方法包括接收多个输入数据流并为输入数据流的一个或多个属性生成一个或多个动态数据类型。 在一些实施例中,该方法可以包括组合输入数据流以基于动态数据类型生成组合输入数据流,并通过组合数据流处理连续查询以检测模式。

    Handling faults in a continuous event processing (CEP) system
    28.
    发明授权
    Handling faults in a continuous event processing (CEP) system 有权
    在连续事件处理(CEP)系统中处理故障

    公开(公告)号:US09047249B2

    公开(公告)日:2015-06-02

    申请号:US13770969

    申请日:2013-02-19

    IPC分类号: G06F11/00 G06F11/20

    摘要: The concept of faults and fault handling are added to the execution of continuous event processing (CEP) queries. By introducing fault handling techniques to the processing of CEP queries, users are enabled to instruct a CEP query processor to respond to faults in a customized manner that does not necessarily involve the halting of the CEP query relative to which the faults occurred. For example, a fault might be due to a temporary problem. Under such circumstances, the CEP query processor can be instructed to ignore the fault and allow the execution of the CEP query to continue relative to the remainder of the event stream. Alternatively, if the fault is due to a problem with the CEP query itself, then the CEP query processor can be instructed to propagate the fault through the query processing system until the fault ultimately causes the problematic CEP query to be halted.

    摘要翻译: 故障和故障处理的概念被添加到执行连续事件处理(CEP)查询。 通过将故障处理技术引入到CEP查询的处理中,用户能够指示CEP查询处理器以定制的方式响应故障,这些定制方式不一定涉及停止发生故障的CEP查询。 例如,故障可能是由于临时问题。 在这种情况下,可以指示CEP查询处理器忽略故障,并允许CEP查询的执行相对于事件流的其余部分继续执行。 或者,如果故障是由于CEP查询本身的问题,则可以指示CEP查询处理器通过查询处理系统传播故障,直到故障最终导致有问题的CEP查询被停止。

    VARIABLE DURATION WINDOWS ON CONTINUOUS DATA STREAMS
    29.
    发明申请
    VARIABLE DURATION WINDOWS ON CONTINUOUS DATA STREAMS 审中-公开
    连续数据流的可变持续时间窗口

    公开(公告)号:US20140201355A1

    公开(公告)日:2014-07-17

    申请号:US13838259

    申请日:2013-03-15

    IPC分类号: H04L12/26

    摘要: Improved techniques are provided for processing streams of data. The duration of the time that an event is eligible for remaining in a time-based window can be variable for different events received via the same event stream. In certain embodiments, the duration of time that an input event spends in a time-based window is a function of one or more values of one or more attributes of the event. Since different events can have different one or more attribute values, the different events can spend different amounts of time in the time-based window for that event stream. The amount of time that an event spends in a time-based window can be controlled via the one or more attributes of the event.

    摘要翻译: 提供了改进的技术来处理数据流。 事件有资格保留在时间窗口中的持续时间可以通过相同的事件流接收的不同事件是可变的。 在某些实施例中,输入事件在基于时间的窗口中花费的持续时间是事件的一个或多个属性的一个或多个值的函数。 由于不同的事件可以具有不同的一个或多个属性值,所以不同的事件可以在该事件流的基于时间的窗口中花费不同的时间量。 事件在时间窗口中花费的时间量可以通过事件的一个或多个属性进行控制。