事件流变换
    5.
    发明公开

    公开(公告)号:CN106664322A

    公开(公告)日:2017-05-10

    申请号:CN201580046306.3

    申请日:2015-08-25

    Abstract: 制定对一个或多个输入事件流的变换以生成一个或多个输出事件流。因此,变换可以被认为是对一个或多个原始输入事件流的查询。事件查询包括表示在特定执行上下文中可用的输入事件流的事件流源表示。事件查询还包括变换模块,该变换模块标识要对执行上下文中的输入事件流执行的变换集。一旦查询被正确地形成,执行模块然后就可以使得对一个或多个指定的输入事件流执行变换以生成输出事件流。

    针对事件流处理的增强型锚协议

    公开(公告)号:CN112805978A

    公开(公告)日:2021-05-14

    申请号:CN201980063775.4

    申请日:2019-06-26

    Abstract: 本文中描述了用于针对流处理的启动和/或恢复的系统和方法。在启动阶段期间:各自标识特定时间的(多个)启动锚请求被累积,直到来自下游节点的(多个)请求未决。所累积的(多个)启动锚请求的最小时间被确定。如果处理系统是输入节点,则与所确定的最小时间相关联的锚被生成。否则,标识所确定的最小时间的启动锚请求被提供给上游节点。一旦与所确定的最小时间相关联的锚被接收到(或生成),锚就响应于来自下游节点的、针对所确定的最小值的所轮询的启动锚请求锚而被提供。在恢复阶段期间,针对由两个特定锚界定的成批数据的异步请求根据被存储在有序锚集合中的信息而被执行。

    用于增强的事件处理的构造的数据流

    公开(公告)号:CN107077477B

    公开(公告)日:2021-01-01

    申请号:CN201580049531.2

    申请日:2015-09-14

    Abstract: 本文中描述的实施例涉及用于增强的事件处理的方法和系统。增强的事件处理请求被接收,增强的处理请求包括来自数据库数据源的输入数据的指示。在增强的事件处理请求中指示的输入数据使用构造的数据流而被访问。构造的数据流提供对数据库数据源的数据库数据随时间的快照的集合的访问。来自构造的数据流源的数据可以根据所选择的值和所选择的时间而被访问。构造的数据流数据包括数据库数据不可获得的时间元素,该时间元素有助于使用构造的数据流数据为数据库数据执行增强的事件处理。针对增强的事件处理请求的输出基于使用构造的数据流数据访问的输入数据而被生成。

    受限的存储器环境中的流式传输联接

    公开(公告)号:CN107690616A

    公开(公告)日:2018-02-13

    申请号:CN201680032699.7

    申请日:2016-06-03

    Abstract: 流式传输联接中可能消耗大量的存储器,因为来自一个流的事件在等待来自第二流的匹配事件时被保持在存储器中。通过分析联接条件以确定两个流中的事件之间时间差异的边界,可以减少存储器需求。当确定来自一个流的事件必须在来自另一流的匹配事件之前发生时,可以以有意延迟来摄取稍后到达的流数据。当确定不管从第一流接收的输入如何,当没有来自第二流的输入时,将不会产生输出,则从第一流拉取数据可以停止。可以采用多阶段的联接计划,使得可以以增大的有意延迟量来扫描不太繁忙的流。仅存储不匹配的数据。

    受限的存储器环境中的流式传输联接

    公开(公告)号:CN107690616B

    公开(公告)日:2020-08-07

    申请号:CN201680032699.7

    申请日:2016-06-03

    Abstract: 流式传输联接中可能消耗大量的存储器,因为来自一个流的事件在等待来自第二流的匹配事件时被保持在存储器中。通过分析联接条件以确定两个流中的事件之间时间差异的边界,可以减少存储器需求。当确定来自一个流的事件必须在来自另一流的匹配事件之前发生时,可以以有意延迟来摄取稍后到达的流数据。当确定不管从第一流接收的输入如何,当没有来自第二流的输入时,将不会产生输出,则从第一流拉取数据可以停止。可以采用多阶段的联接计划,使得可以以增大的有意延迟量来扫描不太繁忙的流。仅存储不匹配的数据。

Patent Agency Ranking