公开(公告)号：US20180324239A1

公开(公告)日：2018-11-08

申请号：US15838089

申请日：2017-12-11

Applicant: salesforce.com, inc.

Inventor： Stephen POWIS ,  Stan LEMON ,  Kevin PEEK

IPC: H04L29/06 ,  H04L29/08

CPC classification number: H04L65/607 ,  G06F9/4843 ,  G06F9/544 ,  G06F17/30516 ,  G06F17/3089 ,  H04L67/141 ,  H04L67/16

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.