State sharing in a distributed data stream processing system
AssigneeInternational Business Machines Corporation
InventorsHenrique Andrade, Bugra Gedik, Martin J. Hirzel, Vibhore Kumar, Giuliano Losa, Robert J. Soule, Kun-Lung Wu
Life of this patent
Estimating the term…
Abstract
State sharing is facilitated in stream processing environments, including distributed stream processing environments. A customized shared state implementation representing the state to be shared is automatically created based on at least one of user preferences, hints of usage, and system performance.
Claims19
A method of sharing state in a stream processing environment, the state represented as a shared data structure, and said method comprising:
- obtaining, by a processor of the stream processing environment, at least one of usage information for the shared data structure, one or more pre-declared characteristics of the shared data structure, and performance information relating to the stream processing environment;
- and
- generating, by the processor based on at least one of the usage information, pre-declared characteristics or performance information, customized code for managing the shared data structure, wherein the shared data structure is shared by at least one of a plurality of operators of one or more stream processing applications executing in the stream processing environment, a plurality of external applications, or one or more operators and one or more external applications.
A system of sharing state in a stream processing environment, said system comprising:
- a processor to obtain at least one of usage information for the shared data structure, one or more pre-declared characteristics of the shared data structure, and performance information relating to the stream processing environment;
- and
- the processor to generate, based on at least one of the usage information, pre-declared characteristics or performance information, customized code for managing the shared data structure, wherein the shared data structure is shared by at least one or a plurality or operators or one or more stream processing applications executing in the stream processing environment, a plurality of external applications, or one or more operators and one or more external applications.
A computer program product for sharing state in a stream processing environment, said computer program comprising:
- a computer readable storage medium readable by a processor and storing instructions for execution by the processor for performing a method comprising:
- obtaining at least one of usage information for the shared data structure, one or more pre-declared characteristics of the shared data structure, and performance information relating to the stream processing environment;
- and
- generating, based on at least one of the usage information, pre-declared characteristics or performance information, customized code for managing the shared data structure, wherein the shared data structure is shared by at least one of a plurality of operators of one or more stream processing applications executing in the stream processing environment, a plurality of external applications, or one or more operators and one or more external applications.
Dependencies are inferred from the claim text.