公开(公告)号：US11080274B2

公开(公告)日：2021-08-03

申请号：US15408130

申请日：2017-01-17

Applicant: Futurewei Technologies, Inc.

Inventor： Yu Dong ,  Qingqing Zhou

IPC: G06F16/2452 ,  G06F16/2458 ,  H04L12/931

Abstract: A computer-implemented method and system at a network switch provides using one or more processors to perform a pre-defined database function on query data contained in data messages received at the network switch, with the performing producing result data, and wherein the pre-defined database function is performed on the query data in a first mode of operation to a state of full completion, generating complete result data and no skipped query data, and in a second mode of operation to a state of partial completion, generating partially complete result data and skipped query data. Further, the method and system performing one or more network switch functions to route the complete result data, and/or route the partially complete result data and skipped query data, to one or more destination nodes. In addition, an application programming interface (API) is used to define the database function.

公开(公告)号：US20180293272A1

公开(公告)日：2018-10-11

申请号：US15479843

申请日：2017-04-05

Applicant: Futurewei Technologies, Inc.

Inventor： Jiangsheng Yu ,  Shijun Ma ,  Qingqing Zhou ,  Ting Yu Cliff Leung

IPC: G06F17/30 ,  G06F17/16 ,  G06F17/18

Abstract: A method for cloning data samples in a data set based on statistic information of the data samples. The method does not use any of the data samples to perform the cloning. The statistic information includes a first set of statistic parameters obtained from a data matrix formed by data entries of the data samples based on Eckart-Young theorem, and a second set of statistic parameters indicating statistical properties of the data entries of the data samples. The data samples are reconstructed using the first and the second sets of statistic parameters based on Eckart-Young theorem.

公开(公告)号：US20180205672A1

公开(公告)日：2018-07-19

申请号：US15408206

申请日：2017-01-17

Applicant: Futurewei Technologies, Inc.

Inventor： Yu Dong ,  Qingqing Zhou ,  Guogen Zhang

IPC: H04L12/931 ,  H04L29/08 ,  G06F17/30

Abstract: A computer-implemented method and system are provided, including executing an application programming interface (API) in a network switch to define at least one of one or more database functions, performing, using one or more processors, the one or more database functions on at least a portion of data contained in a data message received at the switch, to generate result data, and routing the result data to one or more destination nodes. A database function-defined network switch includes a network switch and one or more processors to perform a pre-defined database function on query data contained in data messages received at the switch, to produce result data, wherein the pre-defined database function is performed on the query data in a first mode of operation to a state of full completion, generating complete result data and no skipped query data, or to a state of partial completion, generating partially completed result data and skipped query data.

公开(公告)号：US20160364484A1

公开(公告)日：2016-12-15

申请号：US14736050

申请日：2015-06-10

Applicant: FUTUREWEI TECHNOLOGIES, INC.

Inventor： Yu Dong ,  Qingqing Zhou ,  Guogen Zhang

IPC: G06F17/30 ,  H04L29/08

CPC classification number: G06F16/951 ,  G06F16/217 ,  G06F16/27 ,  H04L67/1097 ,  H04L67/28

Abstract: Data messages having different priorities may be stored in different communication buffers of a network node. The data messages may then be forwarded from the communication buffers to working buffers as space becomes available in the working buffers. After being forwarded to the working buffers, the data messages may be available to be processed by upper-layer operations of the network node. Priorities may be assigned to the data messages based on a priority level of a query associated with the data messages, a priority level of an upper-layer operation assigned to process the data messages, or combinations thereof.

Abstract translation: 具有不同优先级的数据消息可以存储在网络节点的不同通信缓冲器中。 然后，当工作缓冲区中的空间变得可用时，数据消息可以从通信缓冲器转发到工作缓冲区。 在转发到工作缓冲区之后，数据消息可以被网络节点的上层操作处理。 可以基于与数据消息相关联的查询的优先级，分配用于处理数据消息的上层操作的优先级或其组合，将优先级分配给数据消息。

公开(公告)号：US20140280031A1

公开(公告)日：2014-09-18

申请号：US13798680

申请日：2013-03-13

Applicant: FUTUREWEI TECHNOLOGIES, INC.

Inventor： Qingqing Zhou ,  Guogen Zhang

IPC: G06F17/30

CPC classification number: G06F17/30463

Abstract: System and method embodiments are provided for adaptive vector size selection for vectorized query execution. The adaptive vector size selection is implemented in two stages. In a query planning stage, a suitable vector size is estimated for a query by a query planner. The planning stage includes analyzing a query plan tree, segmenting the tree into different segments, and assigning to the query execution plan an initial vector size to each segment. In a subsequent query execution stage, an execution engine monitors hardware performance indicators, and adjusts the vector size according to the monitored hardware performance indicators. Adjusting the vector size includes trying different vector sizes and observing related processor counters to increase or decrease the vector size, wherein the vector size is increased to improve hardware performance according to the processor counters, and wherein the vector size is decreased when the processor counters indicate a decrease in hardware performance.

Abstract translation: 为向量化查询执行的自适应向量大小选择提供了系统和方法实施例。 自适应向量大小选择分两个阶段实现。 在查询计划阶段，由查询计划器为查询估计合适的向量大小。 规划阶段包括分析查询计划树，将树分割成不同的段，并将查询执行计划分配给每个段的初始向量大小。 在随后的查询执行阶段，执行引擎监视硬件性能指标，并根据监视的硬件性能指标调整向量大小。 调整矢量大小包括尝试不同的矢量大小并观察相关的处理器计数器以增加或减少矢量大小，其中根据处理器计数器增加矢量大小以提高硬件性能，并且其中当处理器计数器指示 硬件性能下降。

公开(公告)号：US20140280020A1

公开(公告)日：2014-09-18

申请号：US13802023

申请日：2013-03-13

Applicant: FUTUREWEI TECHNOLOGIES, INC.

Inventor： Mohan Singamshetty ,  Yang Sun ,  Qingqing Zhou

IPC: G06F17/30

CPC classification number: G06F17/30445

Abstract: System and method embodiments are provided for improving the performance of query processing in a massively parallel processing (MPP) database system by pushing down join query processing to data nodes recursively. An embodiment method includes receiving, at a coordinator process, a join query associated with a plurality of tables of the MPP database system, generating, at the coordinator process, an execution plan tree for the join query, and processing, at each of a plurality of data nodes communicating with the coordinator process, the execution plan tree to obtain join query results. The method further includes, upon detecting a next join operator below a top join operator in the execution plan tree at each of the data nodes, forwarding to the other data nodes a sub-tree for the next join operator, and receiving, at each of the data nodes from the other data nodes, sub-tree processing results.

Abstract translation: 提供了系统和方法实施例，用于通过将连接查询处理递归地推送到数据节点来提高大规模并行处理（MPP）数据库系统中查询处理的性能。 一种实施方式包括在协调器进程处接收与MPP数据库系统的多个表相关联的连接查询，在协调器进程处生成用于连接查询的执行计划树，并在多个表中的每一个处处理 的数据节点与协调器进程通信，执行计划树获取连接查询结果。 该方法还包括：在每个数据节点处检测执行计划树中的顶部连接运算符下面的下一个连接运算符，向下一个连接运算符转发另一个数据节点的子树，并在每个 来自其他数据节点的数据节点，子树处理结果。

公开(公告)号：US12189657B2

公开(公告)日：2025-01-07

申请号：US17836105

申请日：2022-06-09

Applicant: Futurewei Technologies, Inc.

Inventor： Qingqing Zhou ,  Yang Sun ,  Guogen Zhang

IPC: G06F16/27 ,  G06F16/215 ,  G06F16/22

Abstract: System and method embodiments are provided for using different storage formats for a primary database and its replicas in a database managed replication (DMR) system. As such, the advantages of both formats can be combined with suitable design complexity and implementation. In an embodiment, data is arranged in a sequence of rows and stored in a first storage format at the primary database. The data arranged in the sequence of rows is also stored in a second storage format at the replica database. The sequence of rows is determined according to the first storage format or the second storage format. The first storage format is a row store (RS) and the second storage format is a column store (CS), or vice versa. In an embodiment, the sequence of rows is determined to improve compression efficiency at the CS.

公开(公告)号：US09552390B2

公开(公告)日：2017-01-24

申请号：US14264851

申请日：2014-04-29

Applicant: Futurewei Technologies, Inc.

Inventor： Qingqing Zhou

IPC: G06F17/30

CPC classification number: G06F17/30463 ,  G06F17/30339

Abstract: Embodiments are provided herein for efficient out-of-order (OOO) multiple query execution within a stored procedure in a database processing system. An embodiment method includes compiling a procedure comprising a plurality of statements. During the compiling, any dependencies between the statements are detected and maintained in a dependency table. The method further includes executing the procedure. During the execution, the method includes upon detecting a change in a dependency between the statements, updating the dependency in the dependency table. The statements are scheduled for OOO execution according to the dependency table with the updated dependencies.

Abstract translation: 本文提供了用于在数据库处理系统中的存储过程中的有效的无序（OOO）多个查询执行的实施例。 实施例方法包括编译包括多个语句的过程。 在编译期间，在依赖关系表中检测和维护语句之间的任何依赖关系。 该方法还包括执行该过程。 在执行期间，该方法包括在检测到语句之间的依赖性的变化时，更新依赖关系表中的依赖性。 根据具有更新的依赖关系的依赖关系表，这些语句被安排为OOO执行。

公开(公告)号：US20200210273A1

公开(公告)日：2020-07-02

申请号：US16737534

申请日：2020-01-08

Applicant: Futurewei Technologies, Inc.

Inventor： Le Cai ,  Qingqing Zhou ,  Yang Sun

IPC: G06F11/07 ,  G06F16/27 ,  G06F11/14 ,  G06F16/25 ,  G06F16/11

Abstract: A method for data redistribution of a job data in a first datanode (DN) to at least one additional DN in a Massively Parallel Processing (MPP) Database (DB) is provided. The method includes recording a snapshot of the job data, creating a first data portion in the first DN and a redistribution data portion in the first DN, collecting changes to a job data copy stored in a temporary table, and initiating transfer of the redistribution data portion to the at least one additional DN.

公开(公告)号：US10360267B2

公开(公告)日：2019-07-23

申请号：US14736050

申请日：2015-06-10

Applicant: Futurewei Technologies, Inc.

Inventor： Yu Dong ,  Qingqing Zhou ,  Guogen Zhang

IPC: G06F17/30 ,  G06F16/951 ,  H04L29/08 ,  G06F16/27 ,  G06F16/21

Abstract: Data messages having different priorities may be stored in different communication buffers of a network node. The data messages may then be forwarded from the communication buffers to working buffers as space becomes available in the working buffers. After being forwarded to the working buffers, the data messages may be available to be processed by upper-layer operations of the network node. Priorities may be assigned to the data messages based on a priority level of a query associated with the data messages, a priority level of an upper-layer operation assigned to process the data messages, or combinations thereof.