Visually exploring and analyzing event streams
First Claim
1. A method, comprising:
- receiving, by one or more continuous query language (CQL) processors, source events;
storing, by the one or more CQL processors, the source events in a data store;
enriching, by the one or more CQL processors, the stored source events with contextual data contained in the data store;
receiving, from a service associated with the data store, Java application programming interfaces (APIs) particular to the data store for retrieving the enriched source events;
making, by the one or more CQL processors, API calls of the received Java APIs to the data store, the API calls configured to request an event stream that includes the enriched source events;
displaying, by the one or more CQL processors, a graph that includes a plurality of first points representing a plurality of first events from the event stream and a plurality of second points representing a plurality of second events from the event stream;
receiving, by the one or more CQL processors, a first event of the plurality of first events from the event stream;
in response to receiving the first event, plotting, in the graph, a first point corresponding to the first event with a first color that visually distinguishes the first point from at least a one other color associated with a remainder of the plurality of points;
receiving, by the one or more CQL processors, a second event of the plurality of second events from the event stream;
in response to receiving the second event;
determining a correlation coefficient between the first event and the second event;
determining a correlation color corresponding to the correlation coefficient; and
plotting, in the graph, a second point corresponding to the second event with the correlation color;
receiving, by the one or more CQL processors, a third event of the plurality of first events from the event stream; and
in response to receiving the third event;
plotting, in the graph, a third point corresponding to the third event with the first color; and
changing a color of the first point to match the at least one other color associated with the remainder of the plurality of points.
2 Assignments
0 Petitions
Accused Products
Abstract
Some event ordering requirements can be determined based on continuous event processing queries. Other event ordering requirements can be determined based on distribution flow types being used to distribute events from event streams to node executing the queries. Events from event streams can be ordered according to ordering semantics that are based on a combination of all of these event ordering requirements. Additionally, virtual computing nodes can be associated with constraints, and computing processors can be associated with capabilities. Virtual computing nodes for processing event streams can be assigned to execute on various computing processors based on both these constraints and capabilities. Additionally, for each of several events in an event stream, a ratio between a total latency and a communication latency can be for determined. Based on an average of these ratios, a quantity of reducing nodes that will be involved in a map-reduce operation can be selected.
562 Citations
20 Claims
-
1. A method, comprising:
-
receiving, by one or more continuous query language (CQL) processors, source events; storing, by the one or more CQL processors, the source events in a data store; enriching, by the one or more CQL processors, the stored source events with contextual data contained in the data store; receiving, from a service associated with the data store, Java application programming interfaces (APIs) particular to the data store for retrieving the enriched source events; making, by the one or more CQL processors, API calls of the received Java APIs to the data store, the API calls configured to request an event stream that includes the enriched source events; displaying, by the one or more CQL processors, a graph that includes a plurality of first points representing a plurality of first events from the event stream and a plurality of second points representing a plurality of second events from the event stream; receiving, by the one or more CQL processors, a first event of the plurality of first events from the event stream; in response to receiving the first event, plotting, in the graph, a first point corresponding to the first event with a first color that visually distinguishes the first point from at least a one other color associated with a remainder of the plurality of points; receiving, by the one or more CQL processors, a second event of the plurality of second events from the event stream; in response to receiving the second event; determining a correlation coefficient between the first event and the second event; determining a correlation color corresponding to the correlation coefficient; and plotting, in the graph, a second point corresponding to the second event with the correlation color; receiving, by the one or more CQL processors, a third event of the plurality of first events from the event stream; and in response to receiving the third event; plotting, in the graph, a third point corresponding to the third event with the first color; and changing a color of the first point to match the at least one other color associated with the remainder of the plurality of points. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. A non-transitory computer-readable medium storing computer-executable instructions that, when executed by one or more processors, configures one or more computer systems to perform at least:
-
instructions that cause the one or more continuous query language (CQL) processors to receive source events; instructions that cause the one or more CQL processors to store the source events in a data store, instructions that cause the one or more CQL processors to enrich the stored source events with contextual data contained in the data store; instructions that cause the one or more CQL processors to receive, from a service associated with the data store, Java application programming interfaces (APIs) particular to the data store for retrieving the enriched source events; instructions that cause the one or more CQL processors to make (API) calls of the received Java APIs to the data store, the API calls configured to request an event stream that includes the enriched source events; instructions that cause the one or more CQL processors to display a graph that includes a plurality of first points representing a plurality of first events from the event stream and a plurality of second points representing a plurality of second events from the event stream; instructions that cause the one or more CQL processors to receive a first event of the plurality of first events from the event stream; instructions that cause the one or more CQL processors to plot, in the graph, a first point corresponding to the first event with a first color that visually distinguishes the first point from at least a one other color associated with a remainder of the plurality of points in response to receiving the first event; instructions that cause the one or more CQL processors to receive a second event of the plurality of second events from the event stream; instructions that cause the one or more CQL processors to, in response to receiving the second event; determine a correlation coefficient between the first event and the second event; determine a correlation color corresponding to the correlation coefficient; and plot, in the graph, a second point corresponding to the second event with the correlation color; instructions that cause the one or more CQL processors to receive a third event of the plurality of first events from the event stream; and instructions that cause the one or more CQL processors to plot, in the graph, a third point corresponding to the third event with the first color and change a color of the first point to match the at least one other color associated with the remainder of the plurality of points in response to receiving the second event. - View Dependent Claims (13, 14, 15, 16)
-
-
17. A system, comprising:
-
a memory storing a plurality of instructions; and a continuous query language (CQL) processor configured to access the memory, the CQL processor further configured to execute the plurality of instructions to at least; receive source events; store the source events in a data store; enrich the stored source events with contextual data contained in the data store; receive, from a service associated with the data store, Java application programming interfaces (APIs) particular to the data store for retrieving the enriched source events; make (API) calls of the received Java APIs to the data store, the API calls configured to request an event stream that includes the enriched source events; display a graph that includes a plurality of first points representing a plurality of first events from the event stream and a plurality of second points representing a plurality of second events from the event stream; receive a first event of the plurality of first events from the event stream; in response to receiving the first event, plot, in the graph, a first point corresponding to the first event with a first color that visually distinguishes the first point from at least a one other color associated with a remainder of the plurality of points; receive a second event of the plurality of second events from the event stream; in response to receiving the second event; determine a correlation coefficient between the first event and the second event; determine a correlation color corresponding to the correlation coefficient; and plot, in the graph, a second point corresponding to the second event with the correlation color; receive a third event of the plurality of first events from the event stream; and in response to receiving the third event; plot, in the graph, a third point corresponding to the third event with the first color; and change a color of the first point to match the at least one other color associated with the remainder of the plurality of points. - View Dependent Claims (18, 19, 20)
-
Specification