METHODS AND APPARATUS FOR PERFORMING REAL-TIME ANALYTICS BASED ON MULTIPLE TYPES OF STREAMED DATA
First Claim
Patent Images
1. A method comprising:
- receiving, at a first compute device, streaming data from a plurality of streaming data sources, at least a portion of the streaming data not being stored in persistent storage;
receiving, from a client device, a signal associated with a query against the plurality of streaming data sources, the query associated with a user interacting with a graphical user interface;
defining a rule based on the query;
applying the rule to the streaming data, a subset of streaming data from the plurality of streaming data sources matching the rule;
storing, in persistent storage, a plurality of alerts, the plurality of alerts associated with the subset of streaming data; and
sending a signal associated with the plurality of alerts to a second compute device.
7 Assignments
0 Petitions
Accused Products
Abstract
Streaming data from a plurality of streaming data sources can be received. The streaming data may not be stored in persistent storage. A query can be received from a client device. A rule can be defined based on the query. The rule can be applied to the streaming data. Alerts associated with a subset of the streaming data that matches the rule can be stored in persistent storage. A signal associated with the alerts can be sent to the client device such that the graphical user interface is updated based on the alerts.
-
Citations
18 Claims
-
1. A method comprising:
-
receiving, at a first compute device, streaming data from a plurality of streaming data sources, at least a portion of the streaming data not being stored in persistent storage; receiving, from a client device, a signal associated with a query against the plurality of streaming data sources, the query associated with a user interacting with a graphical user interface; defining a rule based on the query; applying the rule to the streaming data, a subset of streaming data from the plurality of streaming data sources matching the rule; storing, in persistent storage, a plurality of alerts, the plurality of alerts associated with the subset of streaming data; and sending a signal associated with the plurality of alerts to a second compute device. - View Dependent Claims (2, 3, 4, 5, 6)
-
-
7. A non-transitory processor readable medium storing code representing instructions to be executed by a processor, the code comprising code to cause the processor to:
-
receive, at a compute device, streaming data from a plurality of data sources, at least a portion of the streaming data not being stored in persistent storage; send a first signal to a client device such that the client device renders a graphical user interface presenting at least a portion of the streaming data; receive, from the client device, a request to define a rule in response to a user of the client device making a form-based selection via the graphical user interface; apply the rule to the streaming data, a datum from the streaming data matching the rule; store the datum in persistent storage; and send a second signal to the client device such that an alert is presented via the graphical user interface, the alert based on the datum. - View Dependent Claims (8, 9, 10, 11, 12, 13, 14, 15, 16, 17)
-
-
18. A non-transitory processor readable medium storing code representing instructions to be executed by a processor, the code comprising code to cause the processor to:
-
render a graphical user interface presenting a first datum, the first datum being from a streaming data source from a plurality of streaming data sources, at least a portion of the streaming data sources not being stored in persistent storage; receive a signal associated with a user input via a graphical user interface; send, to a server, a signal representing the user input such that the server defines a rule; and receive, from the server, a second datum from the streaming data source in response to sending the signal to the server.
-
Specification