Event stream processing system using a coordinating spout instance
US10645138B2 · kind B2 · utility
Assignee
Inventors
Key dates
| Filing date | Dec 11, 2017 |
| Grant date | May 5, 2020 |
| Priority date | — |
| Expiry date | Mar 18, 2038 |
Classification
- Technology area (CPC H)Electricity
- CPC primaryH04L67/141
- WIPO fieldDigital communication
- WIPO sectorElectrical engineering
Abstract
In one embodiment, a stream processing system ingests data from one or more data sources and converts the data into an unbounded stream for an event stream processor. The stream processing system may include a first coordinating spout instance that is deployed at a first time, the first coordinating spout instance to instantiate one or more second spout instances and deploy said one more second spout instances at a second time that is later than the first time; the one or more second spout instances to: connect to the one or more data sources, respectively, and ingest a respective portion of the data from its respective one of the one or more data sources; and output messages based on the ingested portions of the data; wherein the unbounded stream for the event stream processor is based on the messages. Other embodiments may be disclosed and/or claimed.
Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.