TUPLE ROUTING IN A STREAMING APPLICATION

摘要

A system and method for modifying the processing within a streaming application are disclosed. The method may determine one or more parameters for a tuple at a first stream operator. The one or more parameters may represent a processing history of the tuple at the first stream operator. The method may associate the one or more parameters with the tuple metadata. A second stream operator may modify the processing of the tuple if the parameter falls outside a threshold.

主权项

1. A computer program product for processing a stream of tuples, the computer program product comprising a 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 one or more parameters at a first stream operator, wherein the one or more parameters represent a processing history of a tuple at the first stream operator; associate the one or more parameters with the tuple; determine by a second stream operator whether to modify processing of the tuple based on the one or more parameters; and modify processing of the tuple if a parameter falls outside a threshold.