DYNAMICALLY CONFIGUREABLE PLACEMENT ENGINE
1 Assignment
0 Petitions
Accused Products
Abstract
A stream application may allocate processing elements to one or more compute nodes (or hosts) to achieve a desired optimization goal. Each optimization mode may define processing element selection criteria and/or host selection criteria. When allocating a processing element to a host, a scheduler may place each processing element individually. Accordingly, the scheduler may use the processing element selection criteria for selecting which processing element in the stream application to allocate next. The scheduler may then determine, based on one or more constraints, which host the processing element can be placed on. If the scheduler determines that multiple hosts are suitable candidates for the processing element, it may use the host selection criteria to pick one of the candidate hosts that further optimize the stream application to meet the desired goal.
66 Citations
20 Claims
-
1-7. -7. (canceled)
-
8. A computer program product for establishing a stream application, the computer program product comprising:
a computer-readable storage medium having computer-readable program code embodied therewith, the computer-readable program code configured to; select a processing element from a plurality of processing elements in the stream application based on at least one processing element selection criteria; determine, based on one or more constraints, a plurality of candidate compute nodes to which the processing element can be allocated from among a plurality of compute nodes; select, based on at least one compute node selection criteria, a compute node from the candidate compute nodes, wherein at least one of the processing element selection criteria and the compute node selection criteria is determined by a current optimization mode for the stream application; and allocate the processing element to the selected compute node. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
15. A system, comprising:
-
a computer processor; and a memory containing a program that, when executed on the computer processor, performs an operation for establishing a stream application, comprising; selecting a processing element from a plurality of processing elements in the stream application based on at least one processing element selection criteria; determining, based on one or more constraints, a plurality of candidate compute nodes to which the processing element can be allocated from among a plurality of compute nodes; selecting, based on at least one compute node selection criteria, a compute node from the candidate compute nodes, wherein at least one of the processing element selection criteria and the compute node selection criteria is determined by a current optimization mode for the stream application; and allocating the processing element to the selected compute node. - View Dependent Claims (16, 17, 18, 19, 20)
-
Specification