公开(公告)号：US20140012877A1

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

申请号：US13936922

申请日：2013-07-08

Applicant: Cisco Technology, Inc.

Inventor： Saileshwar Krishnamurthy ,  Michael R. Lewis ,  Wing Li ,  Neil Thombre ,  Jeffrey A. Davis ,  Daniel Robert Farina

IPC: G06F17/30

CPC classification number: G06F17/30979 ,  G06F17/30516

Abstract: In a system and method for order-independent stream query processing, one or more input streams of data are received, and the one or more input streams are analyzed to determine data which is older than an already emitted progress indicator. The data which is older than the already emitted progress indicator is partitioned into one or more partitions, and each of the one or more partitions are independently processed using out-of-order processing techniques. A query is received, rewritten and decomposed into one or more sub-queries that produce partial results for each of the one or more partitions, where each of the one or more sub-queries correspond to a partition. A view is also produced that consolidates the partial results for each partition. The partial results are consolidated at a consolidation time specified by the query to produce final results, and the final results are provided.

Abstract translation: 在用于与秩序无关的流查询处理的系统和方法中，接收一个或多个输入数据流，并且分析一个或多个输入流以确定比已经发射的进度指示符更早的数据。 比已经发射的进度指示符更老的数据被分割成一个或多个分区，并且使用无序处理技术来独立地处理一个或多个分区中的每一个。 查询被接收，重写并分解成一个或多个子查询，其产生针对一个或多个分区中的每个分区的部分结果，其中一个或多个子查询中的每一个对应于分区。 还会生成一个整合每个分区的部分结果的视图。 部分结果在查询指定的合并时间内合并，以生成最终结果，并提供最终结果。

公开(公告)号：US08972446B2

公开(公告)日：2015-03-03

申请号：US13936922

申请日：2013-07-08

Applicant: Cisco Technology, Inc.

Inventor： Saileshwar Krishnamurthy ,  Michael R. Lewis ,  Wing Li ,  Neil Thombre ,  Jeffrey A. Davis ,  Daniel Robert Farina

IPC: G06F17/30

CPC classification number: G06F17/30979 ,  G06F17/30516

Abstract: In a system and method for order-independent stream query processing, one or more input streams of data are received, and the one or more input streams are analyzed to determine data which is older than an already emitted progress indicator. The data which is older than the already emitted progress indicator is partitioned into one or more partitions, and each of the one or more partitions are independently processed using out-of-order processing techniques. A query is received, rewritten and decomposed into one or more sub-queries that produce partial results for each of the one or more partitions, where each of the one or more sub-queries correspond to a partition. A view is also produced that consolidates the partial results for each partition. The partial results are consolidated at a consolidation time specified by the query to produce final results, and the final results are provided.

Abstract translation: 在用于与秩序无关的流查询处理的系统和方法中，接收一个或多个输入数据流，并且分析一个或多个输入流以确定比已经发射的进度指示符更早的数据。 比已经发射的进度指示符更老的数据被分割成一个或多个分区，并且使用无序处理技术来独立地处理一个或多个分区中的每一个。 查询被接收，重写并分解成一个或多个子查询，其产生针对一个或多个分区中的每个分区的部分结果，其中一个或多个子查询中的每一个对应于分区。 还会生成一个整合每个分区的部分结果的视图。 部分结果在查询指定的合并时间内合并，以生成最终结果，并提供最终结果。