Scalable update propagation via query aggregations and connection migrations
US11087047B2 · kind B2 · utility
Assignee
Inventors
Key dates
| Filing date | Aug 3, 2018 |
| Grant date | Aug 10, 2021 |
| Priority date | — |
| Expiry date | Aug 3, 2038 |
Classification
- Technology area (CPC H)Electricity
- CPC primaryH04L67/566
- WIPO fieldComputer technology
- WIPO sectorElectrical engineering
Abstract
Methods, systems, computer-readable media, and apparatuses for combining nodes and/or aggregating streaming queries in a simulation are presented. In some examples, combining nodes and/or aggregating streaming queries may result in less duplicative data being sent through the system. A first node may be connected to a first aggregator, and the first aggregator may be connected to a second node. In some examples, the first node may comprise a client or another aggregator, and the second node may comprise a data source or another aggregator. Based on a determination that a first streaming query subscription of the first node connected to the first aggregator has changed to a second streaming query subscription, one or more aggregator controller(s) may determine to migrate the first node to a different aggregator. Migrating the first node to a different aggregator may increase overlap of streaming query subscriptions in the system and/or reduce the amount of duplicative data being sent through the system.
Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.