MANAGEMENT SYSTEM FOR PROCESSING STREAMING DATA
1 Assignment
0 Petitions
Accused Products
Abstract
Techniques are disclosed for evaluating tuples for processing by a stream application having a plurality of process elements. In one embodiment, at least one tuple to be processed by at least one processing element of the stream application is identified. A maximum duration for which the at least one processing element is allowed to process the at least one tuple is determined. A duration for which the at least one processing element is likely to process the at least one tuple is also estimated. Processing of the at least one tuple is managed based on a comparison between the maximum duration and the estimated duration.
37 Citations
20 Claims
-
1-7. -7. (canceled)
-
8. A computer program product, comprising:
a computer-readable storage medium having computer-readable program code embodied therewith, the computer-readable program code comprising; computer-readable program code configured to receive streaming data to be processed by a stream application comprising a plurality of processing elements, wherein each processing element includes one or more operators that are contained within a single process, and wherein the streaming data includes a plurality of tuples; computer-readable program code configured to identify at least one tuple to be processed by at least one processing element of the stream application; computer-readable program code configured to determine a maximum duration for which the at least one processing element is allowed to process the at least one tuple; computer-readable program code configured to determine an estimated duration for which the at least one processing element is likely to process the at least one tuple; and computer-readable program code configured to manage processing of the at least one tuple, based on a comparison between the maximum duration and the estimated duration. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
15. A system, comprising:
-
one or more computer processors; a memory containing a program, which when executed by the one or more computer processors is configured to perform an operation comprising; receiving streaming data to be processed by a stream application, wherein the stream application comprises a plurality of processing elements, each processing element including one or more operators that are contained within a single process, and wherein the streaming data includes a plurality of tuples; identifying at least one tuple to be processed by at least one processing element; determining a maximum duration for which the at least one processing element is allowed to process the at least one tuple; determining an estimated duration for which the at least one processing element is likely to process the at least one tuple; and managing processing of the at least one tuple, based on a comparison between the maximum duration and the estimated duration. - View Dependent Claims (16, 17, 18, 19, 20)
-
Specification