Generating a Distributed Stream Processing Application

A computer program product comprising a tangible computer readable recordable storage medium having computer readable program code for generating a distributed stream processing application, said computer program product including:

• computer readable program code for 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;
• computer readable program code for generating one or more containers that encompass a combination of one or more stream processing operators;
• and
• computer readable program code for 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.

An apparatus for generating a distributed stream processing application, comprising:

• a memory;
• and
• at least one processor coupled to said memory and operative to:
• obtain 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;
• generate one or more containers that encompass a combination of one or more stream processing operators;
• and
• generate 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.