Granted Patent B1

US 10,049,136 · App. 15/800,414 · Granted Aug 14, 2018

Inventors: Eric L. Barsness (Pine Island, MN); Daniel E. Beuch (Rochester, MN); Alexander Cook (Chaska, MN); John M. Santosuosso (Rochester, MN)

Assignee: International Business Machines Corporation

G06F17/30516G06F17/30289G06F17/30867

Abstract

Claims (34)

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;

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;

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, the set of outlier classification criteria comprising: a data relevance criterion, a data corruption criterion, a data conformity criterion, a data exception criterion, and a data confidence criterion;

determining, 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;

structuring the outlier response operation to include a filtering operation;

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

structuring the outlier response operation to include a marking operation;

structuring the outlier response operation to include a tracing operation;

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

structuring the outlier response operation to include a routing operation;

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

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

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 the set of outlier tuples of the stream computing environment;

executing, based on the outlier subset of the set of protected 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, wherein executing 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 comprises:

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

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

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

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

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

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

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

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

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

detecting a triggering event;

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;

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;

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;

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.

Assignments (1)

Continuity (1)

Cited By (10)

US 12,231,510 US 12,278,875 US 12,301,683 US 12,309,237 US 12,505,409 US 12,519,867 US 12,530,661 US 12,531,934 US 12,664,148 US 12,675,773