Twitter, Inc. (delisted)
Real-time analysis of data streaming objects for distributed stream processing

Abstract:

Methods, systems, and apparatus, including computer programs encoded on computer storage media, for data stream processing. One method performed by a stream manager in a group of containers including streaming processes and stream managers includes receiving a first data streaming object of the data streaming objects from a first component in the group of containers; determining whether to process the first data streaming object; in response to determining to process the first data streaming object processing the first data streaming object and routing the first data streaming object; and in response to determining not to process the first data streaming object, routing the first data streaming object.