VISUALLY EXPLORING AND ANALYZING EVENT STREAMS

• US 20170024912A1
• Filed: 09/25/2015
• Published: 01/26/2017
• Est. Priority Date: 07/24/2015
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Markovski, Dmitry, Shikalov, Ilya, Bychkov, Vitaly, Nikiforova, Natalia, de Castro Alves, Alexandre, Thukkaram, Prabhu
• Granted Patent: US 9,972,103 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/26 Visual data mining; Browsing structured data
• CPC Class Codes: G06F 16/9024 Graphs; Linked lists G06F16/9027 takes precedence
• CPC Class Codes: G06T 11/206 Drawing of charts or graphs

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.

Claims

1. A method, comprising:

displaying a graph that includes a plurality of points representing a plurality of events from an event stream;

receiving a first event of the plurality of events from the event stream;

in response to receiving the first event, plotting, in the graph, a first point 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 a second event of the plurality of events from the event stream; and

in response to receiving the second event;

plotting, in the graph, a second point 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. The method of claim 1, wherein the graph comprises a scatter plot.

3. The method of claim 1, wherein the X-axis or the Y-axis of the graph are based at least in part on a property of the plurality of events from the event stream.

4. The method of claim 3, further comprising receiving identification of the property from a user associated with the event stream.

5. The method of claim 3, further comprising selecting the property based at least in part on an order of output of the event stream.

6. The method of claim 5, wherein the property comprises a numeric value.

7. The method of claim 3, wherein the Y-axis represents a response variable.

8. The method of claim 1, wherein a size of each of the plurality of points is based at least in part on a respective property of each of the plurality of events from the event stream.

9. The method of claim 1, further comprising removing a number of the plurality of points from the graph, the number based at least in part on a visual characteristic of the graph.

10. The method of claim 1, wherein the graph comprises a scatter plot in which one axis represents a time of a particular event and another axis represents a value of the particular event, wherein the plurality of events of the event stream are received over a time interval, and the method further comprises:

plotting a point that corresponds to the particular event;

determining a revised smoothed curve fitter based at least in part on points contained in the scatter plot; and

re-drawing the revised smoothed curve fitter in the scatter plot.

11. The method of claim 1, wherein the graph comprises a scatter plot in which one axis represents a time of a particular event and another axis represents a value of the particular event, wherein the plurality of events of the event stream are received over a time interval, and the method further comprises:

plotting a point that corresponds to the particular event;

determining one or more clusters of points contained in the scatter plot; and

re-drawing, on the scatter plot, one or more shapes that represent the one or more clusters and include points belonging to those clusters.

12. A 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 processors to display a graph that includes a plurality of points representing a plurality of events from an event stream;

instructions that cause the one or more processors to receive a first event of the plurality of events from the event stream;

instructions that cause the one or more processors to plot, in the graph, a first point 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 processors to receive a second event of the plurality of events from the event stream; and

instructions that cause the one or more processors to plot, in the graph, a second point 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.

13. The computer-readable medium of claim 12, wherein the one or more computer systems are further configured to perform instructions that cause the one or more processors to receive identification, from a user, of a property of the plurality of events from the event stream.

14. The computer-readable medium of claim 13, wherein the property is utilized to represent values of the X-axis or the Y-axis of the graph.

15. The computer-readable medium of claim 13, wherein the property comprises a non-numeric value.

16. The computer-readable medium of claim 12, wherein a size of each of the plurality of points is based at least in part on a respective property of each of the plurality of events from the event stream.

17. A system, comprising:

a memory storing a plurality of instructions; and

a processor configured to access the memory, the processor further configured to execute the plurality of instructions to at least;

display a graph that includes a plurality of points representing a plurality of events from an event stream;

receive a first event of the plurality of events from the event stream;

in response to receiving the first event, plot, in the graph, a first point 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 events from the event stream; and

in response to receiving the second event;

plot, in the graph, a second point 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.

18. The system of claim 17, wherein the processor is further configured to execute the plurality of instructions to at least remove a number of the plurality of points from the graph, the number based at least in part on a visual characteristic of the graph.

19. The system of claim 17, wherein the graph comprises a scatter plot in which one axis represents a time of a particular event and another axis represents a value of the particular event, wherein the plurality of events of the event stream are received over a time interval, and wherein the processor is further configured to execute the plurality of instructions to at least:

plot a point that corresponds to the particular event;

determine a revised smoothed curve fitter based at least in part on points contained in the scatter plot; and

re-draw the revised smoothed curve fitter in the scatter plot.

20. The system of claim 17, wherein the graph comprises a scatter plot in which one axis represents a time of a particular event and another axis represents a value of the particular event, wherein the plurality of events of the event stream are received over a time interval, and wherein the processor is further configured to execute the plurality of instructions to at least:

plot a point that corresponds to the particular event;

determine one or more clusters of points contained in the scatter plot; and

re-draw, on the scatter plot, one or more shapes that represent the one or more clusters and include points belonging to those clusters.