Patent ID: 8600976
Filing Date: 2013-12-03
Classification: G06F

Abstract:
1. A computer-implemented method, 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; invalidating the first data stream based on at least one attribute of the data tuples received via the first data stream; and issuing, by the first processing element, a message received by at least a second processing element that causes at least a second data stream in addition to the first data stream to be invalidated, wherein the second data stream comprises at least one of: (i) a subset of the data tuples of the first data stream processed by the first processing element and received by the second processing element, and (ii) a subset of the data tuples of the first data stream processed by a processing element upstream from the first processing element.