Systems and methods for optimal component composition in a stream processing system
AssigneeInternational Business Machines Corporation
InventorsXiaohui Gu, Philip S. Yu
Life of this patent
Estimating the term…
Abstract
A system and method are provided for optimizing component composition in a distributed stream-processing environment having a plurality of nodes capable of being associated with one or more of a plurality of stream processing components. The system includes an adaptive composition probing (ACP) module and a hierarchical state manager. The ACP module probes a subset of the plurality of stream processing components to determine the optimal component composition in response to a stream processing request. The hierarchical state manager manages local and global information for use by said ACP module in determining the optimal component composition.
Claims24
A system having a processor and a memory for optimizing component composition in a distributed stream-processing environment having a plurality of nodes capable of being associated with one or more of a plurality of stream processing components, the system further comprising:
- an adaptive composition probing (ACP) module which probes a subset of the plurality of stream processing components to determine the optimal component composition in response to a stream processing request;
- and a hierarchical state manager which manages local and global information for use by said ACP module in determining the optimal component composition.
A method for optimizing component composition in a distributed stream-processing environment having a plurality of nodes capable of being associated with one or more of a plurality of stream processing components, the method comprising the steps of:
- performing an adaptive composition probing (ACP) which probes a subset of the plurality of stream processing components to determine the optimal component composition in response to a stream processing request;
- and
- managing local and global information for use by said performing step in determining the optimal component composition.
A program storage device readable by machine, tangibly embodying a program of instructions executable by the machine to perform method steps for optimizing component composition in a distributed stream-processing environment having a plurality of nodes capable of being associated with one or more of a plurality of stream processing components, the method steps comprising:
- performing an adaptive composition probing (ACP) which probes a subset of the plurality of stream processing components to determine the optimal component composition in response to a stream processing request;
- and
- managing local and global information for use by said performing step in determining the optimal component composition.
Dependencies are inferred from the claim text.