Dynamic deployment placement of processing elements in a streaming data system

A non-transitory computer-readable medium storing a program executable to perform operations for deploying a stream computing application including a plurality of processing elements, the operations comprising:

• profiling an execution of the plurality of processing elements of the stream computing application in a test environment to determine a class loaded for each of the plurality of processing elements, the stream computing application having an operator graph that specifies a flow of data tuples among the plurality of processing elements;
• determining at least one of a runtime metric of each of the plurality of processing elements and a system characteristic of each of a plurality of compute nodes;
• determining a network proximity of each of the plurality of compute nodes to a data source external to the stream computing application;
• determining, by one or more computer processors when executing the program, a plurality of groupings of the plurality of processing elements on the plurality of compute nodes based on at least three criteria selected from the class loaded, the runtime metric, the system characteristic, and the network proximity;
• and
• subsequent to deploying the plurality of processing elements to the plurality of compute nodes for execution based on the plurality of groupings, redeploying the at least one processing element to a different compute node upon determining that at least one criterion has changed.

A computer-implemented method for deploying a stream computing application including a plurality of processing elements, the computer-implemented method comprising:

• determining a class loaded for each of the plurality of compute nodes, the stream computing application having an operator graph that specifies a flow of data tuples among the plurality of processing elements;
• determining at least one of a runtime metric of each of the plurality of processing elements and a system characteristic of each of a plurality of compute nodes;
• determining a network proximity of each of the plurality of compute nodes to a data source external to the stream computing application;
• determining, by operation of one or more computer processors, a plurality of groupings of the plurality of processing elements on the plurality of the compute nodes based on at least three criteria selected from the class loaded, the runtime metric, the system characteristic, and the network proximity;
• and
• subsequent to deploying the plurality of processing elements to the plurality of compute nodes for execution based on the plurality of groupings, redeploying the at least one processing element to a different compute node upon determining that at least one criterion has changed.