通过事件流处理集群管理器进行路由管理

    公开(公告)号:CN112540948A

    公开(公告)日:2021-03-23

    申请号:CN202010825616.8

    申请日:2020-08-17

    IPC分类号: G06F15/173

    摘要: 本申请涉及通过事件流处理集群管理器进行路由管理。计算设备管理路由器。基于管理器引擎定义实例化管理器引擎,并基于创建的管理器ESP模型实例化管理器ESPE。基于从管理器配置文件中读取的映射信息创建路由器配置文件,该映射信息描述了事件发布源和管理器ESPE的源窗口之间的连接。基于创建的路由器配置文件实例化路由器引擎。启动连接器以接收基于路由器配置文件的事件。事件是在基于管理器ESP模型处理的管理器ESPE的源窗口中接收的。基于从远程ESP模型定义的多个窗口的每个窗口接收的使用度量,通过路由器引擎选择第三计算设备,该远程ESP模型配置为在接收到已处理事件时进一步处理该已处理的事件。

    事件流处理集群管理器
    2.
    发明授权

    公开(公告)号:CN108419447B

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

    申请号:CN201780004037.3

    申请日:2017-11-16

    摘要: 一种第一计算装置管理事件流处理ESP引擎ESPE的集群。基于从管理器配置文件读取的信息而创建本地ESP模型,所述管理器配置文件包含用以连接到第二计算装置的第一连接信息和用以连接到第三计算装置的第二连接信息。基于所述所创建本地ESP模型而在所述第一计算装置上实例化ESPE。在所述实例化ESPE的第一源窗口中从所述第二计算装置接收事件块对象。向远程第三计算装置部署远程ESP模型。所述管理器配置文件包含所述远程ESP模型的指示符。选择用以接收经处理事件块对象的第三计算装置。将所述经处理事件块对象发布给由向所述第三计算装置部署的所述远程ESP模型定义的第二源窗口。

    用于节点装置基于GPU的并行处理的编译

    公开(公告)号:CN107783782B

    公开(公告)日:2019-03-15

    申请号:CN201710647374.6

    申请日:2017-08-01

    摘要: 本申请涉及用于节点装置基于GPU的并行处理的编译。一种设备可包含处理器以及用以存储指令的存储装置,所述指令致使所述处理器执行包含以下各项的操作:响应于节点装置的GPU可用的确定,确定任务例程是否可经编译以产生用于由所述GPU执行的GPU任务例程,以致使所述任务例程的任务的多个实例至少部分地并行执行而其间不具有相依性;以及响应于所述任务例程能够经编译以产生所述GPU任务例程的确定:采用转换规则以将所述任务例程转换为所述GPU任务例程;编译所述GPU任务例程以用于由所述GPU执行;以及将所述任务关于数据集分区的执行指派于所述节点装置以实现所述多个实例关于所述数据集分区由所述GPU的执行。

    支持事件流处理系统中的故障转移的方法与非暂时性计算机可读媒体以及系统

    公开(公告)号:CN106464746B

    公开(公告)日:2018-11-06

    申请号:CN201580023361.0

    申请日:2015-05-26

    IPC分类号: H04L29/14

    摘要: 在支持事件流处理ESP系统中的故障转移的计算装置中,接收事件块对象。将所述计算装置的第一状态确定为现用或备用。当所述第一状态为现用时,将所述计算装置的第二状态确定为新现用的或非新现用的。当所述计算装置从备用状态切换到现用状态时确定为新现用的。当所述第二状态为新现用时,确定唯一识别上一所发布事件块对象的上一所发布事件块对象识别符。从可由所述计算装置存取的非暂时性计算机可读媒体选择下一事件块对象。所述下一事件块对象具有大于所述所确定上一所发布事件块对象识别符的事件块对象识别符。将所述选定下一事件块对象发布到消息传出网络装置。

    流体回流预测
    7.
    发明公开

    公开(公告)号:CN105408914A

    公开(公告)日:2016-03-16

    申请号:CN201480039993.1

    申请日:2014-10-21

    IPC分类号: G06G7/48

    摘要: 本发明提供一种计算装置,其经配置以确定何时触发针对钻探操作的警报。接收包含在钻探操作的先前连接事件期间针对输入变量而测量的值的经测量的钻探数据。通过使所述经测量的钻探数据作为输入而执行预测模型来确定流体回流测量的预测值。使用包含在第二钻探操作期间针对所述输入变量而测量的多个值的先前钻探数据来确定所述预测模型。所述第二钻探操作是在与所述钻探操作不同的地理井筒位置处的先前钻探操作。将从传感器数据确定的流体回流测量数据与所述流体回流测量的所述经确定的预测值相比较。基于所述比较触发对所述钻探操作的警报。

    与分布式数据库架构并靠的网格计算系统

    公开(公告)号:CN103201740A

    公开(公告)日:2013-07-10

    申请号:CN201180054214.1

    申请日:2011-11-08

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30575

    摘要: 本发明提供用于对存储于分布式数据库系统中的数据执行分析计算的网格计算系统的系统及方法。控制节点处的网格化软件组件经配置以:调用所述控制节点处的数据库管理软件DBMS以致使多个工作者节点处的DBMS使数据可用于在其节点本地的网格化软件组件;指示所述多个工作者节点处的所述网格化软件组件对所接收的数据执行分析计算且将所述数据分析的结果发送到所述控制节点处的所述网格化软件组件;以及汇编由所述多个工作者节点处的所述网格化软件组件执行的所述数据分析的所述结果。