Patent · US Active

Event stream processing partitioning

US9405854B2 · kind B2 · utility

63Cited by
18References
20Claims
0Family size

Assignee

Inventors

Key dates

Filing dateMar 10, 2014
Grant dateAug 2, 2016
Priority date
Expiry dateOct 4, 2034

Classification

  • Technology area (CPC G)Physics
  • CPC primaryG06F16/24568
  • WIPO fieldComputer technology
  • WIPO sectorElectrical engineering

Abstract

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.

Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.