主权项 |
1. A method comprising:
initializing, by a stream application and based on a processing element, a first resource allocation of a first virtual resource, the first virtual resource provided by a virtual machine to enable operation of the processing element, the processing element containing one or more stream operators that operate on one or more tuples of the stream application; monitoring, by the stream application, operation of the virtual machine to allocate one or more virtual resources including the first virtual resource; detecting, by the stream application and based on the monitored operation of the virtual machine, a second resource allocation; determining, by the stream application and based on the detected second resource allocation, an increase in the first virtual resource compared to the first resource allocation; identifying, by the stream application and based on the detected second resource allocation of the virtual machine, the processing element of the stream application; increasing, by the stream application and based on the determined increase in the virtual resource and based on the identified processing element, a first stream operator function of the processing element, the first stream operator function corresponding to the first virtual resource; determining, by the stream application, a resource dependency that the first stream operator function depends on a second stream operation function, the second stream operator function corresponding to a second virtual resource, wherein the resource dependency is a ratio between the first stream operator function and the second stream operator function and is based on tuple processing performance monitored by the stream application; and increasing, by the stream application and based on the determined resource dependency, the second stream operator function of the processing element. |