LIMITING TUPLE CREATION AT THE TUPLE LEVEL

摘要

An administrator may wish to limit the number of tuples that may be spawned as a result of a first tuple entering an operator graph. A first stream operator may receive a first tuple in order to perform an operation on the first tuple to generate a second tuple. The first stream operator may determine whether it is permitted to generate the second tuple by comparing the first tuple's tuple spawn counts to a tuple creation policy. If the first stream operator is permitted to generate the second tuple, the first stream operator may perform the operation on the first tuple and generate the second tuple.

主权项

1. A computer implemented 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, wherein one or more of the stream operators include code configured to output tuples to one or more other stream operators; receiving a first tuple at a first stream operator, the first stream operator being configured to perform one or more operations on the first tuple and to output a second tuple; determining, using a tuple creation policy for the first tuple, that the first stream operator is permitted to generate the second tuple, wherein the tuple creation policy includes a first tuple creation parameter, the first tuple creation parameter defining a maximum number of associated spawn tuples that the first stream operator is permitted to generate for the first tuple; and generating, by the first stream operator and in response to determining that the first stream operator is permitted to generate the second tuple, the second tuple.