公开(公告)号：US09239864B2

公开(公告)日：2016-01-19

申请号：US13865054

申请日：2013-04-17

Applicant: Cisco Technology, Inc.

Inventor： Saileshwar Krishnamurthy ,  Madhu Kumar ,  Amit Bhat ,  Maciek Sakrejda ,  Robert Allen Lerche

IPC: G06F17/30

CPC classification number: G06F17/30445 ,  G06F17/30516

Abstract: In an embodiment, a method for distributing and processing streams over wide area networks comprises receiving, at a unified data processing node, a continuous query; determining a parallel portion of the continuous query; sending the parallel portion to a plurality of distributed data processing nodes located in a plurality of data centers; at each distributed node in the plurality of distributed nodes, locally executing the parallel portion against independent data partitions, producing a partial summary data, sending the partial summary data to the unified node; continuously receiving, at the unified node, in real-time, the partial summary data.

Abstract translation: 在一个实施例中，一种用于在广域网上分发和处理流的方法包括在统一数据处理节点处接收连续查询; 确定连续查询的并行部分; 将并行部分发送到位于多个数据中心中的多个分布式数据处理节点; 在多个分布式节点中的每个分布式节点处，针对独立数据分区本地执行并行部分，产生部分摘要数据，将该部分摘要数据发送到统一节点; 在统一节点连续接收实时的部分摘要数据。

公开(公告)号：US20130275452A1

公开(公告)日：2013-10-17

申请号：US13865054

申请日：2013-04-17

Applicant: CISCO TECHNOLOGY, INC

Inventor： Saileshwar Krishnamurthy ,  Madhu Kumar ,  Amit Bhat ,  Maciek Sakrejda ,  Robert Allen Lerche

IPC: G06F17/30

CPC classification number: G06F17/30445 ,  G06F17/30516

Abstract: In an embodiment, a method for distributing and processing streams over wide area networks comprises receiving, at a unified data processing node, a continuous query; determining a parallel portion of the continuous query; sending the parallel portion to a plurality of distributed data processing nodes located in a plurality of data centers; at each distributed node in the plurality of distributed nodes, locally executing the parallel portion against independent data partitions, producing a partial summary data, sending the partial summary data to the unified node; continuously receiving, at the unified node, in real-time, the partial summary data.

Abstract translation: 在一个实施例中，一种用于在广域网上分发和处理流的方法包括在统一数据处理节点处接收连续查询; 确定连续查询的并行部分; 将并行部分发送到位于多个数据中心中的多个分布式数据处理节点; 在多个分布式节点中的每个分布式节点处，针对独立数据分区本地执行并行部分，产生部分摘要数据，将该部分摘要数据发送到统一节点; 在统一节点连续接收实时的部分摘要数据。