专利快速检索-快速检索全球专利，免费商用专利数据库-IPRDB

1. 发明授权

US11625381B2 Recreating an OLTP table and reapplying database transactions for real-time analytics 有权
公开(公告)号：US11625381B2
公开(公告)日：2023-04-11
申请号：US17238967
申请日：2021-04-23
申请人： Oracle International Corporation
发明人： Sandeep Bishnoi , Prabhu Thukkaram , Iuliia Shmeleva , Dmitrii Markovskii , Vitaly Vitalievich Bychkov , Gyorgy Geiszter
IPC分类号： G06F16/00 , G06F16/22 , G06F16/242 , G06F16/248 , G06F16/23 , G06F16/2455
摘要： Techniques for processing data streaming from one or more event sources in order to recreate a database table with database transactions for real-time analytics. An exemplary technique includes receiving a stream of events comprising change data for a table attribute, populating an in-memory table with the change data based on a token associated with an operation type and a mapping of a first attribute and a second attribute to a key attribute of the in-memory table, executing a continuous query on the change data for the key attribute of the in-memory table to generate events comprising data for a third attribute, and outputting the events having an output shape comprising the third attribute, where the events include the data for the third attribute.

2. 发明授权

US11573965B2 Data partitioning and parallelism in a distributed event processing system 有权
公开(公告)号：US11573965B2
公开(公告)日：2023-02-07
申请号：US15701019
申请日：2017-09-11
申请人： Oracle International Corporation
发明人： Herbert Stiel , Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram
IPC分类号： G06F17/00 , G06F7/00 , G06F16/2455 , G06F16/21 , G06F16/248 , G06F16/27 , G06F16/901 , G06F16/2453 , G06F16/903 , G06F8/35 , G06F9/54 , G06F16/242
摘要： An event processing system for processing events in an event stream is disclosed. The system is configured for determining a stage for a continuous query language (CQL) query being processed by an event processing system and/or determining a stage type associated with the stage. The system is also configured for determining a transformation to be computed for the stage based at least in part on the stage type and/or determining a classification for the CQL query based at least in part on a plurality of rules. The system can also be configured for generating a transformation in a Directly Acyclic Graph (DAG) of a data transformation pipeline for the stage based at least in part on the partitioning criteria for the stage. In some examples, the system can also be configured for determining a partitioning of the stage based at least in part on the transformation.

3. 发明申请

US20220114172A1 QUERY DECOMPOSITION FOR SCALABILITY OF CONTINUOUS QUERY PROCESSING 有权
公开(公告)号：US20220114172A1
公开(公告)日：2022-04-14
申请号：US17559361
申请日：2021-12-22
申请人： Oracle International Corporation
发明人： Unmesh Anil Deshmukh , Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram
IPC分类号： G06F16/2458 , G06F16/2452 , G06F16/9535 , G06F16/2455 , G06F16/2453
摘要： Systems and methods for query decomposition for scalability of continuous query processing are disclosed. In some examples, it is determined whether a query is fully stateful. If it is, the query may be divided into two functions, an aggregate function and a global function. The aggregate functions may be distributed across multiple distributed nodes and executed in parallel. The global function may then receive the results from the distributed nodes and join the results to achieve the fully stateful result.

4. 发明申请

US20190102791A1 TARGET USER ESTIMATION FOR DYNAMIC ASSETS 审中-公开
公开(公告)号：US20190102791A1
公开(公告)日：2019-04-04
申请号：US16022005
申请日：2018-06-28
申请人： Oracle International Corporation
发明人： Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram
IPC分类号： G06Q30/02 , G06F17/30
摘要： Techniques for processing event streams are provided that use streaming analytics to estimate a target user for dynamic assets. An exemplary technique includes receiving a batch of events that have position data for a potential target, determining one or more polygons that comprise the potential target based on the position data for the potential target, determining an approximate target viewership for the one or more polygons based on a profile or taxonomy of the potential target, associating an advertisement with the one or more polygons based on the approximate target viewership, receiving a continuous stream of events that have position data for a dynamic asset, determining that the one or more polygons include the dynamic asset based on the position data for the dynamic asset, obtaining the advertisement associated with the one or more polygons, and providing the advertisement to a sink for display on the dynamic asset.

5. 发明授权

US10127120B2 Event batching, output sequencing, and log based state storage in continuous query processing 有权
公开(公告)号：US10127120B2
公开(公告)日：2018-11-13
申请号：US15161062
申请日：2016-05-20
申请人： Oracle International Corporation
发明人： Hoyong Park , Sandeep Bishnoi , Unmesh Anil Deshmukh , Prabhu Thukkaram
IPC分类号： G06F17/30 , G06F11/14 , G06F9/54
摘要： An event processing system is disclosed that processes events of an event stream, performs the recovery of events during system failure and preserves the state of the system reliably and accurately while achieving desired system performance. In an embodiment, the event processing system processes a first batch of events of a continuous input stream of events using a continuous query and generates an output stream of events related to an application. The event processing system identifies one or more operators of the continuous query and determines that an operator is a journaled operator. The event processing system generates a journaled snapshot of a current state of the system based on execution of the journaled operator on at least the first batch of events and stores the journaled snapshot of the current state of the system.

6. 发明申请

US20180075108A1 AUTOMATIC PARALLELIZATION FOR GEOFENCE APPLICATIONS 审中-公开
公开(公告)号：US20180075108A1
公开(公告)日：2018-03-15
申请号：US15705402
申请日：2017-09-15
申请人： Oracle International Corporation
发明人： Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram , Iuliia Shmeleva
IPC分类号： G06F17/30 , H04W4/02
摘要： An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a continuous data stream related to an application, identify an input geometry associated with the continuous data stream, generate a cluster of geometries based at least in part on the input geometry, generate an output geometry based at least in part on the cluster of geometries and a number of geometries in each cluster of the cluster of geometries, determining one or more partitions for the output geometry based on the cluster of geometries and the number of geometries in each cluster of the cluster of geometries, dynamically change a size of the one or more partitions for the output geometry, and transmitting the output geometry associated with the continuous data stream.

7. 发明申请

US20180075046A1 MANAGING SNAPSHOTS AND APPLICATION STATE IN MICRO-BATCH BASED EVENT PROCESSING SYSTEMS 审中-公开
公开(公告)号：US20180075046A1
公开(公告)日：2018-03-15
申请号：US15706329
申请日：2017-09-15
申请人： Oracle International Corporation
发明人： Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram , Santosh Kumar , Pavan Advani , Kunal Mulay , Jeffrey Toillion
IPC分类号： G06F17/30
摘要： An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a micro-batch stream of input events, process the input events using the CQL engine to generate a set of output events, generate, using a snapshot management algorithm implemented by the CQL engine, a snapshot of a current state of a system based at least in part on the set of output events related to the application, generate a first directory structure to access snapshot information associated with the snapshot of the current state of the system, generate a second directory structure to generate a list of snapshots associated with the current state of the system, and determine based at least in part on the snapshot management algorithm, a process to get, add, or clean the list of snapshots associated with the current state of the system.

8. 发明申请

US20180074856A1 PROCESSING TIMESTAMPS AND HEARTBEAT EVENTS FOR AUTOMATIC TIME PROGRESSION 审中-公开
公开(公告)号：US20180074856A1
公开(公告)日：2018-03-15
申请号：US15696501
申请日：2017-09-06
申请人： Oracle International Corporation
发明人： Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram
IPC分类号： G06F9/48
CPC分类号： G06F9/4881 , G06F16/24568
摘要： An event processing system for processing events in an event stream is disclosed. The system is configured for configuring a stream processor to micro-batch incoming events from a stream source. The system is also configured for generating a single timestamp for a micro-batch of the incoming events and/or receiving the micro-batch of the incoming events from the stream source. The system can also be configured for assigning the single timestamp to each event of the micro-batch and/or generating separate timestamp values for each respective event of the micro-batch. In some examples, the system can also be configured for assigning, for each respective event of the micro-batch, an individual one of the separate timestamp values.

9. 发明授权

US09672082B2 Guaranteeing the event order for multi-stage processing in distributed systems 有权
公开(公告)号：US09672082B2
公开(公告)日：2017-06-06
申请号：US15095766
申请日：2016-04-11
申请人： Oracle International Corporation
发明人： Prabhu Thukkaram , Sandeep Bishnoi , Hoyong Park , Unmesh Anil Deshmukh
IPC分类号： G06F9/54 , G06F17/30 , H04L29/08
CPC分类号： G06F9/542 , G06F17/30516 , G06F17/30867 , H04L67/10
摘要： Systems and methods for guaranteeing the event order for multi-stage processing in distributed systems are disclosed. In some examples, a warm-up period is used to accurately determine a starting point for ordered events of an event stream. Skip-beats may be utilized as dummy events so that the event processor does not wait too long for events that were filtered out at earlier stages.

10. 发明授权

US09418113B2 Value based windows on relations in continuous data streams 有权
标题翻译：基于价值的窗口关于连续数据流中的关系
公开(公告)号：US09418113B2
公开(公告)日：2016-08-16
申请号：US13906162
申请日：2013-05-30
申请人： ORACLE INTERNATIONAL CORPORATION
发明人： Sandeep Bishnoi , Anand Srinivasan , Unmesh Anil Deshmukh
IPC分类号： G06F17/30
CPC分类号： G06F17/30516
摘要： Techniques for managing value-based windows on relations are provided. In some examples, an input relation is generated. The input relation is a bounded set of data records related to an application. A continuous query that identifies the input relation may be received. Additionally, a configurable window operator associated with processing the input relation may be identified. Then, the continuous query may be executed based at least in part on the configurable window operator to generate an output relation. Further, in some instances, the data records of the output relation may be provided based at least in part on execution of the continuous query.
摘要翻译：提供了用于管理基于价值的关系窗口的技术。在一些示例中，生成输入关系。输入关系是与应用有关的一组有限数据记录。可以接收识别输入关系的连续查询。另外，可以识别与处理输入关系相关联的可配置窗口操作符。然后，可以至少部分地基于可配置窗口运算符来执行连续查询以生成输出关系。此外，在一些情况下，可以至少部分地基于连续查询的执行来提供输出关系的数据记录。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式