Processing element host management in a stream computing environment

Abstract

Disclosed aspects relate to processing element host management in a stream computing environment having a pool of compute nodes to host a set of processing elements. A set of processing element placement criteria may be identified for the pool of compute nodes with respect to processing element placement on the pool of compute nodes. A set of processing element profile data may be detected for the set of processing elements with respect to processing element placement on the pool of compute nodes. By comparing the set of processing element profile data and the set of processing element placement criteria, a placement arrangement for the set of processing elements on the pool of compute nodes may be determined. Based on the placement arrangement, the set of processing elements may be established on the pool of compute nodes.

What is claimed is: 
     
         1 . A computer-implemented method comprising:
 identifying, in a subpool of a pool of compute nodes in a stream computing environment, a set of invitation-only host tags associated with a processing element placement on the pool of compute nodes for processing element host management in the stream computing environment;   determining, based on the identified set of invitation-only host tags, a pre-requisite indicated by a respective compute node for the processing element placement on the respective compute node, wherein the determined pre-requisite designates a target processing element type as being eligible for the processing element placement on the respective compute node;   in response to identifying a subset of a set of processing elements that includes a set of tagging criteria which matches the identified set of invitation-only host tags in the subpool of the pool of compute nodes, prioritizing an assignment of the identified subset of the set of processing elements to the subpool of the pool of compute nodes; and   isolating the prioritized assignment of the identified subset of the set of processing elements that have the set of tagging criteria which matches the identified set of invitation-only host tags in the subpool of the pool of compute nodes in the stream computing environment.   
     
     
         2 . The method of  claim 1 , further comprising:
 receiving, from the pool of compute notes, a set of processing element placement criteria; and   detecting, in the received set of processing element placement criteria from the subpool of the pool of compute nodes, the identified set of invitation-only host tags.   
     
     
         3 . The method of  claim 2 , further comprising:
 detecting, for the set of processing elements with respect to the processing element placement on the pool of compute nodes, a set of processing element profile data, wherein the detected set of processing element profile data includes a set of tagging criteria.   
     
     
         4 . The method of  claim 3 , further comprising:
 determining a placement arrangement for the set of processing elements on the pool of compute nodes by comparing the set of tagging criteria of the set of processing elements and the received set of processing element placement criteria of the pool of compute nodes.   
     
     
         5 . The method of  claim 4 , further comprising:
 establishing, based on the determined placement arrangement, the set of processing elements on the pool of compute nodes.   
     
     
         6 . The method of  claim 3 , further comprising:
 resolving that a first subset of the set of processing element profile data for a first processing element of the set of processing elements does not achieve a first subset of the set of processing element placement criteria for a first compute node of the pool of compute nodes; and   preventing assignment of the first processing element to the first compute node.   
     
     
         7 . The method of  claim 3 , further comprising:
 resolving that a first subset of the set of processing element profile data for a first processing element of the set of processing elements achieves a first subset of the set of processing element placement criteria for a first compute node of the pool of compute nodes; and   allocating the first processing element to the first compute node.   
     
     
         8 . The method of  claim 6 , further comprising:
 resolving that the first subset of the set of processing element profile data for the first processing element of the set of processing elements achieves a second subset of the set of processing element placement criteria for a second compute node of the pool of compute nodes; and   allocating the first processing element to the second compute node.   
     
     
         9 . The method of  claim 1 , further comprising:
 configuring, without modifying a streaming application source code, a set of processing element profile data associated with the set of processing elements.   
     
     
         10 . The method of  claim 1 , further comprising:
 configuring, without modifying a streaming application source code, a set of processing element placement criteria received from the pool of compute notes.   
     
     
         11 . The method of  claim 1 , further comprising:
 in response to determining that a first tagging criterion of the set of tagging criteria matches a first invitation-only host tag of the set of invitation-only host tags, allocating a first processing element of the set of processing elements to a first compute node of the pool of compute nodes; and   in response to determining that a second tagging criterion of the set of tagging criteria mismatches a second invitation-only host tag of the set of invitation-only host tags, preventing assignment of a second processing element of the set of processing elements to a second compute node of the pool of compute nodes.   
     
     
         12 . The method of  claim 1 , wherein each invitation-only host tag of the set of invitation-only host tags matches at least one tagging criterion of the set of tagging criteria, and further comprising:
 configuring, without modifying a streaming application source code, the set of tagging criteria.   
     
     
         13 . The method of  claim 4 , wherein each invitation-only host tag of the set of invitation-only host tags matches at least one tagging criterion of the set of tagging criteria, and further comprising:
 configuring, without modifying a streaming application source code, the set of invitation-only host tags.   
     
     
         14 . The method of  claim 13 , further comprising:
 redetermining, in an automated fashion without user intervention, the placement arrangement in response to configuring the set of invitation-only host tags.   
     
     
         15 . The method of  claim 1 , further comprising:
 receiving a stream of tuples to be processed by the set of processing elements operating on the pool of compute nodes; and   processing, using the set of processing elements operating on the pool of compute nodes, the stream of tuples.   
     
     
         16 . A computer system for processing element host management, comprising:
 one or more processors, one or more computer-readable memories, one or more computer-readable tangible storage media, and program instructions stored on at least one of the one or more computer-readable tangible storage media for execution by at least one of the one or more processors via at least one of the one or more memories, wherein the computer system is capable of performing a method comprising:   identifying, in a subpool of a pool of compute nodes in a stream computing environment, a set of invitation-only host tags associated with a processing element placement on the pool of compute nodes for processing element host management in the stream computing environment;   determining, based on the identified set of invitation-only host tags, a pre-requisite indicated by a respective compute node for the processing element placement on the respective compute node, wherein the determined pre-requisite designates a target processing element type as being eligible for the processing element placement on the respective compute node;   in response to identifying a subset of a set of processing elements that includes a set of tagging criteria which matches the identified set of invitation-only host tags in the subpool of the pool of compute nodes, prioritizing an assignment of the identified subset of the set of processing elements to the subpool of the pool of compute nodes; and   isolating the prioritized assignment of the identified subset of the set of processing elements that have the set of tagging criteria which matches the identified set of invitation-only host tags in the subpool of the pool of compute nodes in the stream computing environment.   
     
     
         17 . The computer system of  claim 16 , further comprising:
 receiving, from the pool of compute notes, a set of processing element placement criteria; and   detecting, in the received set of processing element placement criteria from the subpool of the pool of compute nodes, the identified set of invitation-only host tags.   
     
     
         18 . The computer system of  claim 17 , further comprising:
 detecting, for the set of processing elements with respect to the processing element placement on the pool of compute nodes, a set of processing element profile data, wherein the detected set of processing element profile data includes a set of tagging criteria.   
     
     
         19 . The computer system of  claim 18 , further comprising:
 determining a placement arrangement for the set of processing elements on the pool of compute nodes by comparing the set of tagging criteria of the set of processing elements and the received set of processing element placement criteria of the pool of compute nodes.   
     
     
         20 . A computer program product for processing element host management, the computer program product comprising:
 one or more computer-readable storage media and program instructions collectively stored on the one or more computer-readable storage media, the program instructions comprising:   program instructions to identify, in a subpool of a pool of compute nodes in a stream computing environment, a set of invitation-only host tags associated with a processing element placement on the pool of compute nodes for processing element host management in the stream computing environment;   program instructions to determine, based on the identified set of invitation-only host tags, a pre-requisite indicated by a respective compute node for the processing element placement on the respective compute node, wherein the determined pre-requisite designates a target processing element type as being eligible for the processing element placement on the respective compute node;   program instructions to, in response to identifying a subset of a set of processing elements that includes a set of tagging criteria which matches the identified set of invitation-only host tags in the subpool of the pool of compute nodes, prioritize an assignment of the identified subset of the set of processing elements to the subpool of the pool of compute nodes; and   program instructions to isolate the prioritized assignment of the identified subset of the set of processing elements that have the set of tagging criteria which matches the identified set of invitation-only host tags in the subpool of the pool of compute nodes in the stream computing environment.