Patent ID: 9280549
Filing Date: 2016-03-08
CPC Classification: G06F

Claim Text:
1. A computer-implemented method for processing a stream of tuples, comprising: receiving the stream of tuples to be processed by a plurality of processing elements operating on a plurality of compute nodes; monitoring performance of each processing element in a set of processing elements, the set including a first, a second, and one or more additional processing elements of the plurality of processing elements; determining whether the first processing element has a first additional processing capacity by comparing a first performance metric for the first processing element with respective first performance metrics for processing elements of the set, the first processing element operating on a first compute node and providing an input to the second processing element operating on a second compute node; determining whether the second processing element has a second additional processing capacity by comparing a first performance metric for the second processing element with respective first performance metrics for processing elements of the set; employing compression on a tuple at the first processing element if the first processing element has the first additional processing capacity or the second processing element has the second additional processing capacity, wherein the employing of compression on the tuple at the first processing element includes: transmitting the compressed tuple to the second processing element.