知搜-全球专利检索

  1. 登录
  2. 注册

搜索结果

71 条记录 (耗时 0.025 秒)

    FAULT TOLERANCE IN DISTRIBUTED SYSTEMS
    2.
    发明申请
    FAULT TOLERANCE IN DISTRIBUTED SYSTEMS 失效
    分布式系统中的容错

    公开(公告)号：US20120117423A1

    公开(公告)日：2012-05-10

    申请号：US12942326

    申请日：2010-11-09

    申请人： Henrique Andrade ,  Kirsten W. Hildrum ,  Michael J.E. Spicer ,  Chitra Venkatramani ,  Rohit S. Wagle

    发明人： Henrique Andrade ,  Kirsten W. Hildrum ,  Michael J.E. Spicer ,  Chitra Venkatramani ,  Rohit S. Wagle

    IPC分类号： G06F11/07

    CPC分类号： G06F11/1438

    摘要： Fault tolerance is provided in a distributed system. The complexity of replicas and rollback requests are avoided; instead, a local failure in a component of a distributed system is tolerated. The local failure is tolerated by storing state related to a requested operation on the component, persisting that stored state in a data store, such as a relational database, asynchronously processing the operation request, and if a failure occurs, restarting the component using the stored state from the data store.

    摘要翻译： 容错在分布式系统中提供。 避免复制和回滚请求的复杂性; 相反，容忍分布式系统的组件中的本地故障。 通过将与所请求的操作相关的状态存储在组件上，将数据存储器（例如关系数据库）中的存储状态保持为异步处理操作请求，并且如果发生故障，则可以容忍本地故障，使用所存储的重新启动组件 状态从数据存储。

    Tracing Flow of Data in a Distributed Computing Application
    3.
    发明申请
    Tracing Flow of Data in a Distributed Computing Application 失效
    在分布式计算应用程序中跟踪数据流

    公开(公告)号：US20110289301A1

    公开(公告)日：2011-11-24

    申请号：US12785916

    申请日：2010-05-24

    申请人： Paul V. Allen ,  Henrique Andrade ,  Wim De Pauw ,  Bugra Gedik ,  Andy L. Frenkiel ,  Michael Donald Pfeifer

    发明人： Paul V. Allen ,  Henrique Andrade ,  Wim De Pauw ,  Bugra Gedik ,  Andy L. Frenkiel ,  Michael Donald Pfeifer

    IPC分类号： G06F9/30

    CPC分类号： G06F11/3636

    摘要： A method is provided for tracing dataflow in a distributed computing application. For example, the method includes incrementally advancing a dataflow in a dataflow path of one or more dataflow paths according to two or more directives encoded in two or more data messages. The method further includes performing the two or more directives. The dataflow path includes one or more operators including at least one merge operator operative to merge the two or more data messages and merge the two or more directives. One or more of the incrementally advancing of the dataflow and the performing of the two or more directives are implemented as instruction code performed on a processor device.

    摘要翻译： 提供了一种用于在分布式计算应用程序中跟踪数据流的方法。 例如，该方法包括根据在两个或多个数据消息中编码的两个或更多个指令，逐渐前进一个或多个数据流路径的数据流路径中的数据流。 该方法还包括执行两个或更多个指令。 数据流路径包括一个或多个运算符，包括至少一个合并运算符，用于合并两个或多个数据消息并合并两个或多个指令。 数据流的递增推进和两个或多个指令的执行中的一个或多个被实现为在处理器设备上执行的指令代码。

    METHOD OF SELECTING AN EXPRESSION EVALUATION TECHNIQUE FOR DOMAIN-SPECIFIC LANGUAGE COMPILATION
    4.
    发明申请
    METHOD OF SELECTING AN EXPRESSION EVALUATION TECHNIQUE FOR DOMAIN-SPECIFIC LANGUAGE COMPILATION 失效
    选择特定语言编译的表达评估技术的方法

    公开(公告)号：US20110246972A1

    公开(公告)日：2011-10-06

    申请号：US12749947

    申请日：2010-03-30

    申请人： Henrique Andrade ,  Bugra Gedik ,  Mark Mendell ,  Howard W. Nasgaard ,  Kun-Lung Wu

    发明人： Henrique Andrade ,  Bugra Gedik ,  Mark Mendell ,  Howard W. Nasgaard ,  Kun-Lung Wu

    IPC分类号： G06F9/45

    CPC分类号： G06F9/45516 ,  G06F8/51

    摘要： A method and computer program product for selecting an expression evaluation technique for domain-specific language (DSL) compilation. An application written in DSL for a programming task is provided, the application including a plurality of components configured by expressions. A technique that most quickly implements the programming task is selected from a plurality of techniques for evaluating the expressions. The DSL application is compiled in accordance with the selected expression evaluation technique to generate general-purpose programming language (GPL) code.

    摘要翻译： 一种用于选择域特定语言（DSL）编译的表达评估技术的方法和计算机程序产品。 提供了一种用DSL编写的用于编程任务的应用程序，该应用程序包括由表达式配置的多个组件。 从用于评估表达式的多种技术中选择最快速地实现编程任务的技术。 DSL应用程序根据所选择的表达式评估技术进行编译，以生成通用编程语言（GPL）代码。

    PARTIAL FAULT TOLERANT STREAM PROCESSING APPLICATIONS
    5.
    发明申请
    PARTIAL FAULT TOLERANT STREAM PROCESSING APPLICATIONS 有权
    部分容错流程处理应用

    公开(公告)号：US20110239048A1

    公开(公告)日：2011-09-29

    申请号：US12748633

    申请日：2010-03-29

    申请人： HENRIQUE ANDRADE ,  Bugra Gedik ,  Gabriela Jacques da Silva ,  Kun-Lung Wu

    发明人： HENRIQUE ANDRADE ,  Bugra Gedik ,  Gabriela Jacques da Silva ,  Kun-Lung Wu

    IPC分类号： G06F11/28

    CPC分类号： G06F11/28 ,  G06F11/3612 ,  G06F11/3616

    摘要： In one embodiment, the invention comprises partial fault tolerant stream processing applications. One embodiment of a method for implementing partial fault tolerance in a stream processing application comprising a plurality of stream operators includes: defining a quality score function that expresses how well the application is performing quantitatively, injecting a fault into at least one of the plurality of operators, assessing an impact of the fault on the quality score function, and selecting at least one partial fault-tolerant technique for implementation in the application based on the quantitative metric-driven assessment.

    摘要翻译： 在一个实施例中，本发明包括部分容错流处理应用。 用于在包括多个流操作器的流处理应用中实现部分容错的方法的一个实施例包括：定义表示应用程序在定量上执行良好的质量得分函数，将故障注入多个操作符中的至少一个 评估故障对质量得分函数的影响，以及基于定量度量驱动评估，选择至少一种部分容错技术在应用中实现。

    Rules-Based Cross-FSM Transition Triggering
    7.
    发明申请
    Rules-Based Cross-FSM Transition Triggering 失效
    基于规则的跨FSM转换触发

    公开(公告)号：US20100100518A1

    公开(公告)日：2010-04-22

    申请号：US12252515

    申请日：2008-10-16

    申请人： Henrique Andrade ,  James Robert Harold Challenger ,  Louis Ralph Degenaro

    发明人： Henrique Andrade ,  James Robert Harold Challenger ,  Louis Ralph Degenaro

    IPC分类号： G06N5/02

    CPC分类号： G06N5/025

    摘要： A method for cross-triggering transitions in independent finite state machines is provided. For a given plurality of finite state machine definitions having a plurality of states and a plurality of transitions among the states, two or more independent instances of the plurality of finite state machine definitions are created. In addition, associations between two or more of the independent finite state machine instances are identified. The method uses cross-triggering rules that identify a condition in a first one of the associated independent finite state machine instances that triggers a transition action in a second one of the associated independent finite state machine instances. Each cross-triggering rule is triggered upon an occurrence of the cross-triggering rule condition, and the transition action in the second associated independent finite state machine instance is performed in response to the triggering of the cross-triggering rule.

    摘要翻译： 提供了一种在独立有限状态机中交叉触发转换的方法。 对于具有多个状态和状态之间的多个转换的给定多个有限状态机定义，创建多个有限状态机定义的两个或多个独立实例。 另外，确定了两个或多个独立的有限状态机实例之间的关联。 该方法使用交叉触发规则，其识别在相关联的独立有限状态机实例中的第一个条件中触发相关联的独立有限状态机实例中的第二个中的转换动作的条件。 每个交叉触发规则在交叉触发规则条件发生时被触发，并且响应于触发交叉触发规则执行第二关联的独立有限状态机实例中的转换动作。

    METHOD AND SYSTEM FOR PREDICTING RESOURCE USAGE OF REUSABLE STREAM PROCESSING ELEMENTS
    8.
    发明申请
    METHOD AND SYSTEM FOR PREDICTING RESOURCE USAGE OF REUSABLE STREAM PROCESSING ELEMENTS 有权
    用于预测资源使用可回收流程处理元素的方法和系统

    公开(公告)号：US20090119238A1

    公开(公告)日：2009-05-07

    申请号：US11935079

    申请日：2007-11-05

    申请人： Lisa Amini ,  Henrique Andrade ,  Wei Fan ,  James R. Giles ,  Kirsten W. Hildrum ,  Deepak Rajan ,  Deepak S. Turaga ,  Rohit Wagle ,  Joel L. Wolf ,  Philip S. Yu

    发明人： Lisa Amini ,  Henrique Andrade ,  Wei Fan ,  James R. Giles ,  Kirsten W. Hildrum ,  Deepak Rajan ,  Deepak S. Turaga ,  Rohit Wagle ,  Joel L. Wolf ,  Philip S. Yu

    IPC分类号： G06N5/04

    CPC分类号： G06N99/005

    摘要： A method is provided for generating a resource function estimate of resource usage by an instance of a processing element configured to consume zero or more input data streams in a stream processing system having a set of available resources that comprises receiving at least one specified performance metric for the zero or more input data streams and a processing power of the set of available resources, wherein one specified performance metric is stream rate; generating a multi-part signature of executable-specific information for the processing element and a multi-part signature of context-specific information for the instance; accessing a database of resource functions to identify a static resource function corresponding to the executable-specific information and a context-dependent resource function corresponding to the context-specific information; combining the static resource function and the context-dependent resource function to form a composite resource function for the instance; and applying the resource function to the at least one specified performance metric and the processing power to generate the resource function estimate of the at least one specified performance metric for processing by the instance.

    摘要翻译： 提供了一种用于通过被配置为在具有一组可用资源的流处理系统中消耗零个或多个输入数据流的处理元件的实例来生成资源使用的资源功能估计的方法，所述流处理系统包括：一组可用资源，其包括接收至少一个指定的性能度量 零个或多个输入数据流和可用资源集合的处理能力，其中一个指定的性能度量是流速率; 生成用于处理元件的可执行特定信息的多部分签名和该实例的上下文特定信息的多部分签名; 访问资源功能的数据库以识别与所述可执行特定信息相对应的静态资源功能以及与所述上下文特定信息相对应的与上下文相关的资源功能; 结合静态资源功能和上下文相关资源功能，形成实例的复合资源功能; 以及将所述资源功能应用于所述至少一个指定的性能度量和所述处理能力以生成所述至少一个指定的性能度量的所述资源功能估计，以供所述实例处理。

    Method and system for supporting dynamic stream attributes
    9.
    发明申请
    Method and system for supporting dynamic stream attributes 有权
    支持动态流属性的方法和系统

    公开(公告)号：US20070280381A1

    公开(公告)日：2007-12-06

    申请号：US11445889

    申请日：2006-06-01

    申请人： Lisa Amini ,  Henrique Andrade ,  Yoonho Park ,  Philippe Selo ,  Chitra Venkatramani

    发明人： Lisa Amini ,  Henrique Andrade ,  Yoonho Park ,  Philippe Selo ,  Chitra Venkatramani

    IPC分类号： H03D1/00 ,  H04L27/06

    CPC分类号： H04L67/2804

    摘要： A publisher-subscriber system includes a broker configured to receive and distribute at least one data stream from publishers to subscribers in accordance with subscriptions. An annotator/classifier is configured to annotate or classify the data stream by employing one or more additional stream-level attributes to create an annotated data stream wherein the annotated data stream applies the stream-level attribute to all messages therein such that subscribers can subscribe to the annotated data stream created by the annotator/classifier.

    摘要翻译： 发布者订户系统包括被配置为根据订阅从发布者接收和分发至少一个数据流的代理。 注释器/分类器被配置为通过使用一个或多个附加流级别属性来创建注释数据流来对数据流进行注释或分类，其中注释的数据流将流级属性应用于其中的所有消息，使得用户可以订阅 由注释器/分类器创建的注释数据流。

    Failure recovery for stream processing applications
    10.
    发明授权
    Failure recovery for stream processing applications 有权
    流处理应用程序的故障恢复

    公开(公告)号：US08949801B2

    公开(公告)日：2015-02-03

    申请号：US12465215

    申请日：2009-05-13

    申请人： Henrique Andrade ,  Bugra Gedik ,  Gabriela Jacques da Silva ,  Kun-Lung Wu

    发明人： Henrique Andrade ,  Bugra Gedik ,  Gabriela Jacques da Silva ,  Kun-Lung Wu

    IPC分类号： G06F9/45 ,  G06F11/14 ,  G06F11/07 ,  G06F11/00

    CPC分类号： G06F11/1438 ,  G06F11/00 ,  G06F11/07 ,  G06F11/1471

    摘要： In one embodiment, the invention is a method and apparatus for failure recovery for stream processing applications. One embodiment of a method for providing a failure recovery mechanism for a stream processing application includes receiving source code for the stream processing application, wherein the source code defines a fault tolerance policy for each of the components of the stream processing application, and wherein respective fault tolerance policies defined for at least two of the plurality of components are different, generating a sequence of instructions for converting the state(s) of the component(s) into a checkpoint file comprising a sequence of storable bits on a periodic basis, according to a frequency defined in the fault tolerance policy, initiating execution of the stream processing application, and storing the checkpoint file, during execution of the stream processing application, at a location that is accessible after failure recovery.

    摘要翻译： 在一个实施例中，本发明是用于流处理应用的故障恢复的方法和装置。 提供用于流处理应用的故障恢复机制的方法的一个实施例包括接收流处理应用的源代码，其中源代码为流处理应用的每个组件定义容错策略，并且其中相应的故障 为多个组件中的至少两个组件定义的容限策略是不同的，根据所述多个组件中的至少两个组件生成用于将组件的状态转换成包括可存储位序列的检查点文件的指令序列， 在容错策略中定义的频率，启动流处理应用的执行，以及在执行流处理应用期间将检查点文件存储在故障恢复之后可访问的位置。