Stream computing event models

1. A stream-processing system comprising:

one or more computers and one or more storage devices storing instructions that are operable, when executed by the one or more computers, to cause the one or more computers to perform operations comprising:

receiving, by the stream-processing system, a plurality of events representing respective units of activity in a telecommunications network;

classifying, by the stream-processing system, each event of the plurality of events into a respective class of a plurality of classes according to a hierarchical analytic model for events in the telecommunications network, including processing each event according to a respective sequence of sets of attribute-specific criteria defined by the hierarchical analytic model for each class of the plurality of classes, wherein the hierarchical analytic model defines a predetermined order in which the sets of attribute-specific criteria are to be applied by the stream-processing system to each event;

determining, from events classified according to the hierarchical analytic model, that an error condition exists in the telecommunications network;

in response to determining that an error condition exists in the telecommunications network, issuing a corrective action to a plurality of users in the telecommunications network;

computing a measure of an effect of the corrective action issued to the plurality of users;

determining that the measure of the effect of the correction action satisfies a threshold; and

in response, determining that the corrective action was responsible for the removing the error condition in the telecommunications network.

2. The system of claim 1 , wherein one or more of the plurality of events represent a respective user sending a text message through the telecommunications network.

3. The system of claim 1 , wherein one or more of the plurality of events represent a respective user making a voice call through the telecommunications network.

4. The system of claim 1 , wherein the hierarchical analytic model defines, for a particular class of the plurality of classes, at least one set of attribute-specific criteria for data attributes at multiple different layers of a telecommunications protocol stack.

5. The system of claim 1 , wherein classifying each event of the plurality of events into a respective class of a plurality of classes according to a hierarchical analytic model comprises:

evaluating values of each of one or more data attributes of each event according to respective attribute-specific and class-specific criteria in the predetermined order;

determining that a first value of a first data attribute satisfies one or more particular criteria for a first class; and

assigning the first class of the plurality of classes to the event.

6. The system of claim 5 , wherein evaluating the values of each of the one or more data attributes according to the respective attribute-specific and class-specific criteria in the predetermined order comprises stopping the evaluation when a first value of a first data attribute of the plurality of data attributes satisfies one or more particular criteria for the first data attribute and the first class.

7. The system of claim 1 , wherein computing a measure of an effect of the corrective action issued to the plurality of users comprises computing a distance between a pair of distributions that represent failures before and after the corrective action respectively.

8. A method performed by one or more computers, the method comprising:

receiving, by the stream-processing system, a plurality of events representing respective units of activity in a telecommunications network;

classifying, by the stream-processing system, each event of the plurality of events into a respective class of a plurality of classes according to a hierarchical analytic model for events in the telecommunications network, including processing each event according to a respective sequence of sets of attribute-specific criteria defined by the hierarchical analytic model for each class of the plurality of classes, wherein the hierarchical analytic model defines a predetermined order in which the sets of attribute-specific criteria are to be applied by the stream-processing system to each event;

determining, from events classified according to the hierarchical analytic model, that an error condition exists in the telecommunications network;

in response to determining that an error condition exists in the telecommunications network, issuing a corrective action to a plurality of users in the telecommunications network;

computing a measure of an effect of the corrective action issued to the plurality of users;

determining that the measure of the effect of the correction action satisfies a threshold; and

in response, determining that the corrective action was responsible for the removing the error condition in the telecommunications network.

9. The method of claim 8 , wherein one or more of the plurality of events represent a respective user sending a text message through the telecommunications network.

10. The method of claim 8 , wherein one or more of the plurality of events represent a respective user making a voice call through the telecommunications network.

11. The method of claim 8 , wherein the hierarchical analytic model defines, for a particular class of the plurality of classes, at least one set of attribute-specific criteria for data attributes at multiple different layers of a telecommunications protocol stack.

12. The method of claim 8 , wherein classifying each event of the plurality of events into a respective class of a plurality of classes according to a hierarchical analytic model comprises:

evaluating values of each of one or more data attributes of each event according to respective attribute-specific and class-specific criteria in the predetermined order;

determining that a first value of a first data attribute satisfies one or more particular criteria for a first class; and

assigning the first class of the plurality of classes to the event.

13. The method of claim 12 , wherein evaluating the values of each of the one or more data attributes according to the respective attribute-specific and class-specific criteria in the predetermined order comprises stopping the evaluation when a first value of a first data attribute of the plurality of data attributes satisfies one or more particular criteria for the first data attribute and the first class.

14. The method of claim 8 , wherein computing a measure of an effect of the corrective action issued to the plurality of users comprises computing a distance between a pair of distributions that represent failures before and after the corrective action respectively.

15. One or more non-transitory computer storage media encoded with computer program instructions that when executed by one or more computers cause the one or more computers to perform operations comprising:

receiving, by the stream-processing system, a plurality of events representing respective units of activity in a telecommunications network;

classifying, by the stream-processing system, each event of the plurality of events into a respective class of a plurality of classes according to a hierarchical analytic model for events in the telecommunications network, including processing each event according to a respective sequence of sets of attribute-specific criteria defined by the hierarchical analytic model for each class of the plurality of classes, wherein the hierarchical analytic model defines a predetermined order in which the sets of attribute-specific criteria are to be applied by the stream-processing system to each event;

determining, from events classified according to the hierarchical analytic model, that an error condition exists in the telecommunications network;

in response to determining that an error condition exists in the telecommunications network, issuing a corrective action to a plurality of users in the telecommunications network;

computing a measure of an effect of the corrective action issued to the plurality of users;

determining that the measure of the effect of the correction action satisfies a threshold; and

in response, determining that the corrective action was responsible for the removing the error condition in the telecommunications network.

16. The one or more computer storage media of claim 15 , wherein one or more of the plurality of events represent a respective user sending a text message through the telecommunications network.

17. The one or more computer storage media of claim 15 , wherein one or more of the plurality of events represent a respective user making a voice call through the telecommunications network.

18. The one or more computer storage media of claim 15 , wherein the hierarchical analytic model defines, for a particular class of the plurality of classes, at least one set of attribute-specific criteria for data attributes at multiple different layers of a telecommunications protocol stack.

19. The one or more computer storage media of claim 15 , wherein classifying each event of the plurality of events into a respective class of a plurality of classes according to a hierarchical analytic model comprises:

evaluating values of each of one or more data attributes of each event according to respective attribute-specific and class-specific criteria in the predetermined order;

determining that a first value of a first data attribute satisfies one or more particular criteria for a first class; and

assigning the first class of the plurality of classes to the event.

20. The one or more computer storage media of claim 19 , wherein evaluating the values of each of the one or more data attributes according to the respective attribute-specific and class-specific criteria in the predetermined order comprises stopping the evaluation when a first value of a first data attribute of the plurality of data attributes satisfies one or more particular criteria for the first data attribute and the first class.

21. The one or more computer storage media of claim 15 , wherein computing a measure of an effect of the corrective action issued to the plurality of users comprises computing a distance between a pair of distributions that represent failures before and after the corrective action respectively.