-
公开(公告)号:CN110214318B
公开(公告)日:2023-01-10
申请号:CN201780084279.8
申请日:2017-12-22
Applicant: 微软技术许可有限责任公司
IPC: G06F16/2455
Abstract: 适应特定类型的无序数据;即,在数据无序到达时要适应这种无序数据,因为数据是在可能具有不同应用时间线的系统中生成的。当数据到达时,该数据以特定分区键到达。例如,该分区键可以标识数据源。来自每个分区键的数据相对于来自同一分区键的所有其他数据保持有序。也就是说,与来自任何其他键的数据相比,允许来自一个键的数据具有一个不同的时间线。因此,当跨键全局查看时,数据可能不是有序的。相反,只要到达的数据的滞后在某个容忍滞后范围内,就可以容忍数据全局无序。如果数据到达,具有的时间超过最大容忍延迟,则系统应用某个策略来确定如何处理被延迟的数据。
-
公开(公告)号:CN107438836B
公开(公告)日:2020-08-28
申请号:CN201680020627.0
申请日:2016-04-01
Applicant: 微软技术许可有限责任公司
IPC: G06F9/54 , G06F16/2455 , G06F16/2458 , G06F16/27
Abstract: 描述了一种复杂事件处理器,其具有通信接口,其被配置为通过从一个或多个源拉取事件数据来检索事件数据并且接收被推送到该接口的至少一个实时事件流。连接到通信接口的事件处理管道包括连接在通信接口和组合器节点之间的多个运算符节点,组合器节点是被配置为组合来自源和来自实时事件流的事件数据的节点。通信接口被配置为从源检索事件并将从源检索的事件沿事件处理管道推送到组合器节点。通信接口被配置为仅响应于沿着管道在从组合器节点到通信接口的上游方向上传递的请求消息来检索和推送检索到的事件。
-
公开(公告)号:CN110214318A
公开(公告)日:2019-09-06
申请号:CN201780084279.8
申请日:2017-12-22
Applicant: 微软技术许可有限责任公司
IPC: G06F16/2455
Abstract: 适应特定类型的无序数据;即,在数据无序到达时要适应这种无序数据,因为数据是在可能具有不同应用时间线的系统中生成的。当数据到达时,该数据以特定分区键到达。例如,该分区键可以标识数据源。来自每个分区键的数据相对于来自同一分区键的所有其他数据保持有序。也就是说,与来自任何其他键的数据相比,允许来自一个键的数据具有一个不同的时间线。因此,当跨键全局查看时,数据可能不是有序的。相反,只要到达的数据的滞后在某个容忍滞后范围内,就可以容忍数据全局无序。如果数据到达,具有的时间超过最大容忍延迟,则系统应用某个策略来确定如何处理被延迟的数据。
-
公开(公告)号:CN108885641B
公开(公告)日:2022-03-29
申请号:CN201780021857.3
申请日:2017-03-27
Applicant: 微软技术许可有限责任公司
Inventor: B·钱德拉莫利 , R·卡斯特罗·费尔南德兹 , A·H·夸玛 , A·艾尔达维 , J·D·戈尔德斯泰恩
IPC: G06F16/245 , G06F16/2453 , G06F16/2458
Abstract: 高性能查询处理和数据分析可以跨架构上不同的规模而被执行,诸如单核、多核和/或多节点。高性能查询处理和数据分析可以包括查询计算、密钥化数据、数据移动和并行计算的分离,由此增强查询处理和数据分析的能力,同时允许指定数据并行计算的复杂形式,数据并行计算可以跨实时和离线来执行。如本文所述,数据移动和并行计算的去耦合可以改善查询处理和数据分析速度,可以提供多个计算环境中的搜索的优化,并且可以提供搜索执行计划的更大空间的能力。
-
公开(公告)号:CN107438836A
公开(公告)日:2017-12-05
申请号:CN201680020627.0
申请日:2016-04-01
Applicant: 微软技术许可有限责任公司
Abstract: 描述了一种复杂事件处理器,其具有通信接口,其被配置为通过从一个或多个源拉取事件数据来检索事件数据并且接收被推送到该接口的至少一个实时事件流。连接到通信接口的事件处理管道包括连接在通信接口和组合器节点之间的多个运算符节点,组合器节点是被配置为组合来自源和来自实时事件流的事件数据的节点。通信接口被配置为从源检索事件并将从源检索的事件沿事件处理管道推送到组合器节点。通信接口被配置为仅响应于沿着管道在从组合器节点到通信接口的上游方向上传递的请求消息来检索和推送检索到的事件。
-
公开(公告)号:CN109155763B
公开(公告)日:2022-04-29
申请号:CN201780029092.8
申请日:2017-05-05
Applicant: 微软技术许可有限责任公司
Inventor: B·钱德拉莫利 , J·D·戈尔德斯泰恩 , M·尼科利克
Abstract: 本文描述的技术和系统涉及提供数字信号处理(DSP)操作与通用查询处理器的深度集成。这些技术和系统提供一致的查询语言以用于处理时间关系和信号数据,提供用于定义DSP操作符的机制,以及支持离线和在线分析中的递增计算。这些技术和系统包括接收流数据,聚合和执行统一性处理以生成统一信号,以及以批量列表示存储统一信号。可以将数据从批量列表示复制到循环缓冲器,其中DSP操作被应用于数据。递增处理可以避免冗余处理。通过减少在单独的查询数据库和DSP处理器之间来回传递的数据量,以及通过减少处理和/或存储器使用的等待时间来提供对计算机的功能的改进。
-
公开(公告)号:CN109155763A
公开(公告)日:2019-01-04
申请号:CN201780029092.8
申请日:2017-05-05
Applicant: 微软技术许可有限责任公司
Inventor: B·钱德拉莫利 , J·D·戈尔德斯泰恩 , M·尼科利克
IPC: H04L12/911 , H04L29/08 , G06F16/2453 , H04L12/861
Abstract: 本文描述的技术和系统涉及提供数字信号处理(DSP)操作与通用查询处理器的深度集成。这些技术和系统提供一致的查询语言以用于处理时间关系和信号数据,提供用于定义DSP操作符的机制,以及支持离线和在线分析中的递增计算。这些技术和系统包括接收流数据,聚合和执行统一性处理以生成统一信号,以及以批量列表示存储统一信号。可以将数据从批量列表示复制到循环缓冲器,其中DSP操作被应用于数据。递增处理可以避免冗余处理。通过减少在单独的查询数据库和DSP处理器之间来回传递的数据量,以及通过减少处理和/或存储器使用的等待时间来提供对计算机的功能的改进。
-
公开(公告)号:CN108885641A
公开(公告)日:2018-11-23
申请号:CN201780021857.3
申请日:2017-03-27
Applicant: 微软技术许可有限责任公司
Inventor: B·钱德拉莫利 , R·卡斯特罗·费尔南德兹 , A·H·夸玛 , A·艾尔达维 , J·D·戈尔德斯泰恩
IPC: G06F17/30
CPC classification number: G06F17/30466 , G06F17/30424 , G06F17/30474 , G06F17/30551
Abstract: 高性能查询处理和数据分析可以跨架构上不同的规模而被执行,诸如单核、多核和/或多节点。高性能查询处理和数据分析可以包括查询计算、密钥化数据、数据移动和并行计算的分离,由此增强查询处理和数据分析的能力,同时允许指定数据并行计算的复杂形式,数据并行计算可以跨实时和离线来执行。如本文所述,数据移动和并行计算的去耦合可以改善查询处理和数据分析速度,可以提供多个计算环境中的搜索的优化,并且可以提供搜索执行计划的更大空间的能力。
-
-
-
-
-
-
-