公开(公告)号：US20150169786A1

公开(公告)日：2015-06-18

申请号：US14203248

申请日：2014-03-10

申请人： Zbigniew Jerzak ,  IBRAHIM AHMED ,  PALANIAPPAN GANDHI

发明人： Zbigniew Jerzak ,  IBRAHIM AHMED ,  PALANIAPPAN GANDHI

IPC分类号： G06F17/30

CPC分类号： G06F17/30958 ,  G06F17/30433 ,  G06F17/30516

摘要： In an example embodiment, event stream processing is performed by first parsing an input query into a directed acyclic graph (DAG) including a plurality of operator nodes. Then a grouping of one or more of the operator nodes is created. One or more partitions are created, either by the user or automatically, in the DAG by forming one or more duplicates of the grouping. A splitter node is created in the DAG, the splitter node splits data from one or more event streams and distributes it among the grouping and the duplicates of the grouping. Then, the input query is resolved by processing data from one or more event streams using the DAG.

摘要翻译： 在示例实施例中，通过首先将输入查询解析成包括多个运算符节点的有向非循环图（DAG）来执行事件流处理。 然后创建一个或多个运算符节点的分组。 一个或多个分区由用户或自动地在DAG中通过形成分组的一个或多个重复来创建。 在DAG中创建分离器节点，分离器节点从一个或多个事件流分割数据，并将其分配到分组和分组的重复之间。 然后，通过使用DAG处理来自一个或多个事件流的数据来解析输入查询。