Selecting an operator graph configuration for a stream-based computing application
View Patent ↗First and second simulated processing of a stream-based computing application using respective first and second simulation conditions may be performed. The first and second simulation conditions may specify first and second operator graph configurations. Each simulated processing may include inputting a stream of test tuples to the stream-based computing application, which may operate on one or more compute nodes. Each compute node may have one or more computer processors and a memory to store one or more processing elements. Each simulated processing may be monitored to determine one or more performance metrics. The first and second simulated processings may be sorted based on a first performance metric to identify a simulated processing having a first rank. An operator graph configuration associated with the simulated processing having the first rank may be selected if the first performance metric for the simulated processing having the first rank is within a processing constraint.
1. A method for selecting an operator graph configuration for a stream-based computing application, comprising:
performing a first simulated processing of the stream-based computing application using a first simulation condition, the first simulation condition specifying a first operator graph configuration;
performing a second simulated processing of the stream-based computing application using a second simulation condition, the second simulation condition specifying a second operator graph configuration, the second simulation condition being distinct from the first simulation condition;
each simulated processing including inputting a stream of test tuples to the stream-based computing application, the stream-based computing application operating on one or more compute nodes, each compute node having one or more computer processors and a memory to store one or more processing elements, each processing element having one or more stream operators;
monitoring each simulated processing to determine one or more performance metrics;
sorting the first and second simulated processings based on a first performance metric to identify a simulated processing having a first rank; and
selecting an operator graph configuration associated with the simulated processing having the first rank if the first performance metric for the simulated processing having the first rank is within a processing constraint.
2. The method of claim 1 , further comprising, if the first performance metric for the simulated processing having the first rank is outside of the processing constraint, performing a third simulated processing of the stream-based computing application using a third simulation condition, the third simulation condition specifying a third operator graph configuration and being distinct from the first and second simulation conditions.
3. The method of claim 1 , wherein the one or more performance metrics includes a processing time and the processing constraint is a processing time constraint.
4. The method of claim 1 , wherein the one or more performance metrics includes a path travel time and the processing constraint is a path travel time constraint.
5. The method of claim 1 , wherein the first simulation condition includes deactivating one of the compute nodes.
6. The method of claim 1 , wherein the first simulation condition includes deactivating one of the stream operators.
7. The method of claim 1 , wherein the first simulation condition includes configuring a stream operator to initiate an extra stream-based computing application communication.
8. The method of claim 1 , wherein the first simulation condition includes configuring tuple routing at a stream operator.
9. The method of claim 1 , wherein the first simulation condition includes configuring a number of tuples output by a stream operator in response to receiving an input tuple.
10. The method of claim 1 , wherein the first simulation condition includes configuring a size of a tuple output by a stream operator in response to receiving an input tuple.
11. The method of claim 1 , wherein the first simulation condition includes configuring a condition under which a stream operator sheds tuples.
12. The method of claim 1 , wherein the first simulation condition includes configuring a stream operator to group two or more tuples for transmission.