Patent ID: 9122726
Filing Date: 2015-09-01
Classification: G06F

Abstract:
1. A computer program product for processing a stream of tuples, the computer program product comprising a non-transitory computer readable storage medium having program code embodied therewith, the program code comprising computer readable program code configured to: receive a stream of tuples to be processed by a plurality of processing elements operating on one or more computer processors, each processing element having one or more stream operators; determine, at the first stream operator, one or more parameters that represent a processing history of a tuple at the first stream operator; associate the one or more parameters with the tuple; compare a value of the one or more parameters and a corresponding threshold value; determine by the second stream operator, in response to the value of the one or more parameters falling outside the corresponding threshold value, to modify processing of the tuple; and modify processing of the tuple by routing the tuple to a modified execution path.