Back to results
US 2026/0244645 A1Published application
Data Aggregation Processing Method, System, and Device
AssigneeHuawei Cloud Computing Technologies Co., Ltd.
InventorsWeiqi Li, Feiteng Huang, Chao Liu
Life of this patent
Estimating the term…
Abstract
A data aggregation processing method includes data aggregation processing that is performed by a distributed database system, and both data storage and data aggregation processing that are performed by a distributed database, with no need to set up an additional processing system for data aggregation processing. Therefore, data does not need to be replicated and separately sent to the distributed database system and the additionally set up processing system.
Claims20
A method comprising
- receiving, by a coordinator node of a distributed database system, an aggregation instruction for an original data table;
- obtaining, by the coordinator node, a first shard key of an aggregated data table corresponding to the original data table, wherein the aggregated data table records data based on aggregation processing on data in the original data table, and wherein the first shard key comprises at least one first attribute tag of the aggregated data table;
- determining, by the coordinator node, first allocation information indicating a first plurality of storage nodes respectively allocated to a plurality of first attribute value sets, wherein the plurality of first attribute value sets correspond to the first shard key, wherein a first attribute value set of the plurality of first attribute value sets comprises one attribute value of each of the at least one first attribute tag and wherein the distributed database system comprises the first plurality of storage nodes;
- comparing, by the coordinator node, the first attribute value set with an attribute value in a data unit corresponding to the original data table to determine the attribute value matches;
- distributing, by the coordinator node, the data unit to a first storage node of the first plurality of storage nodes to obtain a received data unit;
- and
- performing, by the first storage node, aggregation processing based on the received data unit.
4 more elements
A distributed database system comprising:
- a plurality of storage nodes;
- and
- a coordinator node configured to:
- receive an aggregation instruction for an original data table;
- obtain a first shard key of an aggregated data table corresponding to the original data table, wherein the aggregated data table records data based on performing aggregation processing on data in the original data table, and wherein the first shard key comprises at least one first attribute tag of the aggregated data table;
- determine first allocation information indicating a first plurality of storage nodes respectively allocated to a plurality of first attribute value sets, wherein the plurality of first attribute value sets correspond to the first shard key, and wherein a first attribute value set of the plurality of first attribute value sets comprises an attribute value of each of the at least one first attribute tag;
- compare the first attribute value set in the first allocation information with an attribute value in a data unit corresponding to the original data table to determine the attribute value matches;
- and
- distribute the data unit to a first storage node of the first plurality of storage nodes to obtain a received data unit,
- wherein the first storage node is configured to perform aggregation processing based on the received data unit.
7 more elements
Dependencies are inferred from the claim text.