公开(公告)号：US09953059B2

公开(公告)日：2018-04-24

申请号：US14036659

申请日：2013-09-25

Applicant: Oracle International Corporation

Inventor： Unmesh Anil Deshmukh ,  Anand Srinivasan ,  Vikram Shukla

IPC: G06F17/30

CPC classification number: G06F17/30516 ,  G06F17/30463 ,  G06F17/30466

Abstract: A method may include receiving a continuous query identified by an archived relation associated with an application. The method may also include generating a physical query plan. Additionally, the method may include constructing a structured query language (SQL) equivalent expression corresponding to an attribute utilized by the operator and/or constructing an output SQL expression for the identified operator based at least in part on the SQL equivalent expression. Additionally, the method may include constructing the archiver query for the identified operator based at least in part on the output SQL expression. Further, the method may include executing the archiver query to obtain a result set of data records related to the application and/or generating a snapshot output of one or more data values related to the application based at least in part on the result set of data records.

公开(公告)号：US20140095483A1

公开(公告)日：2014-04-03

申请号：US13830428

申请日：2013-03-14

Applicant: Oracle International Corporation

Inventor： Jeffrey Toillion ,  Unmesh Anil Deshmukh ,  Anand Srinivasan ,  Vikram Shukla

IPC: G06F17/30

CPC classification number: G06F17/30516 ,  B29D30/0681 ,  B29D2030/0682 ,  B32B27/08 ,  B32B27/34 ,  B60C1/0008 ,  B60C5/14 ,  G06F17/30389 ,  G06F17/30424 ,  G06F17/30442 ,  G06F17/30451 ,  G06F17/30457 ,  G06F17/30477 ,  G06F17/30483 ,  G06F17/30498 ,  G06F17/30548 ,  G06F17/30551 ,  G06F17/30554 ,  G06F17/30557 ,  G06F17/30616 ,  G06F17/30864 ,  G06F17/30958

Abstract: Techniques for counting event changes with archived relations are provided. In some examples, a query that identifies at least a data object may be identified. Additionally, the query may be evaluated against historical data associated with the data object. Additionally, in some instances, a listening service may be registered with the data object. Further, the query may be evaluated based at least in part on the data object and the historical data.

Abstract translation: 提供了使用存档关系计数事件更改的技术。 在一些示例中，可以识别至少识别数据对象的查询。 此外，可以针对与数据对象相关联的历史数据来评估查询。 另外，在某些情况下，可以向数据对象注册监听服务。 此外，可以至少部分地基于数据对象和历史数据来评估查询。

公开(公告)号：US20140095462A1

公开(公告)日：2014-04-03

申请号：US13828640

申请日：2013-03-14

Applicant: ORACLE INTERNATIONAL CORPORATION

Inventor： Hoyong Park ,  Anand Srinivasan ,  Vikram Shukla

IPC: G06F17/30

CPC classification number: G06F17/30516 ,  B29D30/0681 ,  B29D2030/0682 ,  B32B27/08 ,  B32B27/34 ,  B60C1/0008 ,  B60C5/14 ,  G06F17/30389 ,  G06F17/30424 ,  G06F17/30442 ,  G06F17/30451 ,  G06F17/30457 ,  G06F17/30477 ,  G06F17/30483 ,  G06F17/30498 ,  G06F17/30548 ,  G06F17/30551 ,  G06F17/30554 ,  G06F17/30557 ,  G06F17/30616 ,  G06F17/30864 ,  G06F17/30958

Abstract: Techniques for implementing the hybrid execution of continuous and scheduled queries are provided. In some examples, a query engine may be initialized with relational data from at least a first source. For example, the first source may include a database or other system that can provide historical data. Additionally, the query engine may be enabled to provide query results based at least in part on the relational data from at least the first source and streaming data from at least a second source. In some examples, the second source may be a data stream.

Abstract translation: 提供了实现连续和预定查询的混合执行的技术。 在一些示例中，可以使用来自至少第一源的关系数据来初始化查询引擎。 例如，第一源可以包括可以提供历史数据的数据库或其他系统。 另外，可以使查询引擎能够至少部分地基于来自至少第一源的关系数据和来自至少第二源的流数据来提供查询结果。 在一些示例中，第二源可以是数据流。

公开(公告)号：US20140095447A1

公开(公告)日：2014-04-03

申请号：US14037153

申请日：2013-09-25

Applicant: Oracle International Corporation

Inventor： Unmesh Anil Deshmukh ,  Anand Srinivasan ,  Vikram Shukla

IPC: G06F17/30

CPC classification number: G06F16/24568 ,  G06F16/24542 ,  G06F16/24544

Abstract: A continuous query identified by an archived relation of an application may be received. A physical query plan may be generated for the continuous query and/or a child operator plan may be identified. A buffer operator may be inserted between the child operator and its parent operator and/or the event information from the child operator may be stored in the buffer operator. A query operator may be identified in the physical query plan. It may be determined that the query operator identified in the physical query plan is a same type as a second query operator in a second continuous query concurrently executing. Further, a combined query plan may be generated based at least in part on the query operator identified in the physical query plan being the same type as the second query operator in the second continuous query.

Abstract translation: 可以接收通过应用的存档关系识别的连续查询。 可以为连续查询生成物理查询计划，和/或可识别子操作员计划。 可以在子操作符和其父操作符之间插入缓冲操作符和/或来自子操作符的事件信息可以存储在缓冲操作器中。 可以在物理查询计划中识别查询运算符。 可以确定在物理查询计划中识别的查询运算符与第二连续查询并发执行中的第二查询运算符相同。 此外，可以至少部分地基于在物理查​​询计划中识别的与第二连续查询中的第二查询运算符相同类型的查询运算符来生成组合查询计划。

公开(公告)号：US11210295B2

公开(公告)日：2021-12-28

申请号：US15905490

申请日：2018-02-26

Applicant: Oracle International Corporation

Inventor： Unmesh Anil Deshmukh ,  Anand Srinivasan ,  Vikram Shukla

IPC: G06F16/2455 ,  G06F16/2453

Abstract: A method may include receiving a continuous query identified by an archived relation associated with an application. The method may also include generating a physical query plan. Additionally, the method may include constructing a structured query language (SQL) equivalent expression corresponding to an attribute utilized by the operator and/or constructing an output SQL expression for the identified operator based at least in part on the SQL equivalent expression. Additionally, the method may include constructing the archiver query for the identified operator based at least in part on the output SQL expression. Further, the method may include executing the archiver query to obtain a result set of data records related to the application and/or generating a snapshot output of one or more data values related to the application based at least in part on the result set of data records.

公开(公告)号：US11093505B2

公开(公告)日：2021-08-17

申请号：US13830378

申请日：2013-03-14

Applicant: Oracle International Corporation

Inventor： Hoyong Park ,  Anand Srinivasan ,  Roger Bolsius ,  Eric Hsiao ,  Jeffrey Toillion ,  Vikram Shukla

IPC: G06F16/20 ,  G06F16/30 ,  G06F16/90 ,  B60C1/00 ,  G06F16/2455 ,  G06F16/25 ,  G06F16/242 ,  G06F16/245 ,  G06F16/248 ,  G06F16/31 ,  G06F16/951 ,  G06F16/2453 ,  G06F16/2458 ,  G06F16/901 ,  B29D30/06 ,  B29D30/00 ,  B32B27/00 ,  B60C5/10 ,  B32B27/08 ,  B32B27/34 ,  B60C5/14

Abstract: Techniques for managing real-time business event analysis and monitoring are provided. In some examples, a logical request may be received at a business intelligence server configured with a continuous query service. Additionally, the continuous query service may be configured to translate the logical request into a physical request. Further, business intelligence information may be provided based at least in part on querying against an event data stream with a continuous query configured based at least in part on the physical request translated by the continuous query service.

公开(公告)号：US20180246936A1

公开(公告)日：2018-08-30

申请号：US15968536

申请日：2018-05-01

Applicant: Oracle International Corporation

Inventor： Anand Srinivasan ,  Vikram Shukla ,  Unmesh Anil Deshmukh

IPC: G06F17/30

CPC classification number: B60C1/0008 ,  B29D30/0681 ,  B29D2030/0682 ,  B32B27/08 ,  B32B27/34 ,  B60C5/14 ,  G06F16/242 ,  G06F16/245 ,  G06F16/2453 ,  G06F16/24535 ,  G06F16/24539 ,  G06F16/2455 ,  G06F16/24553 ,  G06F16/2456 ,  G06F16/24568 ,  G06F16/2474 ,  G06F16/2477 ,  G06F16/248 ,  G06F16/25 ,  G06F16/313 ,  G06F16/9024 ,  G06F16/951

Abstract: Techniques for managing continuous queries that include subqueries are provided. In some examples, a continuous query that includes at least a subquery may be identified. Additionally, the subquery may be processed to obtain a first result or generate a logical subquery plan. Further, in some instances, the continuous query may then be processed based at least in part on the first result from the subquery or by merging a logical continuous query plan with the logical subquery plan. This may result in obtaining a second result via querying a data source with the continuous query that is based at least in part on the first result from the subquery and/or the merged plans.

公开(公告)号：US20180246935A1

公开(公告)日：2018-08-30

申请号：US15967272

申请日：2018-04-30

Applicant: Oracle International Corporation

Inventor： Jeffrey Toillion ,  Unmesh Anil Deshmukh ,  Anand Srinivasan ,  Vikram Shukla

IPC: G06F17/30

Abstract: Techniques for counting event changes with archived relations are provided. In some examples, a query that identifies at least a data object may be identified. Additionally, the query may be evaluated against historical data associated with the data object. Additionally, in some instances, a listening service may be registered with the data object. Further, the query may be evaluated based at least in part on the data object and the historical data.

公开(公告)号：US09756104B2

公开(公告)日：2017-09-05

申请号：US14621098

申请日：2015-02-12

Applicant: Oracle International Corporation

Inventor： Vikram Shukla ,  Anand Srinivasan

IPC: G06F15/16 ,  H04L29/06 ,  G06F17/30 ,  H04L12/26 ,  H04L12/841

CPC classification number: H04L65/602 ,  G06F17/30516 ,  H04L43/08 ,  H04L47/28

Abstract: One embodiment of the invention includes a method of processing streaming data. The method includes initializing a stream of data and setting a time interval to apply to the stream of data. The time interval comprises a window for analyzing the data within the stream of data. The method further includes identifying one or more columns within the stream of data, designating one or more of the columns to be monitored for differences within the data over the time interval, and monitoring the designated columns over the time interval. Further, the method includes determining that at least one value from at least one of the designated columns has changed and in response to at least one value changing, outputting the changed values from the designated columns.

公开(公告)号：US09715529B2

公开(公告)日：2017-07-25

申请号：US15003646

申请日：2016-01-21

Applicant: Oracle International Corporation

Inventor： Hoyong Park ,  Anand Srinivasan ,  Vikram Shukla

IPC: G06F7/00 ,  G06F17/30

CPC classification number: G06F17/30516 ,  B29D30/0681 ,  B29D2030/0682 ,  B32B27/08 ,  B32B27/34 ,  B60C1/0008 ,  B60C5/14 ,  G06F17/30389 ,  G06F17/30424 ,  G06F17/30442 ,  G06F17/30451 ,  G06F17/30457 ,  G06F17/30477 ,  G06F17/30483 ,  G06F17/30498 ,  G06F17/30548 ,  G06F17/30551 ,  G06F17/30554 ,  G06F17/30557 ,  G06F17/30616 ,  G06F17/30864 ,  G06F17/30958

Abstract: Techniques for implementing the hybrid execution of continuous and scheduled queries are provided. In some examples, a query engine may be initialized with relational data from at least a first source. For example, the first source may include a database or other system that can provide historical data. Additionally, the query engine may be enabled to provide query results based at least in part on the relational data from at least the first source and streaming data from at least a second source. In some examples, the second source may be a data stream.