Parallel data stream processing method, parallel data stream processing system, and storage medium
US10459921B2 · kind B2 · utility
Assignee
Inventors
Key dates
| Filing date | Nov 17, 2015 |
| Grant date | Oct 29, 2019 |
| Priority date | — |
| Expiry date | May 5, 2037 |
Classification
- Technology area (CPC G)Physics
- CPC primaryG06F16/24554
- WIPO fieldComputer technology
- WIPO sectorElectrical engineering
Abstract
A non-transitory computer-readable storage medium stores a data stream processing program that causes a computer to execute a process. The process includes extracting a relationship between properties included in events in a data stream from the data stream itself, definitions of queries for processing the data stream, or both of the data stream and the definitions of the queries; specifying a common partitioning key common to a subset of the queries to be grouped into a partitioning group based on partitioning keys in the definitions of the queries, the relationship between the properties, and a probability of the relationship; and assigning the subset of the queries belonging to the partitioning group to each of parallel nodes provided for parallel distributed processing based on the specified common partitioning key.
Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.