1. A method for optimizing data stream processing, comprising the steps of: employing a pattern, wherein the pattern facilitates splitting of one or mole incoming streams and distributing processing across one or more operators; obtaining one or mote operators, wherein the one or more operators support at least one group-independent aggregation and join operation on one or more streams; generating code, wherein the code facilitates mapping of the application onto a computational infrastructure to enable workload partitioning; using the one or more operators to decompose each of the application into one or more granular components; and using the code to reassemble the one or more granular components into one or more deployable blocks to map the application to a computational infrastructure, wherein reassembling the one or more granular components to map the application to the computational infrastructure optimizes data stream processing of the application.