Order-Independent Stream Query Processing
    1.
    发明申请
    Order-Independent Stream Query Processing 有权
    与订单无关的流查询处理

    公开(公告)号:US20110302164A1

    公开(公告)日:2011-12-08

    申请号:US13101967

    申请日:2011-05-05

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30979 G06F17/30516

    摘要: 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.

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