SYSTEMS AND/OR METHODS FOR INTERACTIVE EXPLORATION OF DEPENDENCIES IN STREAMING DATA
First Claim
Patent Images
1. An information processing system, comprising:
- an interface configured to receive at least one selected stream of events from an event bus that receives a plurality of streams of events from a plurality of different devices, each event in each stream in the plurality of streams having at least one attribute;
a model store, backed by a non-transitory computer readable storage medium; and
processing resources including at least one processor and a memory coupled thereto, the processing resources being configured to at least;
receive first user input identifying the at least one selected stream;
receive second user input identifying at least two attributes of interest, the attributes of interest being selected from the attributes of the events in the at least one selected stream;
execute a continuous query on the at least one selected stream to attempt to, directly or indirectly, mathematically compute a statistical model including the at least two identified attributes of interest, the statistical model having a type;
store a representation of the mathematically computed statistical model to the model store;
generate for output to the user a user-interactive display including a representation of the mathematically computed statistical model, the user-interactive display being dynamically changeable based upon at least (a) an update to the mathematically computed statistical model that results from the execution of the continuous query, and (b) receipt of third user input that identifies a sub-stream of the at least one selected stream;
determine whether the mathematically computed statistical model sufficiently fits for the at least two identified attributes of interest; and
in response to a determination that the mathematically computed statistical model does not fit for the at least two identified attributes of interest, change the type of the statistical model to a new type so that the new type of statistical model better fits for the at least two identified attributes of interest.
1 Assignment
0 Petitions
Accused Products
Abstract
Certain example embodiments allow for the continuous discovery and analysis of dependencies in a multidimensional event stream in which various regression models are continuously modified in real time and regression models are switched, if necessary or desirable. The event streams in certain example embodiments are continuously arriving Big Data streams of heterogeneous types, and the discovery and analysis is done dynamically in real time.
58 Citations
30 Claims
-
1. An information processing system, comprising:
-
an interface configured to receive at least one selected stream of events from an event bus that receives a plurality of streams of events from a plurality of different devices, each event in each stream in the plurality of streams having at least one attribute; a model store, backed by a non-transitory computer readable storage medium; and processing resources including at least one processor and a memory coupled thereto, the processing resources being configured to at least; receive first user input identifying the at least one selected stream; receive second user input identifying at least two attributes of interest, the attributes of interest being selected from the attributes of the events in the at least one selected stream; execute a continuous query on the at least one selected stream to attempt to, directly or indirectly, mathematically compute a statistical model including the at least two identified attributes of interest, the statistical model having a type; store a representation of the mathematically computed statistical model to the model store; generate for output to the user a user-interactive display including a representation of the mathematically computed statistical model, the user-interactive display being dynamically changeable based upon at least (a) an update to the mathematically computed statistical model that results from the execution of the continuous query, and (b) receipt of third user input that identifies a sub-stream of the at least one selected stream; determine whether the mathematically computed statistical model sufficiently fits for the at least two identified attributes of interest; and in response to a determination that the mathematically computed statistical model does not fit for the at least two identified attributes of interest, change the type of the statistical model to a new type so that the new type of statistical model better fits for the at least two identified attributes of interest. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14)
-
-
15. An non-transitory computer readable storage medium including instructions that, when executed by at least one hardware processor of a computer system, performs functionality comprising:
-
using processing resources including at least one processor and a memory, receiving, over an electronic interface to an event bus that receives a plurality of streams of events from a plurality of different devices, at least one selected stream of events, each event in each stream in the plurality of streams having at least one attribute; receiving first user input identifying the at least one selected stream; receiving second user input identifying at least two attributes of interest, the attributes of interest being selected from the attributes of the events in the at least one selected stream; executing a continuous query on the at least one selected stream to attempt to, directly or indirectly, mathematically compute a statistical model including the at least two identified attributes of interest, the statistical model having a type; storing a representation of the mathematically computed statistical model to a model store that is backed by a non-transitory computer readable storage medium; generating, for output to the user, a user-interactive display including a representation of the mathematically computed statistical model, the user-interactive display being dynamically changeable based upon at least (a) an update to the mathematically computed statistical model that results from the execution of the continuous query, and (b) receipt of third user input that identifies a sub-stream of the at least one selected stream; determining whether the mathematically computed statistical model sufficiently fits for the at least two identified attributes of interest; and in response to a determination that the mathematically computed statistical model does not fit for the at least two identified attributes of interest, changing the type of the statistical model to a new type so that the new type of statistical model better fits for the at least two identified attributes of interest. - View Dependent Claims (16, 17, 18, 19, 20, 21, 22, 23, 24)
-
-
25. An information processing method, comprising:
-
using processing resources including at least one processor and a memory, receiving, over an electronic interface to an event bus that receives a plurality of streams of events from a plurality of different devices, at least one selected stream of events, each event in each stream in the plurality of streams having at least one attribute; receiving first user input identifying the at least one selected stream; receiving second user input identifying at least two attributes of interest, the attributes of interest being selected from the attributes of the events in the at least one selected stream; executing a continuous query on the at least one selected stream to attempt to, directly or indirectly, mathematically compute a statistical model for the at least two identified attributes of interest, the statistical model having a type; storing a representation of the mathematically computed statistical model to a model store that is backed by a non-transitory computer readable storage medium; generating, for output to the user, a user-interactive display including a representation of the mathematically computed statistical model, the user-interactive display being dynamically changeable based upon at least (a) an update to the mathematically computed statistical model that results from the execution of the continuous query, and (b) receipt of third user input that identifies a sub-stream of the at least one selected stream; determining whether the mathematically computed statistical model sufficiently fits for the at least two identified attributes of interest; and in response to a determination that the mathematically computed statistical model does not fit for the at least two identified attributes of interest, automatically changing the type of the statistical model to a new type so that the new type of statistical model better fits for the at least two identified attributes of interest. - View Dependent Claims (26, 27, 28, 29, 30)
-
Specification