Managing risk with continuous queries

• US 9,852,186 B2
• Filed: 03/14/2013
• Issued: 12/26/2017
• Est. Priority Date: 09/28/2012
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Herwadkar, Rahul, Hsiao, Eric
• Primary Examiner(s): Gurmu, Muluemebet
• Application Number:
  US13/830,759
• Publication Number:
  US 20140095541A1
• Time in Patent Office: 1,748 Days
• Field of Search: 707774
• CPC Class Codes: B29D 2030/0682 Inner liners tubeless tyres with impervious liner or coating on the tyre B60C5/14
• CPC Class Codes: B29D 30/0681 Parts of pneumatic tyres; accessories, auxiliary operations
• CPC Class Codes: B32B 27/08 of synthetic resin
• CPC Class Codes: B32B 27/34 comprising polyamides
• CPC Class Codes: B60C 1/0008 Compositions of the inner liner
• CPC Class Codes: B60C 5/14 with impervious liner or coating on the inner wall of the tyre
• CPC Class Codes: G06F 16/242 Query formulation
• CPC Class Codes: G06F 16/245 Query processing
• CPC Class Codes: G06F 16/2453 Query optimisation
• CPC Class Codes: G06F 16/24535 of sub-queries or views
• CPC Class Codes: G06F 16/24539 using cached or materialised query results
• CPC Class Codes: G06F 16/2455 Query execution
• CPC Class Codes: G06F 16/24553 of query operations
• CPC Class Codes: G06F 16/2456 Join operations
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/2474 Sequence data queries, e.g. querying versioned data
• CPC Class Codes: G06F 16/2477 Temporal data queries
• CPC Class Codes: G06F 16/248 Presentation of query results
• CPC Class Codes: G06F 16/25 Integrating or interfacing systems involving database management systems
• CPC Class Codes: G06F 16/313 Selection or weighting of terms for indexing
• CPC Class Codes: G06F 16/9024 : Graphs; Linked lists G06F16/9027 takes precedence
• CPC Class Codes: G06F 16/951 : Indexing; Web crawling techniques

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.

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.

2. The system of claim 1, wherein the risk indicator is identified automatically by the system utilizing the received data corresponding to the first metric.

3. The system of claim 1, wherein at least one of the first or second queries is a continuous query configured to query against the stream of business event data.

4. The system of claim 3, wherein the continuous query is based at least in part on a continuous query language.

5. The system of claim 1, wherein the second query is implemented prior to implementation of the first query.

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.

7. The non-transitory computer-readable memory of claim 6, wherein the risk indicator is automatically determined by the one or more processors based at least in part on information associated with the key performance indicator.

8. The non-transitory computer-readable memory of claim 6, wherein the risk indicator identifies a risk level associated with the key performance indicator reaching a threshold.

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.

10. The computer-implemented method of claim 9, wherein identifying the risk indicator includes automatically determining one or more risk indicators that affect the key performance indicator.

11. The computer-implemented method of claim 9, wherein the selection of the data object is implemented via an application programming interface method performed by the user.