User interface for specifying data stream processing language programs for analyzing instrumented software
An instrumentation analysis system processes data streams by executing instructions specified using a data stream language program. A user interface allows users to specify data stream language programs. The user interface presents widgets to the user to specify various components of a data stream language program, including a filter expression, an analytical function representing an aggregation or transformation, and so on. The user interface allows users to specify an expression based on results of previously specified data stream language programs. The instrumentation analysis system processes the data stream language programs specified by the user to generate a set of result data streams and plots the result data streams, for example, on a screen of a client device.
1. A computer-implemented method for specifying data stream language programs through a user interface for analyzing instrumented software, the method comprising:
receiving, through the user interface, specifications of the data stream language program for generating one or more sets of graphs based on filtered data of a plurality of data streams, the filtered data generated based on received filter expressions;
receiving, through the user interface, one or more analytical functions for the one or more sets of graphs, each analytical function comprising at least one of a transformation or an aggregation;
generating the one or more sets of graphs based on the specifications of the data stream language program and the one or more analytical functions; and
associating each of the one or more sets of graphs with a label.
2. The computer-implemented method of claim 1 , further comprising:
generating the user interface for specifying the data stream language program, the user interface comprising one or more user interface elements for receiving the filter expressions.
3. The computer-implemented method of claim 1 , wherein the filter expressions comprise values of one or more names of metrics of data streams.
4. The computer-implemented method of claim 1 , wherein the filter expressions are received through widgets of the user interface.
5. The computer-implemented method of claim 1 , further comprising:
generating, through the one or more analytical functions, an aggregate value based on a plurality of data values, each data value obtained from a distinct input data stream for each of the data stream language programs.
6. The computer-implemented method of claim 1 , further comprising:
calculating, through the one or more analytical functions, a mean over a collection of data points by dividing a sum of the collection by a number of the data points in the collection.
7. The computer-implemented method of claim 1 , further comprising:
receiving, through the user interface, a time shift value for a data stream language program corresponding to a plot line of a graph, the time shift value specifying a length of a time interval.
8. The computer-implemented method of claim 1 , further comprising:
selecting a metric from a catalog of metrics for each of the data stream language programs.
9. The computer-implemented method of claim 1 , further comprising:
generating, through the data stream language program, data streams that identify a limiting resource.
10. The computer-implemented method of claim 9 , further comprising:
receiving, through the user interface, a detector to alert a user when an overall utilization of the limiting resource reaches a limit.
11. A system for specifying data stream language programs through a user interface for analyzing instrumented software, the system comprising:
at least one memory having instructions stored thereon; and
at least one processor configured to execute the instructions, wherein the at least one processor is configured to:
receive, through the user interface, specifications of the data stream language program for generating one or more sets of graphs based on filtered data of a plurality of data streams, the filtered data generated based on received filter expressions;
receive, through the user interface, one or more analytical functions for the one or more sets of graphs, each analytical function comprising at least one of a transformation or an aggregation;
generate the one or more sets of graphs based on the specifications of the data stream language program and the one or more analytical functions; and
associate each of the one or more sets of graphs with a label.
12. The system of claim 11 , further configured to:
generate the user interface for specifying the data stream language program, the user interface comprising one or more user interface elements for receiving the filter expressions.
13. The system of claim 11 , wherein the filter expressions comprise values of one or more names of metrics of data streams.
14. The system of claim 11 , wherein the filter expressions are received through widgets of the user interface.
15. The system of claim 11 , further configured to:
generate, through the one or more analytical functions, an aggregate value based on a plurality of data values, each data value obtained from a distinct input data stream for each of the data stream language programs.
16. The system of claim 11 , further configured to:
calculate, through the one or more analytical functions, a mean over a collection of data points by dividing a sum of the collection by a number of the data points in the collection.
17. The system of claim 11 , further configured to:
receive, through the user interface, a time shift value for a data stream language program corresponding to a plot line of a graph, the time shift value specifying a length of a time interval.
18. The system of claim 11 , further configured to:
select a metric from a catalog of metrics for each of the data stream language programs.
19. The system of claim 11 , further configured to:
generate, through the data stream language program, data streams that identify a limiting resource.
20. A non-transitory computer-readable storage medium comprising instructions stored thereon, which when executed by one or more processors, cause the one or more processors to perform operations for specifying data stream language programs through a user interface for analyzing instrumented software, comprising:
receiving, through the user interface, specifications of the data stream language program for generating one or more sets of graphs based on filtered data of a plurality of data streams, the filtered data generated based on received filter expressions;
receiving, through the user interface, one or more analytical functions for the one or more sets of graphs, each analytical function comprising at least one of a transformation or an aggregation;
generating the one or more sets of graphs based on the specifications of the data stream language program and the one or more analytical functions; and
associating each of the one or more sets of graphs with a label.