Managing a stream computing environment using a projected database object

1. A computer-implemented method for managing a stream computing environment using a projected database object, the method comprising:

comparing, with respect to a database management system (DBMS) that relates to the stream computing environment, a set of realized data of a realized database object of the DBMS with a set of projected data of a projected database object of the DBMS;

identifying, based on comparing the set of realized data of the realized database object with the set of projected data of the projected database object, an outlier subset of the set of projected data of the projected database object;

structuring, based on the outlier subset of the set of projected data of the projected database object, an outlier response operation for execution in the stream computing environment;

executing, based on the outlier subset of the set of projected data of the projected database object, the outlier response operation in the stream computing environment which corresponds to the outlier subset of the set of projected data of the projected database object;

detecting a triggering event; and

modifying, in response to detecting the triggering event, the set of projected data of the projected database object to match the set of realized data of the realized database object.

2. The method of claim 1 , further comprising:

ascertaining, based on the outlier subset of the set of projected data of the projected database object, that the stream computing environment includes a set of outlier tuples.

3. The method of claim 1 , further comprising:

structuring the outlier response operation to include a filtering operation;

correlating the outlier subset of the set of projected data of the projected database object with a set of outlier tuples of the stream computing environment; and

filtering, in the stream computing environment, the set of outlier tuples that correlates to the outlier subset of the set of projected data of the projected database object.

4. The method of claim 1 , further comprising:

structuring the outlier response operation to include a prioritization-downgrade operation;

correlating the outlier subset of the set of projected data of the projected database object with a set of outlier tuples of the stream computing environment; and

downgrading, in the stream computing environment, a priority of the set of outlier tuples that correlates to the outlier subset of the set of projected data of the projected database object.

5. The method of claim 1 , further comprising:

structuring the outlier response operation to include a marking operation;

correlating the outlier subset of the set of projected data of the projected database object with a set of outlier tuples of the stream computing environment; and

marking, in the stream computing environment, the set of outlier tuples that correlates to the outlier subset of the set of projected data of the projected database object.

6. The method of claim 1 , further comprising:

structuring the outlier response operation to include a tracing operation;

correlating the outlier subset of the set of projected data of the projected database object with a set of outlier tuples of the stream computing environment; and

tracing, in the stream computing environment, the set of outlier tuples that correlates to the outlier subset of the set of projected data of the projected database object.

7. The method of claim 1 , further comprising:

structuring the outlier response operation to include a code robustness operation;

correlating the outlier subset of the set of projected data of the projected database object with a set of outlier tuples of the stream computing environment; and

modifying, in the stream computing environment, a robust nature of a set of code to process the set of outlier tuples that correlates to the outlier subset of the set of projected data of the projected database object.

8. The method of claim 1 , further comprising:

structuring the outlier response operation to include a routing operation;

correlating the outlier subset of the set of projected data of the projected database object with a set of outlier tuples of the stream computing environment; and

routing, to an execution path in the stream computing environment, the set of outlier tuples that correlates to the outlier subset of the set of projected data of the projected database object.

9. The method of claim 1 , further comprising:

structuring the outlier response operation to include a performance collection operation;

correlating the outlier subset of the set of projected data of the projected database object with a set of outlier tuples of the stream computing environment; and

collecting, in the stream computing environment, a set of outlier tuple performance information for the set of outlier tuples that correlates to the outlier subset of the set of projected data of the projected database object.

10. The method of claim 1 , further comprising:

structuring the outlier response operation to include an ancillary action prevention operation;

correlating the outlier subset of the set of projected data of the projected database object with a set of outlier tuples of the stream computing environment; and

preventing, in the stream computing environment, a set of ancillary actions with respect to the set of outlier tuples that correlates to the outlier subset of the set of projected data of the projected database object.

11. The method of claim 1 , further comprising:

structuring the outlier response operation to include a projection-prevention operation;

correlating the outlier subset of the set of projected data of the projected database object with a set of outlier tuples of the stream computing environment; and

preventing, with respect to the DBMS, a projection of the set of outlier tuples that correlates to the outlier subset of the set of projected data of the projected database object.

12. The method of claim 1 , further comprising:

capturing a referral value which indicates references to a set of columns of the DBMS;

comparing the referral value with a threshold value related to references;

computing that the referral value exceeds the threshold value related to references; and

modifying, based on and in response to computing that the referral value exceeds the threshold value related to references, the set of projected data of the projected database object to harmonize with the set of realized data of the realized database object.

13. The method of claim 1 , further comprising:

evaluating, to identify the outlier subset of the set of projected data of the projected database object, the set of projected data of the projected database object with respect to a set of outlier classification criteria selected from the group consisting of:

a data relevance criterion;

a data corruption criterion;

a data conformity criterion;

a data exception criterion; and

a data confidence criterion.

14. The method of claim 1 , further comprising:

performing, in a dynamic fashion to streamline management of the stream computing environment using the projected database object, each of:

the comparing, the identifying, and the executing.

15. The method of claim 1 , further comprising:

executing, in an automated fashion without user intervention, each of:

the comparing, the identifying, and the executing.

16. The method of claim 1 , further comprising:

receiving a stream of tuples to be processed by a set of processing elements which operates on a set of compute nodes; and

processing, using the set of processing elements operating on the set of compute nodes, the stream of tuples.

17. A system for managing a stream computing environment using a projected database object, 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:

comparing, with respect to a database management system (DBMS) that relates to the stream computing environment, a set of realized data of a realized database object of the DBMS with a set of projected data of a projected database object of the DBMS;

identifying, based on comparing the set of realized data of the realized database object with the set of projected data of the projected database object, an outlier subset of the set of projected data of the projected database object;

structuring, based on the outlier subset of the set of projected data of the projected database object, an outlier response operation for execution in the stream computing environment;

executing, based on the outlier subset of the set of projected data of the projected database object, the outlier response operation in the stream computing environment which corresponds to the outlier subset of the set of projected data of the projected database object;

detecting a triggering event; and

modifying, in response to detecting the triggering event, the set of projected data of the projected database object to match the set of realized data of the realized database object.

18. A computer program product for managing a stream computing environment using a projected database object, the computer program product comprising a computer 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:

comparing, with respect to a database management system (DBMS) that relates to the stream computing environment, a set of realized data of a realized database object of the DBMS with a set of projected data of a projected database object of the DBMS;

identifying, based on comparing the set of realized data of the realized database object with the set of projected data of the projected database object, an outlier subset of the set of projected data of the projected database object;

structuring, based on the outlier subset of the set of projected data of the projected database object, an outlier response operation for execution in the stream computing environment;

executing, based on the outlier subset of the set of projected data of the projected database object, the outlier response operation in the stream computing environment which corresponds to the outlier subset of the set of projected data of the projected database object;

detecting a triggering event; and

modifying, in response to detecting the triggering event, the set of projected data of the projected database object to match the set of realized data of the realized database object.