-
公开(公告)号：US10231085B1
公开(公告)日：2019-03-12
申请号：US16124014
申请日：2018-09-06
Applicant: Oracle International Corporation
Inventor： Santosh Kumar , Santosh Kumar Singh , Prithviraj Singh , Rahul Gupta , Yathish Gatty , Kunal Mulay
Abstract: An event processing system for distributing geospatial computations with geo-fences is disclosed. The system can partition and distribute geo-fences efficiently for parallel computation, and can track a potentially unlimited number of moving objects. A computing device determines a minimum bounding rectangle (MBR) covering a geographic area indexed by a geo-grid, and partitions the MBR and a set of geo-fences to a plurality of processing nodes. The computing device receives input events of a stream comprising locations within the geographic area. The device distributes the events to partitions on processing nodes, based at least on the events' locations. The device can determine a partition identifier corresponding to a respective location in constant time. The computing device then combines partition results to obtain a single geospatial computation result.
-
公开(公告)号：US10349210B2
公开(公告)日：2019-07-09
申请号：US16249468
申请日：2019-01-16
Applicant: Oracle International Corporation
Inventor： Santosh Kumar , Santosh Kumar Singh , Prithviraj Singh , Rahul Gupta , Yathish Gatty , Kunal Mulay
Abstract: An event processing system for distributing geospatial computations with geo-fences is disclosed. The system can partition and distribute geo-fences efficiently for parallel computation, and can track a potentially unlimited number of moving objects. A computing device determines a minimum bounding rectangle (MBR) covering a geographic area indexed by a geo-grid, and partitions the MBR and a set of geo-fences to a plurality of processing nodes. The computing device receives input events of a stream comprising locations within the geographic area. The device distributes the events to partitions on processing nodes, based at least on the events' locations. The device can determine a partition identifier corresponding to a respective location in constant time. The computing device then combines partition results to obtain a single geospatial computation result.
-
3.发明申请公开(公告)号：US20180075046A1
公开(公告)日：2018-03-15
申请号：US15706329
申请日：2017-09-15
Applicant: Oracle International Corporation
Inventor： Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram , Santosh Kumar , Pavan Advani , Kunal Mulay , Jeffrey Toillion
IPC: G06F17/30
Abstract: 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.
-
公开(公告)号：US10713249B2
公开(公告)日：2020-07-14
申请号：US15706329
申请日：2017-09-15
Applicant: Oracle International Corporation
Inventor： Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram , Santosh Kumar , Pavan Advani , Kunal Mulay , Jeffrey Toillion
IPC: G06F17/30 , G06F16/2453 , G06F16/13 , G06F16/23 , G06F16/11 , G06F16/901 , G06F16/9032 , G06F16/2455 , G06F16/903 , G06F11/30
Abstract: 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.
-
Patent Agency Ranking
公开(公告)号：US20190104380A1
公开(公告)日：2019-04-04
申请号：US16124014
申请日：2018-09-06
Applicant: Oracle International Corporation
Inventor： Santosh Kumar , Santosh Kumar Singh , Prithviraj Singh , Rahul Gupta , Yathish Gatty , Kunal Mulay
Abstract: An event processing system for distributing geospatial computations with geo-fences is disclosed. The system can partition and distribute geo-fences efficiently for parallel computation, and can track a potentially unlimited number of moving objects. A computing device determines a minimum bounding rectangle (MBR) covering a geographic area indexed by a geo-grid, and partitions the MBR and a set of geo-fences to a plurality of processing nodes. The computing device receives input events of a stream comprising locations within the geographic area. The device distributes the events to partitions on processing nodes, based at least on the events' locations. The device can determine a partition identifier corresponding to a respective location in constant time. The computing device then combines partition results to obtain a single geospatial computation result.
-
公开(公告)号：US11615088B2
公开(公告)日：2023-03-28
申请号：US15706226
申请日：2017-09-15
Applicant: Oracle International Corporation
Inventor： Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram , Santosh Kumar , Pavan Advani , Kunal Mulay , Jeffrey Toillion
IPC: G06F16/2453 , G06F16/13 , G06F16/23 , G06F16/11 , G06F16/901 , G06F16/9032 , G06F16/2455 , G06F16/903 , G06F11/30
Abstract: An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a continuous query, apply a transformation to the continuous query to generate a query plan for the continuous query, transform the query plan using a transformation algorithm to generate a transformed query plan, receive a micro-batch stream of input events related to an application, process the input events of the micro-batch stream based at least in part on the transformed query plan to generate a set of output events related to the application, and store the set of output events related to the application in an output queue.
-
公开(公告)号：US20180075099A1
公开(公告)日：2018-03-15
申请号：US15706226
申请日：2017-09-15
Applicant: Oracle International Corporation
Inventor： Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram , Santosh Kumar , Pavan Advani , Kunal Mulay , Jeffrey Toillion
IPC: G06F17/30
CPC classification number: G06F16/24542 , G06F11/3003 , G06F16/113 , G06F16/128 , G06F16/13 , G06F16/23 , G06F16/24568 , G06F16/9024 , G06F16/9032 , G06F16/90335 , G06F16/90344
Abstract: An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a continuous query, apply a transformation to the continuous query to generate a query plan for the continuous query, transform the query plan using a transformation algorithm to generate a transformed query plan, receive a micro-batch stream of input events related to an application, process the input events of the micro-batch stream based at least in part on the transformed query plan to generate a set of output events related to the application, and store the set of output events related to the application in an output queue.
-
公开(公告)号：US10789250B2
公开(公告)日：2020-09-29
申请号：US15706407
申请日：2017-09-15
Applicant: Oracle International Corporation
Inventor： Hoyong Park , Sandeep Bishnoi , Prabhu Thukkaram , Santosh Kumar , Pavan Advani , Kunal Mulay , Jeffrey Toillion
IPC: G06F17/30 , G06F16/2453 , G06F16/13 , G06F16/23 , G06F16/11 , G06F16/901 , G06F16/9032 , G06F16/2455 , G06F16/903 , G06F11/30
Abstract: An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a continuous query, apply a transformation to the continuous query to generate a query plan for the continuous query, monitor the continuous query using a monitoring transformation process, receive a micro-batch stream of input events related to an application, and process the input events of the micro-batch stream based at least in part on the monitoring transformation process to generate a set of output events related to the application.
-
公开(公告)号：US20190149949A1
公开(公告)日：2019-05-16
申请号：US16249468
申请日：2019-01-16
Applicant: Oracle International Corporation
Inventor： Santosh Kumar , Santosh Kumar Singh , Prithviraj Singh , Rahul Gupta , Yathish Gatty , Kunal Mulay
CPC classification number: H04W4/021 , G06F9/542 , G06F16/215 , G06F16/2237 , G06F16/2255 , G06F16/24554 , G06F16/248 , G06F16/29 , G06F16/9535 , G06F16/9537 , H04L67/10 , H04L67/18 , H04W4/023
Abstract: An event processing system for distributing geospatial computations with geo-fences is disclosed. The system can partition and distribute geo-fences efficiently for parallel computation, and can track a potentially unlimited number of moving objects. A computing device determines a minimum bounding rectangle (MBR) covering a geographic area indexed by a geo-grid, and partitions the MBR and a set of geo-fences to a plurality of processing nodes. The computing device receives input events of a stream comprising locations within the geographic area. The device distributes the events to partitions on processing nodes, based at least on the events' locations. The device can determine a partition identifier corresponding to a respective location in constant time. The computing device then combines partition results to obtain a single geospatial computation result.
-
-
-
-
-
-
-
-
Search Results
9
records
(took 0.015 seconds)
