会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 6. 发明申请
    • METHOD AND STREAM PROCESSING SYSTEM FOR MANAGING DATA STREAM PROCESSING TASKS OF A PREDEFINED APPLICATION TOPOLOGY
    • 用于管理预定应用拓扑的数据流处理任务的方法和流处理系统
    • WO2017148503A1
    • 2017-09-08
    • PCT/EP2016/054242
    • 2016-02-29
    • NEC EUROPE LTD.
    • CHENG, BinPAPAGEORGIOU, ApostolosBAUER, Martin
    • G06F9/48G06F9/50
    • G06F9/4881G06F9/4843G06F9/5066G06F9/5083
    • A method for managing data stream processing tasks of a predefined application topology in a stream processing system, wherein said stream processing system comprises one or more data producers, one or more compute nodes and one or more result consumers, wherein geographic scope granularities are assigned to the data stream processing tasks of the application topology, wherein a result consumer sends a subscription to a task manager in order to trigger data processing for computing a result, wherein said subscription includes geographic scope related information concerning the triggered data processing, wherein, based on the geographic scope related information of said subscription, the task manager generates an execution plan including task instances for performing the triggered data processing, and wherein the task manager generates from the execution plan a deployment plan for deploying the task instances of the execution plan on the compute nodes. Furthermore, a corresponding stream processing system is disclosed.
    • 一种用于管理流处理系统中的预定义应用拓扑的数据流处理任务的方法,其中所述流处理系统包括一个或多个数据生成器,一个或多个计算节点以及一个或多个结果消费者 ,其中地理范围粒度被分配给应用拓扑的数据流处理任务,其中结果消费者向任务管理器发送预订以触发用于计算结果的数据处理,其中所述预订包括涉及与地理范围有关的信息 其中,基于所述预订的地理范围相关信息,所述任务管理器生成包括用于执行所触发的数据处理的任务实例的执行计划,并且其中,所述任务管理器从所述执行计划生成用于部署所述触发数据处理的部署计划 计算节点上执行计划的任务实例。 此外,还公开了相应的流处理系统。
    • 8. 发明申请
    • SYSTEMS AND METHODS FOR CACHING TASK EXECUTION
    • 用于缓存任务执行的系统和方法
    • WO2017117216A1
    • 2017-07-06
    • PCT/US2016/068869
    • 2016-12-28
    • TAO, TaoBARDWAJ, SantoshKUMAR, SubodhEUGLEY, Brian
    • TAO, TaoBARDWAJ, SantoshKUMAR, SubodhEUGLEY, Brian
    • G06F9/00G06F9/46G06F9/50
    • G06F9/4881G06F9/5033G06F9/5066H04L67/04H04L67/10H04L67/2842H04L67/32H04L67/322H04L67/327
    • Certain disclosed embodiments provide improved systems and methods for processing jobs. The method comprises steps including receiving, from a client device over a network, information representing a job and generating at least two tasks representative of the job. The method further comprises, for each task, assigning, by a processor, a signature to the task representative of whether the task has been processed, determining at least one dataset related to the task, and assigning a signature to the determined at least one dataset. The method further comprises searching, by the processor, a data structure for the task signature, and based on the searching, sending the task over a network to a task executor for processing or locating results associated with the task. The method further comprises sending, over a network, a job result to the client device. Systems and computer readable media are also provided.
    • 某些公开的实施例提供了用于处理作业的改进的系统和方法。 该方法包括以下步骤:包括通过网络从客户端设备接收表示作业的信息并生成表示作业的至少两个任务。 该方法进一步包括,对于每个任务,由处理器向代表该任务是否已经处理的任务分配签名,确定与该任务相关的至少一个数据集,以及将签名分配给确定的至少一个数据集 。 该方法还包括由处理器搜索任务签名的数据结构,并且基于搜索,通过网络将任务发送给任务执行器,以处理或定位与该任务相关联的结果。 该方法进一步包括通过网络向客户端设备发送作业结果。 还提供系统和计算机可读介质。