发明名称 |
Predicted outputs in a streaming environment |
摘要 |
According to embodiments of the disclosure, methods, systems, and computer program products for initializing a streaming application are disclosed. The method may include compiling code on a compiler system, the compiling of the code including establishing an operator graph having a plurality of processing elements including a first processing element and a second processing element. The compiling of code including receiving a first compiler directive specifying an operator sub-graph included in the operator graph, the operator sub-graph containing one or more processing elements from the plurality of processing elements. The compiling of code including receiving a second compiler directive identifying the first processing element, the first processing element configured to bypass the operator sub-graph by transmitting a predicted output tuple to the second processing element in response to determining that a processing condition exists in the operator graph. |
申请公布号 |
US9189212(B2) |
申请公布日期 |
2015.11.17 |
申请号 |
US201414230376 |
申请日期 |
2014.03.31 |
申请人 |
International Business Machines Corporation |
发明人 |
Branson Michael J.;Santosuosso John M. |
分类号 |
G06F9/45;G06F17/30 |
主分类号 |
G06F9/45 |
代理机构 |
|
代理人 |
Nock James R.;Bowman Nicholas D. |
主权项 |
1. A method for initializing a streaming application, the method including compiling code on a compiler system, the compiling of the code comprising:
establishing an operator graph having a plurality of processing elements including a first processing element and a second processing element; receiving a first compiler directive specifying an operator sub-graph included in the operator graph, the operator sub-graph containing one or more processing elements from the plurality of processing elements, the operator sub-graph configured to receive an input tuple and configured to transmit an output tuple to the second processing element of the operator graph; and receiving a second compiler directive identifying the first processing element, the first processing element configured to bypass the operator sub-graph by transmitting a predicted output tuple to the second processing element in response to determining that a processing condition exists in the operator graph. |
地址 |
Armonk NY US |