System and method for using stream objects to perform stream processing in a text-based computing environment
First Claim
Patent Images
1. A computer-implemented method of processing data, said method comprising:
- providing an a stream processing object class definition of a stream processing object class for facilitating at least one operation on a data stream, the object class definition specifying operations defining at least a portion of an Application Programming Interface (API), the object class definition including at least an update operation for updating a retained internal state of an object instance of the stream processing object class without producing an output, a stream processing operation, and an output operation for producing at least one output value for an object instance of the stream processing object class, the update operation and output operation being separately invocable;
instantiating an object of the stream processing object class in a textual dynamically-typed language environment to produce an object instance; and
using the object instance to operate on the data stream via the API; and
generating code for the object instance based on a set of parameters.
1 Assignment
0 Petitions
Accused Products
Abstract
A mechanism for using stream objects in stream processing operations is provided. A definition of a class of stream objects used in stream processing algorithms can define output and update operations included in instances of the stream objects and the API (application programming interface) through which they may be called. The class definition may further include the type of state information to be held by the instantiated stream objects. An instance of the stream object may be instantiated in a text-based computing environment and the operations may be used to process streams of data.
-
Citations
41 Claims
-
1. A computer-implemented method of processing data, said method comprising:
-
providing an a stream processing object class definition of a stream processing object class for facilitating at least one operation on a data stream, the object class definition specifying operations defining at least a portion of an Application Programming Interface (API), the object class definition including at least an update operation for updating a retained internal state of an object instance of the stream processing object class without producing an output, a stream processing operation, and an output operation for producing at least one output value for an object instance of the stream processing object class, the update operation and output operation being separately invocable; instantiating an object of the stream processing object class in a textual dynamically-typed language environment to produce an object instance; and using the object instance to operate on the data stream via the API; and generating code for the object instance based on a set of parameters. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21)
-
-
22. A computer-implemented method of processing data, said method comprising:
-
providing an a stream processing object class definition of a stream processing object class for facilitating at least one operation on a data stream, the object class definition specifying operations defining at least a portion of an Application Programming Interface (API), the object class definition including at least an update operation for updating a retained internal state of an object instance of the stream processing object class without producing an output, a stream processing operation and an output operation for producing least one output value for an object instance of the stream processing object class, the update operation and output operation being separately invocable; instantiating an object of the stream processing object class in a textual dynamically-typed language environment to produce an object instance; using the object instance to operate on the data stream via the API; and generating code for the object instance based on a set of parameters. - View Dependent Claims (23)
-
-
24. A non-transitory computer-readable medium holding instructions that when executed by a processor process data, by:
-
providing an object class definition of a stream processing object class for facilitating at least one operation on a data stream, the object class definition specifying operations defining at least a portion of an Application programming Interface (API), the object class definition including at least an update operation for updating a retained internal state of an object instance of the stream processing object class without producing an output, a stream processing operation and an output operation for producing at least one output value for an object instance of the stream processing object class, the update operation and the output operation being separately invocable; instantiating an object of the stream processing object class in textual dynamically-typed language environment to produce an object instance; and using the object instance to operate on the data stream via the API; and generating code for the object instance based on a set of parameters. - View Dependent Claims (25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39)
-
-
40. A non-transitory computer-readable medium holding instructions that when executed on a processor process data by:
-
providing an object class definition of a stream processing object class for facilitating at least one operation on a data stream, the object class definition specifying operations defining at least a portion of an Application Programming Interface (API), the object class definition including at least an update operation for updating a retained internal state of an object instance of the stream processing object class without producing an output, a stream processing operation and an output operation for providing at least one output value for an object instance of the stream processing object class, the update operation and the output operation being separately invocable; instantiating an object of the stream processing object class in a textual dynamically typed language environment to produce an object instance; using the object instance to operate on the data stream via the API; and generating code for the object instance based on a set of parameters. - View Dependent Claims (41)
-
Specification