| 摘要 |
一种基于分布式系统的流式构建数据方的方法和装置。该方法包括：处理节点接收主节点发送的物理节点图；处理节点为物理节点图中的第一逻辑节点上的任一个第一物理节点，物理节点图包括至少一个第一逻辑节点和一个第二逻辑节点，第一逻辑节点包括至少一个第一物理节点，第二逻辑节点包括至少一个第二物理节点，第一逻辑节点和第二逻辑节点相连；处理节点根据物理节点图确定自身待计算的Cube的结构；若处理节点接收到主节点发送的查询命令，根据自身待计算的Cube的结构对自身所接收到的数据流进行聚集操作，生成Cube；处理节点将Cube发送给主节点。; determining, by the processing node, a structure of a to-be-computed data cube of the processing node according to the physical node diagram; if the processing node receives a query command sent by the master node, performing, according to the structure of the to-be-computed data cube of the processing node, an aggregation operation on a data stream received by the processing node, to generate a data cube; and sending, by the processing node, the data cube to the master node. |
