Join operations for continuous queries over archived views
    52.
    发明授权
    Join operations for continuous queries over archived views 有权
    加入操作以对存档视图进行连续查询

    公开(公告)号:US09262479B2

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

    申请号:US14037171

    申请日:2013-09-25

    IPC分类号: G06F17/30

    摘要: A continuous query may be received, the continuous query being identified based at least in part on an archived view. The archived view may be created and/or identified based at least in part on a join query related to two or more archived relations associated with an application, at least one of the two or more archived relations being identified as a dimension relation. A query plan for the continuous query may be generated. A join operator in the query plan may be identified based at least in part on the dimension relation. A state of an operator corresponding to the dimension relation may be initialized. It may be identified if the state of the operator identifies an event that detects a change to the dimension relation. The continuous query may be re-started based at least in part on the event that detects the change to the dimension relation.

    摘要翻译: 可以接收连续查询,至少部分地基于归档视图来识别连续查询。 可以至少部分地基于与应用相关联的两个或多个存档关系的连接查询来创建和/或识别归档视图,所述两个或多个存档关系中的至少一个被标识为维度关系。 可以生成连续查询的查询计划。 可以至少部分地基于维度关系来识别查询计划中的连接运算符。 对应于尺寸关系的操作者的状态可以被初始化。 如果操作者的状态识别检测到尺寸关系的变化的事件,则可以识别它。 至少部分地基于检测到维度关系的改变的事件重新开始连续查询。

    SUPPORT FOR A NEW INSERT STREAM (ISTREAM) OPERATION IN COMPLEX EVENT PROCESSING (CEP)
    53.
    发明申请
    SUPPORT FOR A NEW INSERT STREAM (ISTREAM) OPERATION IN COMPLEX EVENT PROCESSING (CEP) 有权
    支持新的插入流(ISTREAM)在复杂事件处理(CEP)中的操作

    公开(公告)号:US20150156241A1

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

    申请号:US14621098

    申请日:2015-02-12

    摘要: One embodiment of the invention includes a method of processing streaming data. The method includes initializing a stream of data and setting a time interval to apply to the stream of data. The time interval comprises a window for analyzing the data within the stream of data. The method further includes identifying one or more columns within the stream of data, designating one or more of the columns to be monitored for differences within the data over the time interval, and monitoring the designated columns over the time interval. Further, the method includes determining that at least one value from at least one of the designated columns has changed and in response to at least one value changing, outputting the changed values from the designated columns.

    摘要翻译: 本发明的一个实施例包括处理流数据的方法。 该方法包括初始化数据流并设置应用于数据流的时间间隔。 时间间隔包括用于分析数据流内的数据的窗口。 该方法还包括识别数据流内的一个或多个列,指定待监视的一列或多列待数据在时间间隔内的差异,以及在该时间间隔内监视指定的列。 此外,该方法包括确定来自至少一个指定列的至少一个值已经改变并且响应于至少一个值改变,从指定列输出改变的值。

    VARIABLE DURATION NON-EVENT PATTERN MATCHING
    54.
    发明申请
    VARIABLE DURATION NON-EVENT PATTERN MATCHING 有权
    可变时间非事件模式匹配

    公开(公告)号:US20140201225A1

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

    申请号:US13839288

    申请日:2013-03-15

    IPC分类号: 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.

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

    SUPPORT FOR A PARAMETERIZED QUERY/VIEW IN COMPLEX EVENT PROCESSING
    55.
    发明申请
    SUPPORT FOR A PARAMETERIZED QUERY/VIEW IN COMPLEX EVENT PROCESSING 有权
    支持在复杂事件处理中进行参数查询/查看

    公开(公告)号:US20140136514A1

    公开(公告)日:2014-05-15

    申请号: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)中提供参数化查询的方法。 该方法包括提供包括一个或多个绑定变量的查询模板,提供与一个或多个绑定变量相对应的参数集合,以及解析查询模板以确定一个或多个绑定变量的位置。 该方法还包括扫描所提供的参数集合以确定参数组中的哪一组要绑定到一个或多个绑定变量,将被确定为绑定的一个或多个绑定变量绑定到参数集合,以及 用绑定的一个或多个绑定变量替换相应的参数集。 该方法还包括将参数化查询的所有形式注入到系统中,并且一个模板/参数化查询被配置为全部运行它们。

    GENERATION OF ARCHIVER QUERIES FOR CONTINUOUS QUERIES OVER ARCHIVED RELATIONS
    58.
    发明申请
    GENERATION OF ARCHIVER QUERIES FOR CONTINUOUS QUERIES OVER ARCHIVED RELATIONS 有权
    通过存档关系生成连续查询的存档查询

    公开(公告)号:US20140095445A1

    公开(公告)日:2014-04-03

    申请号:US14036659

    申请日:2013-09-25

    IPC分类号: G06F17/30

    摘要: A method may include receiving a continuous query identified by an archived relation associated with an application. The method may also include generating a physical query plan. Additionally, the method may include constructing a structured query language (SQL) equivalent expression corresponding to an attribute utilized by the operator and/or constructing an output SQL expression for the identified operator based at least in part on the SQL equivalent expression. Additionally, the method may include constructing the archiver query for the identified operator based at least in part on the output SQL expression. Further, the method may include executing the archiver query to obtain a result set of data records related to the application and/or generating a snapshot output of one or more data values related to the application based at least in part on the result set of data records.

    摘要翻译: 方法可以包括接收由与应用相关联的归档关系识别的连续查询。 该方法还可以包括生成物理查询计划。 另外,该方法可以包括至少部分地基于SQL等效表达来构造对应于运营商利用的属性的结构化查询语言(SQL)等效表达和/或为所识别的运算符构建输出SQL表达式。 另外,该方法可以包括至少部分地基于输出SQL表达式来构建针对所识别的运算符的归档器查询。 此外,该方法可以包括执行归档器查询以至少部分地基于数据的结果集来获得与应用相关的数据记录的结果集和/或生成与应用相关的一个或多个数据值的快照输出 记录。

    OPERATOR SHARING FOR CONTINUOUS QUERIES OVER ARCHIVED RELATIONS

    公开(公告)号:US20220147528A1

    公开(公告)日:2022-05-12

    申请号:US17584148

    申请日:2022-01-25

    IPC分类号: G06F16/2453 G06F16/2455

    摘要: A continuous query identified by an archived relation of an application may be received. A physical query plan may be generated for the continuous query and/or a child operator plan may be identified. A buffer operator may be inserted between the child operator and its parent operator and/or the event information from the child operator may be stored in the buffer operator. A query operator may be identified in the physical query plan. It may be determined that the query operator identified in the physical query plan is a same type as a second query operator in a second continuous query concurrently executing. Further, a combined query plan may be generated based at least in part on the query operator identified in the physical query plan being the same type as the second query operator in the second continuous query.