Data stream quality management for analytic environments

A method, comprising:

• deploying, into a runtime environment upstream from an analytic module, an ingress quality specification (IQS) module;
• receiving, by the IQS module, a data stream;
• selecting, by the IQS module, a subset of data of the data stream;
• determining if the subset of data meets a quality expectation of the analytic module by analyzing whether the subset of data includes a minimum quantity of data samples based on the quality expectation of the analytic module;
• responsive to determining that the subset of data meets the quality expectation, annotating the subset of data to indicate a quality status;
• and
• outputting the data stream with the annotated subset of data to the analytic module.

A method, comprising:

• receiving, by a first ingress quality specification (IQS) module deployed in a runtime environment, a data stream;
• applying, by the first IQS module, a first predicate to a subset of data of the data stream to determine if the subset of data meets a first quality expectation of a downstream analytic module;
• making a first annotation in the subset of data to indicate a quality status based on a result of applying the first predicate;
• outputting by the first IQS module the data stream to a second IQS module;
• applying, by the second IQS module, a second predicate to the subset of data to determine if the subset of data meets a second quality expectation of the analytic module;
• making a second annotation in the subset of data to indicate a quality status based on a result of applying the second predicate;
• receiving, by the analytic module, the data stream from the second IQS module and analyzing the subset of data to assess a performance level of a monitored object, the analytic module discerning between the first annotation and the second annotation to determine whether to include the subset of data in the assessment of the monitored object.