Real-time analysis of data streaming objects for distributed stream processing

Methods, systems, and apparatus 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 stream.