Patent ID: 8560726
Filing Date: 2013-10-15
Classification: G06F,H04L

Abstract:
1. A computer-readable storage medium storing an application, which, when executed on a hardware processor, performs a process, comprising: providing a plurality of processing elements comprising one or more operators, the operators configured to process streaming data tuples by operation of one or more computer processors; establishing an operator graph of a plurality of operators, the operator graph defining at least one execution path in which a first operator of the plurality of operators is configured to: (i) receive data tuples from at least one upstream operator and (ii) transmit data tuples to at least one downstream operator; receiving, at a first processing element of the plurality of processing elements, one or more data tuples associated with a first data stream and one or more data tuples associated with a second data stream; establishing, based on a specified metric, a first rate value associated with the first data stream and a second rate value associated with the second data stream; identifying a first subset of data tuples of the first data stream based on the first rate value and a second subset of data tuples based on the second rate value; processing, by the first processing element, the first and second subsets of data tuples; and outputting the first and second subsets of data tuples.