PLACEMENT OF SERVICES IN STREAM COMPUTING APPLICATIONS

摘要

A stream of tuples to be processed by a plurality processing elements executing on two or more compute nodes is received. Each compute node stores one or more of the processing elements having one or more stream operators. It is determined whether an overhead parameter associated with a first streams service located at a first stream operator is outside of a first overhead criterion. The first streams service is ended at the first stream operator and a second streams service is instantiated at a second stream operator when the overhead parameter associated with the first streams service is outside of the first overhead criterion. The second stream operator is different from the first stream operator. The method may include determining whether the first streams service samples a first data attribute of tuples or measures performance.

主权项

1. A computer-implemented method for processing streaming data, comprising:
receiving a stream of tuples to be processed by a plurality processing elements executing on two or more compute nodes, each compute node having one or more processors and a memory to store one or more of the processing elements, each processing element including one or more stream operators, wherein each stream operator is connected to at least one other stream operator and the stream operators define an operator graph having one or more execution paths corresponding with one or more flows of tuples between the stream operators; determining whether an overhead parameter associated with a first streams service located at a first stream operator is outside of a first overhead criterion; and ending the first streams service at the first stream operator, and instantiating a second streams service at a second stream operator in the operator graph when the overhead parameter associated with the first streams service is outside of the first overhead criterion, wherein the second stream operator is different from the first stream operator.