Generating differences for tuple attributes
A sequence of tuples, each having one or more attributes, is received at one of one or more processing elements operating on one or more processors. Each processing element may have one or more stream operators. A first stream operator may be identified as one that only processes an instance of a first attribute in a currently received tuple when a difference between an instance of the first attribute in a previously received tuple and the instance of the first attribute in the currently received tuple is outside of a difference threshold. A second stream operator may generate a difference attribute from a first instance of the first attribute in a first one of the received tuples and a second instance of the first attribute in a second one of the received tuples. The difference attribute may be transmitted from the second stream operator to the first stream operator.
1. A computer-implemented method for processing tuples on one or more computer processors, each tuple having one or more attributes, comprising:
receiving at one of one or more processing elements a sequence of two or more tuples to be processed by the one or more processing elements, each processing element having one or more stream operators;
identifying that a first stream operator only processes an instance of a first attribute in a currently received tuple when a difference between an instance of the first attribute in a previously received tuple and the instance of the first attribute in the currently received tuple is outside of a difference threshold;
generating, at a second stream operator, a first difference attribute from a first instance of the first attribute and a second instance of the first attribute;
determining whether the first difference attribute is outside of the difference threshold;
transmitting the first difference attribute from the second stream operator to the first stream operator when the first difference attribute is outside of the difference threshold;
configuring the first stream operator to receive reference instances of the first attribute and difference attributes; and
entering a dormant mode, at the first stream operator, when the first stream operator does not receive a difference attribute for a particular period of time.
2. The method of claim 1 , further comprising requesting that a reference instance of the first attribute be transmitted to the first stream operator when the first stream operator leaves the dormant mode.
3. The method of claim 2 , further comprising transmitting the reference instance of the first attribute to the first stream operator.
4. The method of claim 3 , wherein the reference instance of the first attribute is substantially the same as the first instance of the first attribute.