Multi-granular stream processing
First Claim
Patent Images
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; and
processing 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; and
performing 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.
1 Assignment
0 Petitions
Accused Products
Abstract
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.
-
Citations
20 Claims
-
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; and processing 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; and performing 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. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 15, 16, 17, 18, 19, 20)
-
10. A computer system for facilitating stream processing in a computing environment, the computer system comprising:
-
a memory; and a processor in communications with the memory, wherein the computer system is capable of performing a method, said 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; and processing 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; and performing at least one of; forwarding one or more results of the at least one result to the second component for user 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. - View Dependent Claims (11, 12)
-
-
13. A method of facilitating stream processing in a computing environment, said 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; and processing 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 or more operations; and performing 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. - View Dependent Claims (14)
-
Specification