Bifurcated System for Querying Multiple Data Types

Patent metadata

Field	Value
Publication number	US-2025278403-A1
Application number	US-202418617163-A
Country	US
Kind code	A1
Filing date	Mar 26, 2024
Priority date	Feb 29, 2024
Publication date	Sep 4, 2025
Grant date	—

Abstract

Techniques are disclosed relating to executing a bifurcated computer system for different types of data processing. The system receives a plurality of requests to execute queries and executes a first service of the system for a first query specified by the requests based on the first query specifying a first type of data. The system accesses, via the first service for the first query, a first database storing the first type of data. The system executes a second service for a second query specified by the requests based on the second query specifying a second type of data. The system accesses, via the second service for the second query, a second database storing the second type of data. The system transmits results of the first database to a user device of the first query and results of the second database to a user device of the second query.

First claim

1 . A method, comprising:
receiving, by a bifurcated computer system from one or more user devices, a plurality of requests to execute queries; executing, by the system for a first query specified by one of the plurality of requests, a first service included in a first processing pipeline of the system, wherein executing the first service is performed based on the first query specifying a first type of data to access; accessing, by the system via the first service and for the first query, a first database included in the first processing pipeline of the system and storing the first type of data; executing, by the system for a second query specified by one of the plurality of requests, a second service included in a second processing pipeline of the system, wherein executing the second service is performed based on the second query specifying a second, different type of data to access; accessing, by the system via the second service and for the second query, a second database included in the second processing pipeline of the system and storing the second, different type of data; and transmitting, by the system, results of accessing the first database to a user device corresponding to the first query and results of accessing the second database to a user device corresponding to the second query.

2 . The method of claim 1 , wherein the first type of query retrieves real-time data that is processed in real-time and the second type of query retrieves batch data that is processed in batches.

3 . The method of claim 1 , wherein the first service is an online transaction processing (OLTP) service and the second service is an online analytical processing (OLAP) service, and wherein the first type of data is OLTP data and the second type of data is OLAP data.

4 . The method of claim 1 , wherein transmitting the results of accessing the first database is performed before transmitting the results of accessing the second database, and wherein an amount of data returned in the results of accessing the second database is larger than an amount of data returned in the results of accessing the first database.

5 . The method of claim 1 , wherein the data retrieved by the first query from the first database includes geolocation data, wherein the first database is a non-relational database storing the geolocation data as key-value pairs, and wherein a given entry in the non-relational database includes a key storing an entity identifier corresponding to an entity and a value storing a latitude and longitude indicating a geographic location of the entity.

6 . The method of claim 5 , wherein executing the first service for the first query to retrieve geolocation data from the first database includes performing a k-nearest neighbor (kNN) search query on the first database, wherein a search region of the kNN search query is a circle with a minimum radius that encompasses a number of entities that satisfies an entity threshold requirement, and wherein the number of entities are located in geographic locations that fall within a circumference of the circle.

7 . The method of claim 1 , wherein the plurality of requests are received via a single user interface of the bifurcated computer system, and wherein the single user interface includes a user interface element capable of receiving user input specifying the first type of data or the second, different type of data.

8 . The method of claim 1 , wherein the first database and the second database are implemented using the same database schema.

9 . A non-transitory computer-readable medium having instructions stored thereon that are executable by a computing system to perform operations comprising:
receiving, from one or more user devices, a plurality of requests to execute queries; executing, for a first query specified by one of the plurality of requests, a first service included in a first pipeline of the computing system, wherein executing the first service is performed based on the first query specifying a first type of data to access, and wherein executing the first service includes accessing, for the first query, a first database included in the first pipeline of the system and storing the first type of data; executing, for a second query specified by one of the plurality of requests, a second service included in a second pipeline of the system, wherein executing the second service is performed based on the second query specifying a second, different type of data to access, and wherein executing the second service includes accessing, for the second query, a second database included in the second pipeline of the system and storing the second, different type of data; transmitting, to a user device corresponding to the first query, results of accessing the first database; and transmitting, to a user device corresponding to the second query, results of accessing the second database.

10 . The non-transitory computer-readable medium of claim 9 , wherein the data retrieved by the first query from the first database includes transaction network graph data, wherein the first database is a non-relational database storing the transaction network graph data as key-value pairs, and wherein a given entry in the non-relational database includes a key storing an entity identifier corresponding to an entity and a value storing transaction data indicating information for a given transaction executed for the entity, including a transaction identifier.

11 . The non-transitory computer-readable medium of claim 9 , wherein the first type of query processes data in real-time and the second type of query performs batch processing.

12 . The non-transitory computer-readable medium of claim 9 , wherein the first service is an online transaction processing (OLTP) service and the second service is an online analytical processing (OLAP) service, and wherein the first query is an OLTP query and the second query is an OLAP query.

13 . The non-transitory computer-readable medium of claim 9 , wherein the data retrieved by the first query from the first database includes geolocation data, and wherein the first database is a non-relational database storing the geolocation data as key-value pairs, wherein a given entry in the non-relational database includes a key storing an entity identifier corresponding to an entity and a value storing a latitude and longitude indicating a geographic location of the entity.

14 . The non-transitory computer-readable medium of claim 13 , wherein executing the first service for the first query to retrieve geolocation data from the first database includes performing a k-nearest neighbor (kNN) search query on the first database, wherein a search region of the kNN search query is a circle with a minimum radius that encompasses a number of entities that satisfies an entity threshold requirement, and wherein the number of entities are located in geographic locations that fall within a circumference of the circle.

15 . The non-transitory computer-readable medium of claim 9 , wherein the plurality of requests are received via a single user interface of the computing system, and wherein the single user interface includes a user interface element capable of receiving user input specifying the first type of data or the second, different type of data.

16 . A bifurcated system, comprising:
an online data processing service; an offline data processing service; a non-transitory computer-readable medium having stored thereon instructions that are executable by the online data processing service and the offline data processing service to cause the system to perform operations

Assignees

• Paypal Inc

Inventors

• Zhang Pengshan
• Zhou Yuliang
• Sharma Nitin S
• Periyasamy Eswaramoorthy
• Luan Xiaojun
• Guo Junshi

Classifications

• G06F16/2471

  Distributed queries · CPC title

• G06F16/29

  Geographical information databases · CPC title

• G06F16/254

  Extract, transform and load [ETL] procedures, e.g. ETL data flows in data warehouses · CPC title

• G06F16/2455 Primary

  Query execution · CPC title

• G06F16/2379 Primary

  Updates performed during online database operations; commit processing · CPC title