REROUTING DATA OF A STREAMING APPLICATION

摘要

A streams manager monitors performance of a streaming application and determines if operators are underperforming according to a threshold. When the performance needs to be improved, the streams manager automatically modifies the flow graph to offload or reroute a stream of data, or part of a stream of data, to a similar operator to more efficiently utilize streaming resources. Operators are provided with multiple ports to allow the streams manager to send additional streams to the operator.

主权项

1. An apparatus comprising:
at least one processor; a memory coupled to the at least one processor; a streaming application residing in the memory and executed by the at least one processor, the streaming application comprising a flow graph that includes a plurality of operators that process a plurality of data tuples; and a streams manager residing in the memory and executed by the at least one processor, wherein the streams manager monitors performance of the plurality of operators of the streaming application, and when the streams manager determines a first operator of the flow graph is underperforming, the streams manager identifies a second operator compatible with the first operator and reroutes data flowing to the first operator to flow to the second operator.