发明名称 Multi-granular stream processing
摘要 Stream processing is facilitated by distributing responsibility for processing the stream to multiple components of a computing environment. A programmable unit receives one or more streams and determines the operations to be performed for the one or more streams and which components of the computing environment are to perform those operations. It forwards data relating to the one or more streams to one or more components of the computing environment for processing and/or information purposes.
申请公布号 US8892762(B2) 申请公布日期 2014.11.18
申请号 US200912637972 申请日期 2009.12.15
申请人 International Business Machines Corporation 发明人 Krishnamurthy Rajaram B.;Parris Carl J.;Boice Charles;Liu Lurng-Kuo
分类号 G06F15/16;G06F9/50;H04L29/06 主分类号 G06F15/16
代理机构 Heslin Rothenberg Farley & Mesiti P.C. 代理人 Chiu, Esq. Steven;Schiller, Esq. Blanche E.;Heslin Rothenberg Farley & Mesiti P.C.
主权项 1. A computer program product for facilitating stream processing in a computing environment, said computer program product comprising: a non-transitory computer readable storage medium readable by a processing circuit and storing instructions for execution by the processing circuit for performing a method comprising: obtaining, by a programmable unit, a description of one or more streams to be received by the programmable unit from at least one source of the one or more streams, the description indicating a plurality of operations to be performed on content of the one or more streams to be received by the programmable unit;receiving, by the programmable unit, from a first component of the computing environment, different from the at least one source of the one or more streams, data to program, based at least in part on the description of the one or more streams, the programmable unit to recognize one set of one or more operations, of the plurality of operations, determined by the first component to be performed by the programmable unit, and to recognize another set of one or more operations, of the plurality of operations, determined by the first component to be performed by a second component of the computing environment;receiving, by the programmable unit, the one or more streams from the at least one source; andprocessing by the programmable unit the one or more streams, wherein the processing includes: performing the one set of one or more operations for the one or more streams at the programmable unit to obtain at least one result of performing the one set of one or more operations; andperforming at least one of: forwarding one or more results of the at least one result to the second component for use in performing the another set of one or more operations by the second component; orforwarding one or more results of the at least one result to the first component.
地址 Armonk NY US