Schwabe Willimason & Wyatt
Event stream processing system using a coordinating spout instance
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.
SALESFORCE.COM, INC
H G H H H G G G H H
H04L G06F H04L H04L H04L G06F G06F G06F H04L H04L
inventional inventional additional inventional inventional additional inventional inventional inventional additional
Kevin Stanley C. Stephen
Peek Lemon Powis