Edge device query processing of distributed database

Patent metadata

Field	Value
Publication number	US-12339848-B2
Application number	US-202318180027-A
Country	US
Kind code	B2
Filing date	Mar 7, 2023
Priority date	May 11, 2021
Publication date	Jun 24, 2025
Grant date	Jun 24, 2025

Abstract

A method for processing a query for data stored in a distributed database includes receiving, at an edge device, the query for data stored in the distributed database from a query device. The query is a request for data stored at the edge device and for data stored at other edge devices. The method includes executing, by the edge device, the query to find partial query results comprising the data stored at the edge device. The method includes generating, by the edge device, statistical information based on the partial query results. The method includes determining, by the edge device, a statistical confidence associated with the partial query results based on the statistical information. The method includes generating, by the edge device, an approximate response to the query based on the statistical information. The method includes transmitting the approximate response to the query device.

First claim

The invention claimed is:

1. A method for processing a distributed join query for data stored in a distributed database including a network of edge devices, the method comprising:
receiving, at an aggregator, the query for data stored in the distributed database from a query device, wherein the query is a request for at least one of: data stored at an edge device or data stored at other edge devices in the distributed database;
generating, by the aggregator, a query plan based on the query, wherein the query plan includes instructions for the edge device to generate an approximate response to the query; and
executing, by the edge device, the query plan based on the instructions, wherein the executing the query plan includes:
generating, by the edge device, partial query results using one or more distributed reference tables stored at the edge device,
wherein the one or more distributed reference tables include various data and metadata describing a structure of the data stored at the other edge devices in the distributed database, and
wherein the partial query results include at least one of: a portion of the data stored at the edge device or a portion of the data stored at the other edge devices;

generating, by the edge device, statistical information based on the partial query results;
determining, by the edge device, a statistical confidence associated with the partial query results based on the statistical information; and
in response to the statistical confidence exceeding a confidence interval threshold:
generating, by the edge device, the approximate response to the query based on the statistical information; and
transmitting, by the edge device, the approximate response to the query device.

2. The method of claim 1 wherein the query is an edge query language (EDQL) query.

3. The method of claim 1 wherein the query specifies a shard algorithm, and wherein the shard algorithm specifies a location of data stored in the distributed database.

4. The method of claim 1 further comprising:
causing the statistical information to be stored on a dynamic ledger,
wherein the dynamic ledger is a blockchain.

5. The method of claim 1 further comprising:
generating, by the edge device, a probability distribution model based on the partial query results;
generating, using the probability distribution model, the approximate response; and
storing the probability distribution model on a dynamic ledger.

6. The method of claim 1 ,
wherein the statistical information includes outlier data and at least one of: a mean of sensor data, a standard deviation of the sensor data, a sum of the sensor data, a count of the sensor data, or a reading associated with a particular sensor,
wherein the sensor data is collected by sensors connected to at least one of the edge device or the other edge devices, and
wherein the edge device and the other edge devices maintain a volume of the sensor data that is larger than a capacity of a centralized storage location.

7. The method of claim 1 wherein the network of edge devices includes a mesh network of edge devices.

8. The method of claim 1 further comprising:
receiving an instruction, from the aggregator, to reproduce a subset of the data stored at the edge device to a second edge device; and
transmitting the subset of the data from the edge device to the second edge device.

9. The method of claim 1 ,
wherein the one or more distributed reference tables are generated by the aggregator.

10. An edge device system comprising:
a set of one or more processors that executes a set of computer-readable instructions, wherein the set of one or more processors collectively:
receives, at an aggregator, a distributed join query for data stored in a distributed database from a query device,
wherein the distributed database includes a network of edge devices, and
wherein the query is a request for at least one of: data stored at an edge device or data stored at other edge devices in the distributed database;

generates, by the aggregator, a query plan based on the query, wherein the query plan includes instructions for the edge device to generate an approximate response to the query; and
executes, by the edge device, the query plan based on the instructions, wherein executing the query plan includes:
generating, by the edge device, partial query results using one or more distributed reference tables stored at the edge device,
wherein the one or more distributed reference tables include various data and metadata describing a structure of the data stored at the other edge devices in the distributed database, and
wherein the partial query results include at least one of: a portion of the data stored at the edge device or a portion of the data stored at the other edge devices;

generating, by the edge device, statistical information based on the partial query results;
determining, by the edge device, a statistical confidence associated with the partial query results based on the statistical information; and
in response to the statistical confidence exceeding a confidence interval threshold:
generating, by the edge device, the approximate response to the query based on the statistical information; and
transmitting, by the edge device, the approximate response to the query device.

11. The system of claim 10 wherein the query is an edge query language (EDQL) query.

12. The system of claim 10 ,
wherein the query specifies a shard algorithm, and
wherein the shard algorithm specifies a location of data stored in the distributed database.

13. The system of claim 10 ,
wherein at least one of: the data stored at the edge device or the data stored at the other edge devices at least partially includes sensor data collected from sensors connected to at least one of: the edge device or the other edge devices, and
wherein the edge device and the other edge devices maintain a volume of the sensor data that is larger than a capacity of a centralized storage location.

14. The system of claim 10 wherein the network of edge devices includes a mesh network of edge devices.

Assignees

• Strong Force Vcn Portfolio 2019 Llc

Inventors

• Cella Charles Howard
• Cardno Andrew

Classifications

• G06F16/182

  Distributed file systems · CPC title

• G05D1/69

  Coordinated control of the position or course of two or more vehicles · CPC title

• G06F16/24537

  of operators · CPC title

• G06F16/278

  Data partitioning, e.g. horizontal or vertical partitioning · CPC title

• G06F16/2456

  Join operations · CPC title