| 主权项 |
1. A method for processing a stream of tuples, comprising:
receiving 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, a first stream operator configured to associate an indication to tuples that require modified processing and a second stream operator configured to perform a data processing operation; receiving a first tuple at the second stream operator; first examining, by the second stream operator, the first tuple for the indication; performing, by the second stream operator, the data processing operation on first data in response to the receiving the first tuple, the performing the data processing operation based on not detecting the indication during the first examining, the data processing operation modifying the first data in a first manner; receiving a second tuple at the second stream operator; second examining, by the second stream operator, the second tuple for the indication; and performing, by the second stream operator, a modified data processing operation on second data in response to the receiving the second tuple, the performing the modified data processing operation based on detecting the indication during the second examining, the indication having been associated with the second tuple by the first stream operator, the modified data processing operation modifying the second data in a second manner different from the first manner, the second tuple remaining in the stream of tuples after the performing the modified data processing operation. |
