Dynamically composing data stream processing applications

A method for dynamically modifying inter-connections between a plurality of components in a component-based data stream processing application, the method comprising:

• receiving a data producer profile for each of a plurality of output ports within a software application to be executed on one or more processors, wherein the application comprises a plurality of components that each comprise an output port that produces a data stream and an input port that consumes a data stream, and wherein each data producer profile describes a characteristic of the data produced by the corresponding output port;
• receiving a data subscription profile for each of one or more input ports of a plurality of components of the application, wherein each data subscription profile describes a characteristic of the data consumed by the input port;
• establishing one or more connections between output ports and input ports of the plurality of components in the application based on a comparison of received data producer profiles and received data subscription profiles;
• executing the data stream processing application on one or more processors to process one or more streams of data;
• receiving either or both of a new data producer profile or a new data subscription profile during the execution of the application;
• and
• establishing at least one new connection between an output port and an input port based upon a revised comparison of the received data profiles that include the one or more new data profiles.

A computer program product comprising a tangible computer readable recordable storage medium including computer useable program code for dynamically modifying inter-connections between a plurality of components in a component-based data stream processing application, the computer program product including:

• computer useable program code for receiving a data producer profile for each of a plurality of output ports within a software application to be executed on one or more processors, wherein the application comprises a plurality of components that each comprise an output port that produces a data stream and an input port that consumes a data stream, and wherein each data producer profile describes a characteristic of the data produced by the corresponding output port;
• computer useable program code for receiving a data subscription profile for each of one or more input ports of a plurality of components of the application, wherein each data subscription profile describes a characteristic of the data consumed by the corresponding input port;
• computer useable program code for establishing one or more connections between the output ports and the input ports of the plurality of components in the application based on a comparison of the received data producer profile and the received data subscription profile;
• computer useable program code for executing the data stream processing application on one or more processors to process one or more streams of data;
• computer useable program code for receiving either or both of a new data producer profile or a new data subscription profile during the execution of the application;
• and
• computer useable program code for establishing at least one new connection between an output port and an input port based upon a revised comparison of the received data profiles that include the one or more new data profiles.