Patent ID: 8407360

Claim:
A method for generating a distributed stream processing application, comprising the steps of: obtaining a declarative description of one or more data stream processing tasks from a graph of operators, wherein the declarative description expresses at least one stream processing task; generating one or more containers that encompass a combination of one or more stream processing operators via fusing an output of an upstream operator into an input of a downstream operator within a same container, wherein said fusing comprises: using a function call to propagate one or more stream data objects from the output of the upstream operator to the input of the downstream operator; and using one or more queues and one or more execution threads to propagate one or more stream data objects from the output of the upstream operator to the input of the downstream operator; and generating one or more execution units from the declarative description of one or more data stream processing tasks, wherein the one or more execution units are deployable across one or more distributed computing nodes, and comprise a distributed data stream processing application binary.