1. 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, wherein the declarative description expresses at least one stream processing task; 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.