Sharing of Flows in a Stream Processing System

A computer program product comprising a tangible computer readable recordable storage medium including computer useable program code for generating code for a flow, the computer program product including:

• computer useable program code for receiving a flow for an application to be deployed, wherein the flow comprises one or more sub-flows;
• computer useable program code for identifying one or more sub-flows of the flow that match one or more existing sub-flows that are already running in one or more separate flows by querying a run-time flow information repository;
• computer useable program code for generating code for the flow, wherein the code comprises newly generated code for each of the one or more sub-flows that do not match one or more existing sub-flows that are already running in one or more separate flows, and wherein the code also comprises one or more connectors to one or more matching sub-flows that are already running in one or more separate flows in lieu of generating new code for the one or more sub-flows that match one or more existing sub-flows that are already running in one or more separate flows;
• and
• computer useable program code for deploying the generated code for the flow and updating the run-time flow information repository with information pertaining to the flow.

A system for generating code for a flow, comprising:

• a memory;
• and
• at least one processor coupled to the memory and operative to:
• receive a flow for an application to be deployed, wherein the flow comprises one or more sub-flows;
• identify one or more sub-flows of the flow that match one or more existing sub-flows that are already running in one or more separate flows by querying a run-time flow information repository;
• generate code for the flow, wherein the code comprises newly generated code for each of the one or more sub-flows that do not match one or more existing sub-flows that are already running in one or more separate flows, and wherein the code also comprises one or more connectors to one or more matching sub-flows that are already running in one or more separate flows in lieu of generating new code for the one or more sub-flows that match one or more existing sub-flows that are already running in one or more separate flows;
• and
• deploy the generated code for the flow and update the run-time flow information repository with information pertaining to the flow.