-
公开(公告)号:US11412343B2
公开(公告)日:2022-08-09
申请号:US16123973
申请日:2018-09-06
Applicant: Oracle International Corporation
Inventor: Santosh Kumar , Santosh Kumar Singh , Prithviraj Singh , Rahul Gupta , Yathish Gatty , Hanumesh Thippanna Govindappa
IPC: H04W4/021 , H04W4/02 , G06F9/54 , G06F16/29 , G06F16/22 , H04L67/10 , H04L67/52 , G06F16/215 , G06F16/2455 , G06F16/9535 , G06F16/9537 , G06F16/248
Abstract: An event processing system for distributing a geospatial computation, and processing events in an event stream, is disclosed. The disclosed system and methods can apply a spatial function, such as distance, within Distance, and proximity, in parallel to a stream comprising event locations. The disclosed system improves over existing geospatial computations by providing an efficient parallel implementation that can handle a large number of moving objects in real time with little latency. A computing device receives an event stream comprising locations and can geohash the locations to obtain geohashes identifying geo grid cells containing the locations. The computing device can determine respective sets of neighboring geohashes identifying neighboring cells in the geo grid. The computing device then partitions the geospatial computation by mapping, based on the respective geo hash and the respective set of neighboring geo hashes, the events to processors.
-
公开(公告)号: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.
-
公开(公告)号:US09703836B2
公开(公告)日:2017-07-11
申请号:US15015933
申请日:2016-02-04
Applicant: Oracle International Corporation
Inventor: Eric Hsiao , Vishal Sharma , Adriano Covello Santos , Rahul Gupta
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 managing tactical query to continuous query conversion are provided. In some examples, a tactical query configured to enable the pulling of business event data from a database to a query engine may be determined. For example, a query engine may be configured with the tactical query. The configuration may be based at least in part on an indication of the business event data to be displayed. Further, in some examples, a conversion of the tactical query to a continuous query may be enabled. The conversion or enablement of the conversion may be based at least in part on a request.
-
公开(公告)号:US12271396B2
公开(公告)日:2025-04-08
申请号:US18225827
申请日:2023-07-25
Applicant: Oracle International Corporation
Inventor: Rohit Jaykumar Gattani , Rahul Gupta
Abstract: A system for data partitioning based on discovery of discrete partitioning information. The system can receive data sets in table format from source system. The data can be stored in the source system to be partitioned and transmitted from the source system to a target system. The system can determine a respective partitioning column for each data set. The system can determine a number of partitions. The system can determine, for each data set, a respective set of discrete values from the plurality of discrete values of the respective partitioning column. The number of the discrete values of the set of discrete values can be based at least in part on the number of partitions. The system can the discrete value sets with each other. The system can determine a final set of discrete values based at least in part on the comparison.
-
公开(公告)号:US20240256296A1
公开(公告)日:2024-08-01
申请号:US18487435
申请日:2023-10-16
Applicant: Oracle International Corporation
Inventor: Rohit Jaykumar Gattani , Rahul Gupta
CPC classification number: G06F9/44526 , G06F9/45529
Abstract: Techniques for instantiating a reference type to create a first descendant loader and a second descendant loader. The first descendant loader and the second descendant loader may be isolated loaders. The first descendant loader may load a first plugin and a first set of libraries. The first set of libraries may be needed to complete a first operation. The second descendant loader may load a second plugin and a second set of libraries. The second set of libraries may be needed to complete a second operation. The first set of libraries may conflict with the second set of libraries. A first method of the first plugin may be invoked through a plugin interface in order to complete the first operation. A second method of the second plugin may be invoked through the plugin interface to complete the second operation.
-
公开(公告)号: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.
-
公开(公告)号:US09531800B2
公开(公告)日:2016-12-27
申请号:US13801972
申请日:2013-03-13
Applicant: Oracle International Corporation
Inventor: Rahul Gupta , Dimitri Laloue , Kiran Prabhakar
CPC classification number: H04L67/1031 , G06F9/5083 , G06F2209/504 , H04L67/1008 , Y02D10/22
Abstract: A computer-controlled method can include creating a throttling group corresponding to a backend server configured to provide business services to multiple electronic devices over a service bus, defining a throttling group parameter for the throttling group, and routing messages based on the throttling group parameter.
Abstract translation: 计算机控制的方法可以包括创建对应于后端服务器的限制组,所述后端服务器被配置为通过服务总线向多个电子设备提供业务服务,为限制组定义节流组参数,以及基于所述调节组参数来路由消息。
-
公开(公告)号:US20160154855A1
公开(公告)日:2016-06-02
申请号:US15015933
申请日:2016-02-04
Applicant: Oracle International Corporation
Inventor: Eric Hsiao , Vishal Sharma , Adriano Covello Santos , Rahul Gupta
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 managing tactical query to continuous query conversion are provided. In some examples, a tactical query configured to enable the pulling of business event data from a database to a query engine may be determined. For example, a query engine may be configured with the tactical query. The configuration may be based at least in part on an indication of the business event data to be displayed. Further, in some examples, a conversion of the tactical query to a continuous query may be enabled. The conversion or enablement of the conversion may be based at least in part on a request.
Abstract translation: 提供了用于管理连续查询转换的战术查询的技术。 在一些示例中,可以确定配置为使得能够将数据库中的业务事件数据拉到查询引擎的战术查询。 例如,查询引擎可以配置有战术查询。 该配置可以至少部分地基于要显示的业务事件数据的指示。 此外,在一些示例中,可以启用战术查询到连续查询的转换。 转换的转换或启用可以至少部分地基于请求。
-
-
-
-
-
-
-