Operator fusion management in a stream computing environment

Abstract

Disclosed aspects relate to managing a set of development data for operator fusion management in a stream computing environment having a plurality of stream operators. A set of operator attributes of the plurality of stream operators may be collected by an operator fusion management engine in the stream computing environment. A set of candidate operator fusion management operations may be determined with respect to the plurality of stream operators. The set of candidate operator fusion management operations may be determined by the operator fusion management engine based on the set of operator attributes. At least one of the set of candidate operator fusion management operations may be performed in the stream computing environment with respect to the plurality of stream operators.

What is claimed is: 
     
         1 . A computer-implemented method for operator fusion management in a stream computing environment having a plurality of stream operators, the method comprising:
 collecting, by an operator fusion management engine in the stream computing environment, a set of operator attributes of the plurality of stream operators;   determining, by the operator fusion management engine based on the set of operator attributes, a set of candidate operator fusion management operations with respect to the plurality of stream operators; and   performing, in the stream computing environment with respect to the plurality of stream operators, at least one of the set of candidate operator fusion management operations.   
     
     
         2 . The method of  claim 1 , further comprising:
 prescribing, related to an inclusion-exclusion determination of the set of candidate operator fusion management operations with respect to the plurality of stream operators, a user-directed fusion of the plurality of stream operators; and   proscribing, related to the inclusion-exclusion determination of the set of candidate operator fusion management operations with respect to the plurality of stream operators, a non-user-directed fusion of the plurality of stream operators.   
     
     
         3 . The method of  claim 1 , further comprising:
 detecting that a first subset of stream operators of the plurality of stream operators has a first subset of operator attributes of the set of operator attributes;   detecting that a second subset of stream operators of the plurality of stream operators has a second subset of operator attributes of the set of operator attributes;   comparing, to determine the set of candidate operator fusion management operations with respect to the plurality of stream operators, the first subset of operator attributes of the set of operator attributes with the second subset of operator attributes of the set of operator attributes;   resolving, based on the comparing, a mismatch of the first and second subsets of operator attributes of the set of operator attributes to determine the set of candidate operator fusion management operations with respect to the plurality of stream operators; and   proscribing, related to an inclusion-exclusion determination of the set of candidate operator fusion management operations with respect to the plurality of stream operators, an operator fusion action of the first and second stream operators based on the mismatch.   
     
     
         4 . The method of  claim 3 , further comprising:
 detecting that the first subset of operator attributes has a first set of values which indicates a first set of operator regions;   detecting that the second subset of operator attributes has a second set of values which indicates a second set of operator regions that differs from the first set of operator regions; and   determining, by the operator fusion management engine based on the first and second sets of values, the set of candidate operator fusion management operations with respect to the plurality of stream operators.   
     
     
         5 . The method of  claim 4 , further comprising:
 authorizing, related to the inclusion-exclusion determination of the set of candidate operator fusion management operations with respect to the plurality of stream operators, an operator fusion action of the first subset of stream operators and a third subset of stream operators having a third subset of operator attributes which does not indicate the second set of operator regions.   
     
     
         6 . The method of  claim 3 , further comprising:
 detecting that the first subset of operator attributes has a first set of values which indicates a first set of channels of a first set of operator regions;   detecting that the second subset of operator attributes has a second set of values which indicates a second set of channels of the first set of operator regions that differs from the first set of channels; and   determining, by the operator fusion management engine based on the first and second sets of values, the set of candidate operator fusion management operations with respect to the plurality of stream operators.   
     
     
         7 . The method of  claim 6 , further comprising:
 authorizing, related to the inclusion-exclusion determination of the set of candidate operator fusion management operations with respect to the plurality of stream operators, an operator fusion action of the first subset of stream operators and a third subset of stream operators having a third subset of operator attributes which does not indicate the second set of channels.   
     
     
         8 . The method of  claim 1 , further comprising:
 determining, using a segregated location criterion pertaining to a region of stream operators, the set of candidate operator fusion management operations with respect to the plurality of stream operators.   
     
     
         9 . The method of  claim 1 , further comprising:
 determining, using a provisional location criterion pertaining to a region of stream operators, the set of candidate operator fusion management operations with respect to the plurality of stream operators.   
     
     
         10 . The method of  claim 1 , further comprising:
 determining, using a soft-partition co-locate criterion pertaining to a region of stream operators, the set of candidate operator fusion management operations with respect to the plurality of stream operators.   
     
     
         11 . The method of  claim 1 , further comprising:
 preventing, with respect to a first stream operator having a first virtual machine configuration and a second stream operator having a second virtual machine configuration, an operator fusion action.   
     
     
         12 . The method of  claim 1 , further comprising:
 fusing, with respect to a first group of stream operators that has a first set of computing capabilities which are identical, the first group of stream operators; and   preventing, with respect to a second group of stream operators that has a second set of computing capabilities which are non-identical, an operator fusion action.   
     
     
         13 . The method of  claim 1 , further comprising:
 preventing, by the operator fusion management engine with respect to the plurality of stream operators, an automated operator fusion action; and   authorizing, by the operator fusion management engine, a manual operator fusion action.   
     
     
         14 . The method of  claim 1 , further comprising:
 fusing, with respect to a first group of stream operators of a same parallel channel, the first group of stream operators; and   preventing, with respect to a second group of stream operators of different parallel channels, an operator fusion action.   
     
     
         15 . The method of  claim 1 , further comprising:
 fusing, with respect to a first group of stream operators of a first channel of a first region and a second group of stream operators of a second channel of a second region, the first and second groups of stream operators; and   preventing, with respect to the first group of stream operators of the first channel of the first region and a third group of stream operators of a third channel of the first region, an operator fusion action.   
     
     
         16 . The method of  claim 1 , further comprising:
 providing, by the operator fusion management engine, a debug notification which indicates a fusion activity event.   
     
     
         17 . The method of  claim 1 , further comprising:
 executing, in a dynamic fashion to streamline operator fusion management in the stream computing environment, each of:
 the collecting, the determining, and the performing. 
   
     
     
         18 . The method of  claim 1 , further comprising:
 executing, in an automated fashion without user intervention, each of:
 the collecting, the determining, and the performing. 
   
     
     
         19 . A system for operator fusion management in a stream computing environment having a plurality of stream operators, the system comprising:
 a memory having a set of computer readable computer instructions, and   a processor for executing the set of computer readable instructions, the set of computer readable instructions including:   collecting, by an operator fusion management engine in the stream computing environment, a set of operator attributes of the plurality of stream operators;   determining, by the operator fusion management engine based on the set of operator attributes, a set of candidate operator fusion management operations with respect to the plurality of stream operators; and   performing, in the stream computing environment with respect to the plurality of stream operators, at least one of the set of candidate operator fusion management operations.   
     
     
         20 . A computer program for operator fusion management in a stream computing environment having a plurality of stream operators, the computer program product comprising a readable storage medium having program instructions embodied therewith, wherein the computer readable storage medium is not a transitory signal per se, the program instructions executable by a processor to cause the processor to perform a method comprising:
 collecting, by an operator fusion management engine in the stream computing environment, a set of operator attributes of the plurality of stream operators;   determining, by the operator fusion management engine based on the set of operator attributes, a set of candidate operator fusion management operations with respect to the plurality of stream operators; and   performing, in the stream computing environment with respect to the plurality of stream operators, at least one of the set of candidate operator fusion management operations.