SMART TUPLE DYNAMIC GROUPING OF TUPLES
First Claim
1. A method for processing a stream of tuples, the method comprising:
- receiving, by a stream application, a stream of tuples to be processed by a plurality of processing elements operating on one or more compute nodes, each processing element having one or more stream operators;
assigning, by the stream application, one or more processing cycles to one or more segments of software code embedded in a tuple of the stream of tuples; and
executing, by the software-embedded tuple, the following operations;
identifying a set of target tuples of the stream of tuples based upon operation criteria; and
performing, based on the set of identified target tuples, an operation.
1 Assignment
0 Petitions
Accused Products
Abstract
A stream application receives a stream of tuples to be processed by a plurality of processing elements. The plurality of processing elements operating on one or more compute nodes. Each processing element has one or more stream operators. The stream application assigns one or more processing cycles to one or more segments of software code. The segments of software code are embedded in a tuple of the stream of tuples. The software-embedded tuple identifies a set of target tuples based upon operation criteria. The set of target tuples are a part of the stream of tuples. The software-embedded tuple performs an operation based on the set of identified target tuples.
14 Citations
12 Claims
-
1. A method for processing a stream of tuples, the method comprising:
-
receiving, by a stream application, a stream of tuples to be processed by a plurality of processing elements operating on one or more compute nodes, each processing element having one or more stream operators; assigning, by the stream application, one or more processing cycles to one or more segments of software code embedded in a tuple of the stream of tuples; and executing, by the software-embedded tuple, the following operations; identifying a set of target tuples of the stream of tuples based upon operation criteria; and performing, based on the set of identified target tuples, an operation. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12)
-
Specification