-
公开(公告)号：EP2616965A1
公开(公告)日：2013-07-24
申请号：EP11761766.2
申请日：2011-09-16
IPC分类号： G06F17/30
CPC分类号： G06F16/24524 , G06F16/2452 , G06F16/24534
摘要： 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.
-
公开(公告)号：EP2959408A2
公开(公告)日：2015-12-30
申请号：EP14709807.3
申请日：2014-02-19
IPC分类号： G06F17/30
CPC分类号： G06F17/30516 , G06F17/30445 , G06F17/3051 , G06F17/30548
摘要： A continuous event processing (CEP) query processor determines how and when a CEP query can be processed in a concurrent manner, such that multiple threads of execution can concurrently perform at least some of the CEP query's operations concurrently with each other. According to one technique, a user can instruct a CEP query processor to attempt to execute a CEP query in a concurrent manner. The CEP query processor responsively determines whether the CEP query's execution, or parts thereof, can be made concurrent based on certain constraints that can depend on inheritance and operation type. Based on this determination, the CEP query processor can execute at least certain parts of a CEP query in parallel relative to the same event within an event stream.
-
公开(公告)号：EP2929467A1
公开(公告)日：2015-10-14
申请号：EP13815232.7
申请日：2013-12-04
IPC分类号： G06F17/30
CPC分类号： G06F17/30516
摘要： Large quantities of data can be processed and/or queried relatively quickly using a combination of continuous event processing and a Map-Reduce algorithmic tool. The continuous event processor can continuously produce real-time results by merging (a) CQL query results from events received since a currently executing Map-Reduce job was started with (b) a most recent query result produced by a most recently completed Map-Reduce job. When the currently executing Map-Reduce job completes, its query result can be stored and made accessible to the continuous event processor, and a new Map-Reduce job can be started relative to event data that has grown in size since the execution of the last Map-Reduce job. The Map-Reduce algorithmic tool provides a convenient mechanism for analyzing and processing large quantities of data.
-
-
5.发明公开
公开(公告)号：EP3198479A1
公开(公告)日：2017-08-02
申请号：EP15778105.5
申请日：2015-09-21
发明人： DE CASTRO ALVES, Alexandre , DESHMUKH, Unmesh Anil , BEDEKAR, Yogesh , THUKKARAM, Prabhu , MAHENDRU, Ashish
IPC分类号： G06F17/30
CPC分类号： G06F17/30516 , G06F17/30339 , G06F17/30557 , G06F17/30867
摘要： Some event ordering requirements can be determined based on continuous event processing queries. Other event ordering requirements can be determined based on distribution flow types being used to distribute events from event streams to node executing the queries. Events from event streams can be ordered according to ordering semantics that are based on a combination of all of these event ordering requirements. Additionally, virtual computing nodes can be associated with constraints, and computing processors can be associated with capabilities. Virtual computing nodes for processing event streams can be assigned to execute on various computing processors based on both these constraints and capabilities. Additionally, for each of several events in an event stream, a ratio between a total latency and a communication latency can be for determined. Based on an average of these ratios, a quantity of reducing nodes that will be involved in a map-reduce operation can be selected.
摘要翻译： 一些事件排序要求可以基于连续的事件处理查询来确定。 其他事件排序要求可以基于用于将事件从事件流分发到执行查询的节点的分发流类型来确定。 来自事件流的事件可以根据基于所有这些事件排序要求的组合的排序语义进行排序。 另外，虚拟计算节点可以与约束相关联，并且计算处理器可以与能力相关联。 用于处理事件流的虚拟计算节点可以被分配以基于这些约束和能力在各种计算处理器上执行。 另外，对于事件流中的多个事件中的每一个事件，可以确定总等待时间和通信等待时间之间的比率。 基于这些比率的平均值，可以选择将涉及地图缩小操作的减少节点的数量。
-
-
-
-
搜索结果
5 条记录 (耗时 0.01 秒)
