Suppressing stream functionality to expedite preferred data
AssigneeInternational Business Machines Corporation
InventorsEric L. Barsness, Michael J. Branson, John M. Santosuosso
Life of this patent
Estimating the term…
Abstract
A controller analyzes a tuple in an operator graph. The controller determines that the tuple includes one or more selected characteristics. These characteristics signify preferred data. The controller determines operations of the operator graph which can be suppressed. The controller suppresses the one or more operations. The controller suppresses those operations in response to the tuple including one or more of the selected characteristics.
Claims16
A computer system for managing selected data in a data stream comprising:
- a memory;
- one or more processing circuits communicatively coupled to the memory, wherein the one or more processing circuits are configured to:
- determine, by analyzing a first tuple in an operator graph, that the first tuple includes one or more selected characteristics from a set of selected characteristics, the set of selected characteristics consisting of characteristics indicative of data for expedited processing, the set of selected characteristics comprising hard-coded characteristics and learned characteristics;
- determine, in response to determining that the first tuple includes the one or more selected characteristics, one or more operations of the operator graph which are suppressible;
- suppress, in response to determining that the first tuple includes the one or more selected characteristics, the one or more operations for processing of the first tuple;
- analyze how tuples without characteristics from the set of selected characteristics are processed within the operator graph;
- detect that a subset of tuples without characteristics from the set of selected characteristics end the subset's processing chain with a same operation as tuples containing one or more characteristics from the set of selected characteristics;
- determine a common characteristic among the subset of tuples;
- and
- add the common characteristic as a learned characteristic to the set of selected characteristics.
A computer program product for managing selected data in a data stream, the computer program product comprising a computer readable storage medium having computer program instructions stored thereon, the program instructions executable by a computer processor of a computer to cause the computer to:
- determine, by analyzing a first tuple in an operator graph, that the first tuple includes one or more selected characteristics from a set of selected characteristics, the set of selected characteristics consisting of characteristics indicative of data for expedited processing, the set of selected characteristics comprising hard-coded characteristics and learned characteristics;
- determine, in response to determining that the first tuple includes the one or more selected characteristics, one or more operations of the operator graph which are suppressible;
- suppress, in response to determining that the first tuple includes the one or more selected characteristics, the one or more operations for processing of the first tuple;
- analyze how tuples without characteristics from the set of selected characteristics are processed within the operator graph;
- detect that a subset of tuples without characteristics from the set of selected characteristics end the subset's processing chain with a same operation as tuples containing one or more characteristics from the set of selected characteristics;
- determine a common characteristic among the subset of tuples;
- and
- add the common characteristic as a learned characteristic to the set of selected characteristics.
Dependencies are inferred from the claim text.