Stream processing with runtime adaptation

摘要

Embodiments of the disclosure include a method for providing stream processing with runtime adaptation includes registering one or more events, wherein each of the events is associated with a stream processing application. The method also includes monitoring, by a processor, for an occurrence of the one or more events associated with the stream processing application, wherein each of the one or more events is associated with one or more runtime metrics. The method further includes receiving an event notification, wherein the event notification includes event identification and an event context and executing an adaptation of the stream processing application.

主权项

1. A method for providing stream processing with runtime adaptation comprising:
creating, by a processor, an orchestrator configured to communicate with a runtime infrastructure and a stream processing application, the orchestrator configured to: register one or more events, wherein each of the events is associated with the stream processing application; monitor for an occurrence of the one or more events associated with the stream processing application, wherein each of the one or more events is associated with one or more runtime metrics; receive an event notification, wherein the event notification includes event identification and an event context; and based on receiving the event notification, execute an adaptation of the stream processing application, where the orchestrator includes APIs to influence a physical deployment of the stream processing application by changing a placement of operators in hosts and partitioning of operators in processing elements.