System and method for defining windows of tuples of interest
AssigneeInternational Business Machines Corporation
InventorsJames Carey, Alexander Cook, Jason A. Nikolai, John M. Santosuosso
Life of this patent
Estimating the term…
Abstract
A method, computer program product, and computing device for identifying at least one tuple of interest from a plurality of tuples during execution of a streaming application. A window of tuples including the at least one tuple from the plurality of tuples may be defined. One or more operations may be performed on the window of tuples.
Claims17
A computer-implemented method for processing tuples of interest in a streaming application environment, comprising:
- identifying, at a computing device, at least one tuple of interest from a plurality of tuples in a data stream during execution of a streaming application, wherein each tuple within the plurality of tuples includes one or more attributes, wherein identifying the at least one tuple of interest includes identifying the at least one tuple of interest based upon, at least in part, an attribute value of the tuple of interest exceeding an attribute value threshold for the attribute value;
- defining a window of tuples including the at least one tuple of interest from the plurality of tuples;
- revising deployment of one or more stream operators on one or more host computing devices based on the identified at least one tuple of interest;
- and
- performing, using the one or more stream operators, one or more operations on the window of tuples.
A computer program product for processing tuples of interest in a streaming application environment, comprising a non-transitory computer readable storage medium having a plurality of instructions stored thereon, which, when executed by a processor, cause the processor to perform operations comprising:
- identifying, at a computing device, at least one tuple of interest from a plurality of tuples in a data stream during execution of a streaming application, wherein each tuple within the plurality of tuples includes one or more attributes, wherein identifying the at least one tuple of interest includes identifying the at least one tuple of interest based upon, at least in part, an attribute value of the tuple of interest exceeding an attribute value threshold for the attribute value;
- defining a window of tuples including the at least one tuple of interest from the plurality of tuples;
- revising deployment of one or more stream operators on one or more host computing devices based on the identified at least one tuple of interest;
- and
- performing, using the one or more stream operators, one or more operations on the window of tuples.
A computing system for processing tuples of interest in a streaming application environment, including one or more processors and one or more memories configured to perform operations comprising:
- identifying, at a computing device, at least one tuple of interest from a plurality of tuples in a data stream during execution of a streaming application, wherein each tuple within the plurality of tuples includes one or more attributes, wherein identifying the at least one tuple of interest includes identifying the at least one tuple of interest based upon, at least in part, an attribute value of the tuple of interest exceeding an attribute value threshold for the attribute value;
- defining a window of tuples including the at least one tuple of interest from the plurality of tuples;
- revising deployment of one or more stream operators on one or more host computing devices based on the identified at least one tuple of interest;
- and
- performing, using the one or more stream operators, one or more operations on the window of tuples.
Dependencies are inferred from the claim text.