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.