US 2014/0279965 A1 · COMPRESSING TUPLES IN A STREAMING APPLICATION

Abstract

A method, system, and computer program product to process data in a streaming application are disclosed. The method, system, and computer program product may include receiving a stream of tuples to be processed by a plurality of processing elements operating on a plurality of compute nodes. The method, system, and computer program product may determine whether a first processing element has additional processing capacity. In some embodiments, the method, system, and computer program product determine whether a second processing element, which receives its input from the first processing element, also has additional processing capacity. The method, system, and computer program product may employ compression at the first processing element if one of the first and the second processing element has additional processing capacity.

Claims8

Dependent claims

A 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;
determining whether a first of the plurality of processing elements has a first additional processing capacity, the first of the plurality of processing elements providing an input to a second of the plurality of processing elements;
determining whether the second of the plurality of processing elements has a second additional processing capacity;
and
employing compression at the first of the plurality of processing elements if one of the first of the plurality of processing elements has the first additional processing capacity and the second of the plurality of processing elements has the second additional processing capacity.

2 more elements

Dependencies are inferred from the claim text.

Compressing tuples in a streaming application

Life of this patent

Compressing tuples in a streaming application

Life of this patent

Abstract

Claims8