Enhanced barrier operator within a streaming environment
US8943120B2 · kind B2 · utility
Assignee
Inventors
Key dates
| Filing date | Dec 22, 2011 |
| Grant date | Jan 27, 2015 |
| Priority date | — |
| Expiry date | May 4, 2032 |
Classification
- Technology area (CPC H)Electricity
- CPC primaryH04N21/8193
- WIPO fieldAudio-visual technology
- WIPO sectorElectrical engineering
Abstract
Techniques are described for processing data. Embodiments receive streaming data to be processed by a plurality of processing elements. An operator graph of the plurality of processing elements is established. The operator graph defines at least one execution path and at least one of the processing elements of the operator graph is configured to receive data from at least one upstream processing element and transmit data to at least one downstream processing element. Additionally, a first processing element in the operator graph includes a barrier operator that joins the output of one or more upstream operators included on one or more of the plurality of processing elements. Embodiments initiate one or more timeout conditions at the barrier operator. Embodiments also determine, at the first processing element, that one or more timeout conditions have been satisfied before data has been received from each of the one or more upstream operators. Upon determining that the one or more timeout conditions have been satisfied, embodiments generate output data at the barrier operator without the data from at least one of the one or more upstream operators.
Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.