Managing risk with continuous queries
First Claim
1. A system, comprising:
- a memory storing a plurality of instructions; and
one or more processors configured to access the memory, wherein the one or more processors are further configured to execute the plurality of instructions to at least;
identify a key performance indicator associated with business event data;
generate a first query for the key performance indicator;
generate a relation based at least in part on a stream of the business event data;
implement the first query against the relation to receive first data corresponding to the key performance indicator associated with the business event data;
store a first snapshot of the first data corresponding to the key performance indicator in a data table;
identify a risk indicator associated with the key performance indicator based at least in part on the key performance indicator;
implement a second query against the relation;
receive second data corresponding to the risk indicator based at least in part on the second query, the risk indicator identifying a change in the second data above a threshold amount corresponding to the first data, the second data corresponding to the risk indicator received by at least listening to event output of the second query;
store a second snapshot of the second data corresponding to the risk indicator in the data table;
associate the data table with a key performance indicator watchlist;
generate information for presenting a risk dashboard user interface comprising a first visualization associated with the first snapshot of the first data corresponding to the key performance indicator associated with the key performance indicator watchlist and a second visualization associate with the second snapshot of the second data corresponding to the risk indicator associated with the key performance indicator watchlist; and
present the first visualization and the second visualization in the risk dashboard user interface.
1 Assignment
0 Petitions
Accused Products
Abstract
Techniques for managing risks with continuous queries are provided. In some examples, a selection of a data object enabled to provide a real-time stream of business event data may be received. The selection may be received by a user associated with the business event data. Additionally, a continuous query language query may be generated. The query may be configured to monitor the real-time stream of business event data for a first metric. In some examples, the a risk indicator associated with a second metric that affects the first metric may be identified. Output events of a pre-existing continuous query language query may be listened to. Further, a real-time visualization of the first metric and/or the second metric may be provided.
-
Citations
11 Claims
-
1. A system, comprising:
-
a memory storing a plurality of instructions; and one or more processors configured to access the memory, wherein the one or more processors are further configured to execute the plurality of instructions to at least; identify a key performance indicator associated with business event data; generate a first query for the key performance indicator; generate a relation based at least in part on a stream of the business event data; implement the first query against the relation to receive first data corresponding to the key performance indicator associated with the business event data; store a first snapshot of the first data corresponding to the key performance indicator in a data table; identify a risk indicator associated with the key performance indicator based at least in part on the key performance indicator; implement a second query against the relation; receive second data corresponding to the risk indicator based at least in part on the second query, the risk indicator identifying a change in the second data above a threshold amount corresponding to the first data, the second data corresponding to the risk indicator received by at least listening to event output of the second query; store a second snapshot of the second data corresponding to the risk indicator in the data table; associate the data table with a key performance indicator watchlist; generate information for presenting a risk dashboard user interface comprising a first visualization associated with the first snapshot of the first data corresponding to the key performance indicator associated with the key performance indicator watchlist and a second visualization associate with the second snapshot of the second data corresponding to the risk indicator associated with the key performance indicator watchlist; and present the first visualization and the second visualization in the risk dashboard user interface. - View Dependent Claims (2, 3, 4, 5)
-
-
6. A non-transitory computer-readable memory storing a plurality of instructions executable by one or more processors, the plurality of instructions comprising:
-
instructions that cause the one or more processors to identify a key performance indicator associated with streaming business event data; instructions that cause the one or more processors to generate a first continuous query for the key performance indicator; instructions that cause the one or more processors to generate a relation based at least in part on the streaming business event data; instructions that cause the one or more processors to implement the first continuous query against the relation for monitoring a first metric of the relation, the first metric indicating the key performance indicator of the streaming business event data; instructions that cause the one or more processors to store a first snapshot of the first metric corresponding to the key performance indicator in a data table; instructions that cause the one or more processors to identify a risk indicator based at least in part on the key performance indicator; instructions that cause the one or more processors to implement a second continuous query against the relation; instructions that cause the one or more processors to listen to event output of the second continuous query that outputs a second metric of the relation, the second metric affecting the first metric and corresponding to the risk indicator, the risk indicator identifying a change in the second metric above a threshold amount corresponding to the first metric; instructions that cause the one or more processors to receive the second metric based at least in part on the listening; instructions that cause the one or more processors to store a second snapshot of the second metric corresponding to the risk indicator in the data table; instructions that cause the one or more processors to associate the data table with a key performance indicator watchlist; instructions that cause the one or more processors to generate information for presenting a real-time risk dashboard user interface comprising a first visualization associated with the first snapshot of the first metric corresponding to the key performance indicator associated with the key performance indicator watchlist and a second visualization associated with the second snapshot of the second metric corresponding to the risk indicator associated with the key performance indicator watchlist; and instructions that cause the one or more processors to present the first visualization and the second visualization in the risk dashboard user interface. - View Dependent Claims (7, 8)
-
-
9. A computer-implemented method, comprising:
-
receiving selection, from a user associated with business event data, of a data object enabled to provide a real-time stream of the business event data; identifying a key performance indicator associated with the business event data; generating a first continuous query language query for the key performance indicator; generating a relation based at least in part on the real-time stream of the business event data; implementing the first continuous query language query against the relation to monitor the relation of the business event data for a first metric corresponding to a key performance indicator associated with the real-time stream; storing a first snapshot of the first data corresponding to the key performance indicator in a data table; identifying a risk indicator associated with a second metric that affects the first metric based at least in part on the key performance indicator; implementing a second continuous query language query against the relation; listening to output events of the second continuous query language query configured to monitor the relation for the second metric, the second metric corresponding to the risk indicator, and the risk indicator identifying a change in the second metric above a threshold amount corresponding to the first metric; storing a second snapshot of the second data corresponding to the risk indicator in the data table; associating the data table with a key performance indicator watchlist; generating information for presenting a real-time risk dashboard user interface comprising a first visualization associated with the first snapshot of the first metric corresponding to the key performance indicator associated with the key performance indicator watchlist and a second visualization associated with the second snapshot of the second metric corresponding to the risk indicator associated with the key performance indicator watchlist; and presenting the first visualization and the second visualization in the risk dashboard user interface. - View Dependent Claims (10, 11)
-
Specification