-
公开(公告)号：CN110214318B
公开(公告)日：2023-01-10
申请号：CN201780084279.8
申请日：2017-12-22
Applicant: 微软技术许可有限责任公司
IPC: G06F16/2455
Abstract: 适应特定类型的无序数据；即，在数据无序到达时要适应这种无序数据，因为数据是在可能具有不同应用时间线的系统中生成的。当数据到达时，该数据以特定分区键到达。例如，该分区键可以标识数据源。来自每个分区键的数据相对于来自同一分区键的所有其他数据保持有序。也就是说，与来自任何其他键的数据相比，允许来自一个键的数据具有一个不同的时间线。因此，当跨键全局查看时，数据可能不是有序的。相反，只要到达的数据的滞后在某个容忍滞后范围内，就可以容忍数据全局无序。如果数据到达，具有的时间超过最大容忍延迟，则系统应用某个策略来确定如何处理被延迟的数据。
-
公开(公告)号：CN107438836A
公开(公告)日：2017-12-05
申请号：CN201680020627.0
申请日：2016-04-01
Applicant: 微软技术许可有限责任公司
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: 适应特定类型的无序数据；即，在数据无序到达时要适应这种无序数据，因为数据是在可能具有不同应用时间线的系统中生成的。当数据到达时，该数据以特定分区键到达。例如，该分区键可以标识数据源。来自每个分区键的数据相对于来自同一分区键的所有其他数据保持有序。也就是说，与来自任何其他键的数据相比，允许来自一个键的数据具有一个不同的时间线。因此，当跨键全局查看时，数据可能不是有序的。相反，只要到达的数据的滞后在某个容忍滞后范围内，就可以容忍数据全局无序。如果数据到达，具有的时间超过最大容忍延迟，则系统应用某个策略来确定如何处理被延迟的数据。
-
-
-
Search Results
4
records
(took 0.023 seconds)
