Event stream processing system

A stream processing system to ingest data from one or more data sources and convert the data into an unbounded stream for an event stream processor, the stream processing system comprising:

• a first coordinating spout instance that is deployed at a first time, the first coordinating spout instance to instantiate a second spout instance and a third spout instance;
• the first coordinating spout instance to sequentially deploy the second and third spout instances, the second spout instance deployed at a second time that is later than the first time and the third spout instance deployed at a third time that is later than the second time;
• the second and third spout instances to each ingest a same portion of the data from the one or more data sources and output first messages and second messages, respectively;
• wherein the unbounded stream for the event stream processor is based on the first and second messages.

A method of ingesting data from one or more data sources and convert the data into an unbounded stream for an event stream processor, the method comprising:

• deploying a first coordinating spout instance at a first time;
• after deploying the first coordinating spout instance, using 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;
• connecting to the one or more data sources, using the one or more second spout instances respectively, to ingest respective portions of the data from the one or more data sources;
• and
• outputting messages from the one or more second spout instances based on the ingested portions of the data;
• wherein the unbounded stream for the event stream processor is based on the messages.