发明名称 |
Triggering window conditions using exception handling |
摘要 |
In a stream computing application, data may be transmitted between operators using tuples. However, the receiving operator may not evaluate these tuples as they arrive but instead wait to evaluate a group of tuples—i.e., a window. A window is typically triggered when a buffer associated with the receiving operator reaches a maximum window size or when a predetermined time period has expired. Additionally, a window may be triggered by a monitoring a tuple rate—i.e., the rate at which the operator receives the tuples. If the tuple rate exceeds or falls below a threshold, a window may be triggered. Further, the number of exceptions, or the rate at which an operator throws exceptions, may be monitored. If either of these parameters satisfies a threshold, a window may be triggered, thereby instructing an operator to evaluate the tuples contained within the window. |
申请公布号 |
US9430117(B2) |
申请公布日期 |
2016.08.30 |
申请号 |
US201213347974 |
申请日期 |
2012.01.11 |
申请人 |
INTERNATIONAL BUSINESS MACHINES CORPORATION |
发明人 |
Branson Michael J.;Santosuosso John M.;Schulz Brandon W. |
分类号 |
G06F15/16;G06F7/00;G09G5/00;G06F3/0481;G06F5/06;G06F15/163;G06F9/44;G06F17/30;H04N21/435 |
主分类号 |
G06F15/16 |
代理机构 |
Patterson + Sheridan, LLP |
代理人 |
Patterson + Sheridan, LLP |
主权项 |
1. A computer-implemented method for processing data, comprising:
receiving streaming data tuples to be processed by a plurality of operators, the operators processing at least a portion of the received data tuples by operation of one or more computer processors; establishing an operator graph of the 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 receive data tuples from at least one upstream operator and transmit data tuples to at least one downstream operator; determining a current number of exceptions occurring while the upstream operator performs an operation based on at least one of the streaming data tuples; and triggering a data window in at least one operator of the plurality of operators different from the upstream operator when the current number of exceptions satisfies a threshold, the data window comprising a plurality of data tuples, and wherein triggering the data window causes the at least one operator to evaluate the plurality of data tuples in the data window. |
地址 |
Armonk NY US |