Patent ID: 8972480
Filing Date: 2015-03-03
Classification: H04L,H04N

Abstract:
1. A computer-implemented method for processing data, comprising: establishing an operator graph for a plurality of processing elements that each include a respective one or more operators configured to perform a respective one or more operations on tuples of streaming data, wherein the operator graph defines at least one execution path through the operators of the plurality of processing elements, and wherein a first processing element in the operator graph includes a barrier operator that joins the output of a plurality of upstream operators included in one or more of the plurality of processing elements; and upon determining at least one of (i) one or more timeout conditions have been satisfied at the barrier operator and (ii) a punctuation signal has been received at the barrier operator, before data has been received from all of the plurality of upstream operators, generating, by operation of one or more computer processors, output data at the barrier operator without the data from at least one of the plurality of upstream operators, comprising: