Fusion recommendation for performance management in streams

摘要

Fusion hints can be generated in order to recommend streams application actors (like streams operators) for fusion or separation in a streams computing environment. Profiles can be made for the streams application actors, and fusion candidates can be determined from the profiles, based on fusion candidate rules. Based on the fusion candidate rule satisfied, a particular associated fusion recommendation can be identified and made to the user via a user interface. The recommendation can be displayed, along with the identities of the streams application actors identified as fusion candidates.

主权项

1. A system for recommending streams application actors for fusion, wherein the streams application actors are dispersed on an operator graph within a streaming environment, the system comprising:
one or more processing circuits configured to: generate, for each of two or more streams application actors in the operator graph, a streams application actor profile; determine, from the streams application actor profiles for two or more streams application actors, the two or more streams application actors are fusion candidates, wherein the determining is based on streams application actor profile data, including historical runtime data and real-time processing data, and based on the streams application actors satisfying at least one fusion candidate rule from a set of fusion candidate rules, each fusion candidate rule associated with one or more fusion recommendations, wherein the fusion recommendation includes reconfiguration data for a particular portion of the operator graph; identify, in response to the determining, a fusion recommendation from the one or more fusion recommendations associated with the at least one fusion candidate rule; display, in response to the identifying, an identity of each of the two or more streams application actors, the fusion recommendation, and the reconfiguration data for a particular portion of the operator graph, wherein the displayed fusion recommendation shows a table indicating the current performance of the two or more streams application actors and one or more predicted performance of future processing cycles of the two or more streams application actors each performance associated with the implementation of the fusion recommendation; and accept the fusion recommendation, and automatically apply, by a compiler, the accepted fusion recommendation to the two or more streams application actors and reconfiguring the particular portion of the operator graph.