Processing element placement tool

摘要

A method, system, and computer program product for selectively associating one or more processing elements, or portions thereof, to one or more compute nodes. The method, system, and computer program product can include presenting a stream computing application, presenting metrics associated with at least one compute node and at least one processing element (or portion thereof), receiving input from a graphical display, associating one or more processing elements (or portions thereof) to one or more compute nodes, and updating the graphical display and the metrics to reflect the selective associations.

主权项

1. A computer program product comprising a non-transitory computer readable storage medium having program instructions embodied therewith, the program instructions executable by a processor to cause the processor to perform a method comprising:
generating a graphical user interface display presenting the stream computing application and the computing infrastructure, wherein the stream computing application comprises one or more processing elements, wherein each processing element comprises one or more stream operators, wherein the computing infrastructure comprises one or more compute nodes, wherein the graphical user interface is deployed from an integrated development environment (IDE); displaying a respective metric for each presented stream operator; displaying a respective metric for each presented processing element; displaying a respective metric for each presented compute node; allocating at least a portion of a processing element to at least one compute node, each allocation using input received from the graphical user interface; updating, in response to each respective allocation, the graphical user interface display to execute the at least a portion of a processing element on the at least one compute node; updating, in response to each respective allocation, each respective metric for each presented stream operator, each respective metric for each presented processing element, and each respective metric for each presented compute node; identifying unallocated processing elements or portions thereof; allocating the identified unallocated processing elements or portions thereof to one or more compute nodes according to a predefined protocol; encoding each respective allocation onto at least one computer readable storage medium,wherein encoding each respective allocation comprises at least one subconfiguration statement,wherein the at least one subconfiguration statement comprises a relative partition constraint,wherein the relative partition constraint defines if a set of processing elements executes on a same partition, executes on different partitions, or executes on a partition in isolation;
metering the use of the graphical user interface display; and generating an invoice based on the metered use.