发明名称 |
MANAGING MULTIPLE WINDOWS ON AN OPERATOR GRAPH |
摘要 |
Embodiments of the disclosure provide a method, system, and computer program product for managing a windowing operation. The method for grouping processing of a stream of tuples with each tuple containing one or more attributes can include receiving the stream of tuples to be processed by a plurality of processing elements operating on one or more computer processors. The method can also include processing, with a first processing method, a group of tuples from the stream of tuples into a grouping window. The method can also include processing, with a second processing method, a subgroup of tuples from the group of tuples into a subgrouping window. The second processing method can include identifying a sub-membership condition. |
申请公布号 |
US2015088889(A1) |
申请公布日期 |
2015.03.26 |
申请号 |
US201314057163 |
申请日期 |
2013.10.18 |
申请人 |
International Business Machines Corporation |
发明人 |
Branson Michael J.;Cobb Bradford L.;Santosuosso John M. |
分类号 |
G06F17/30 |
主分类号 |
G06F17/30 |
代理机构 |
|
代理人 |
|
主权项 |
1. A computer program product for processing a stream of tuples, each tuple containing one or more attributes, the computer program product comprising a computer readable storage medium having program code embodied therewith, the program code comprising computer readable program code configured to:
process the attributes of the stream of tuples using stream operators operating on one or more computer processors and corresponding one or more processing elements; process, with a first processing method, a group of tuples from the stream of tuples into a grouping window, wherein the first processing method is configured to:
identify a membership condition,determine whether the membership condition is met by a tuple from the stream of tuples, andinclude the tuple in the grouping window in response to the membership condition being met; and process, with a second processing method, a subgroup of tuples from the group of tuples into a subgrouping window, wherein the second processing method is configured to:
identify a sub-membership condition.determine whether the sub-membership condition is met by a tuple from the group of tuples, andinclude the tuple in the subgrouping window in response to the sub-membership condition being met. |
地址 |
Armonk NY US |