专利快速检索-快速检索全球专利，免费商用专利数据库-IPRDB

1. 发明申请

US20140059210A1 STREAM PROCESSING WITH RUNTIME ADAPTATION 有权
标题翻译：具有运行适应性的流程处理
公开(公告)号：US20140059210A1
公开(公告)日：2014-02-27
申请号：US13594961
申请日：2012-08-27
申请人： Bugra Gedik , Gabriela Jacques da Silva , Vibhore Kumar , Rohit Wagle , Kun-Lung Wu
发明人： Bugra Gedik , Gabriela Jacques da Silva , Vibhore Kumar , Rohit Wagle , Kun-Lung Wu
IPC分类号： G06F15/173
CPC分类号： G06F9/5066 , G06F17/30516 , H04L43/08
摘要： Embodiments of the disclosure include a system for providing stream processing with runtime adaptation, having a stream processing application that receives an incoming data stream and a runtime infrastructure configured to execute the stream processing application. The system also includes an orchestrator configured to communicate with the runtime infrastructure and the stream processing application, the orchestrator configured to perform a method. The method includes registering one or more events, wherein each of the events is associated with a stream processing application. The method also includes monitoring, by a processor, for an occurrence of the one or more events associated with the stream processing application, wherein each of the one or more events is associated with one or more runtime metrics. The method further includes receiving an event notification, wherein the event notification includes event identification and an event context and executing an adaptation of the stream processing application.
摘要翻译：本公开的实施例包括用于提供具有运行时适应的流处理的系统，具有接收输入数据流的流处理应用和被配置为执行流处理应用的运行时基础设施。该系统还包括经配置以与运行时基础设施和流处理应用程序进行通信的协调者，该协调器被配置为执行方法。该方法包括登记一个或多个事件，其中每个事件与流处理应用相关联。该方法还包括由处理器监视与流处理应用相关联的一个或多个事件的发生，其中所述一个或多个事件中的每一个与一个或多个运行时度量相关联。该方法还包括接收事件通知，其中事件通知包括事件识别和事件上下文以及执行流处理应用的适应。

2. 发明授权

US09063788B2 Stream processing with runtime adaptation 有权
标题翻译：流处理与运行时适应
公开(公告)号：US09063788B2
公开(公告)日：2015-06-23
申请号：US13594961
申请日：2012-08-27
申请人： Bugra Gedik , Gabriela Jacques da Silva , Vibhore Kumar , Rohit Wagle , Kun-Lung Wu
发明人： Bugra Gedik , Gabriela Jacques da Silva , Vibhore Kumar , Rohit Wagle , Kun-Lung Wu
IPC分类号： G06F15/16 , G06F9/50 , H04L12/26 , G06F17/30
CPC分类号： G06F9/5066 , G06F17/30516 , H04L43/08
摘要： Embodiments of the disclosure include a system for providing stream processing with runtime adaptation, having a stream processing application that receives an incoming data stream and a runtime infrastructure configured to execute the stream processing application. The system also includes an orchestrator configured to communicate with the runtime infrastructure and the stream processing application, the orchestrator configured to perform a method. The method includes registering one or more events, wherein each of the events is associated with a stream processing application. The method also includes monitoring, by a processor, for an occurrence of the one or more events associated with the stream processing application, wherein each of the one or more events is associated with one or more runtime metrics. The method further includes receiving an event notification, wherein the event notification includes event identification and an event context and executing an adaptation of the stream processing application.
摘要翻译：本公开的实施例包括用于提供具有运行时适应的流处理的系统，具有接收输入数据流的流处理应用和被配置为执行流处理应用的运行时基础设施。该系统还包括经配置以与运行时基础设施和流处理应用程序进行通信的协调者，该协调器被配置为执行方法。该方法包括登记一个或多个事件，其中每个事件与流处理应用相关联。该方法还包括由处理器监视与流处理应用相关联的一个或多个事件的发生，其中所述一个或多个事件中的每一个与一个或多个运行时度量相关联。该方法还包括接收事件通知，其中事件通知包括事件识别和事件上下文以及执行流处理应用的适应。

3. 发明申请

US20140059212A1 STREAM PROCESSING WITH RUNTIME ADAPTATION 审中-公开
标题翻译：具有运行适应性的流程处理
公开(公告)号：US20140059212A1
公开(公告)日：2014-02-27
申请号：US13600294
申请日：2012-08-31
申请人： Bugra Gedik , Gabriela Jacques da Silva , Vibhore Kumar , Rohit Wagle , Kun-Lung Wu
发明人： Bugra Gedik , Gabriela Jacques da Silva , Vibhore Kumar , Rohit Wagle , Kun-Lung Wu
IPC分类号： G06F15/173
CPC分类号： G06F9/5066 , G06F17/30516 , H04L43/08
摘要： Embodiments of the disclosure include a method for providing stream processing with runtime adaptation includes registering one or more events, wherein each of the events is associated with a stream processing application. The method also includes monitoring, by a processor, for an occurrence of the one or more events associated with the stream processing application, wherein each of the one or more events is associated with one or more runtime metrics. The method further includes receiving an event notification, wherein the event notification includes event identification and an event context and executing an adaptation of the stream processing application.
摘要翻译：本公开的实施例包括用于提供具有运行时适应的流处理的方法，包括登记一个或多个事件，其中每个事件与流处理应用相关联。该方法还包括由处理器监视与流处理应用相关联的一个或多个事件的发生，其中所述一个或多个事件中的每一个与一个或多个运行时度量相关联。该方法还包括接收事件通知，其中事件通知包括事件识别和事件上下文以及执行流处理应用的适应。

4. 发明授权

US09075662B2 Stream processing with runtime adaptation 有权
标题翻译：流处理与运行时适应
公开(公告)号：US09075662B2
公开(公告)日：2015-07-07
申请号：US13600294
申请日：2012-08-31
申请人： Bugra Gedik , Gabriela Jacques da Silva , Vibhore Kumar , Rohit Wagle , Kun-Lung Wu
发明人： Bugra Gedik , Gabriela Jacques da Silva , Vibhore Kumar , Rohit Wagle , Kun-Lung Wu
IPC分类号： G06F15/16 , G06F9/50 , H04L12/26 , G06F17/30
CPC分类号： G06F9/5066 , G06F17/30516 , H04L43/08
摘要： Embodiments of the disclosure include a method for providing stream processing with runtime adaptation includes registering one or more events, wherein each of the events is associated with a stream processing application. The method also includes monitoring, by a processor, for an occurrence of the one or more events associated with the stream processing application, wherein each of the one or more events is associated with one or more runtime metrics. The method further includes receiving an event notification, wherein the event notification includes event identification and an event context and executing an adaptation of the stream processing application.
摘要翻译：本公开的实施例包括用于提供具有运行时适应的流处理的方法，包括登记一个或多个事件，其中每个事件与流处理应用相关联。该方法还包括由处理器监视与流处理应用相关联的一个或多个事件的发生，其中所述一个或多个事件中的每一个与一个或多个运行时度量相关联。该方法还包括接收事件通知，其中事件通知包括事件识别和事件上下文以及执行流处理应用的适应。

5. 发明申请

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

6. 发明授权

US08458650B2 Injecting a fault into a stream operator in a data stream processing application 有权
公开(公告)号：US08458650B2
公开(公告)日：2013-06-04
申请号：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 , G06F9/44 , G06F9/45 , G06F11/00
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.

7. 发明授权

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

8. 发明申请

US20100293532A1 FAILURE RECOVERY FOR STREAM PROCESSING APPLICATIONS 有权
标题翻译：流程处理应用失败恢复
公开(公告)号：US20100293532A1
公开(公告)日：2010-11-18
申请号：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分类号： G06F11/07 , G06F9/45
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.
摘要翻译：在一个实施例中，本发明是用于流处理应用的故障恢复的方法和装置。提供用于流处理应用的故障恢复机制的方法的一个实施例包括接收流处理应用的源代码，其中源代码为流处理应用的每个组件定义容错策略，并且其中相应的故障为多个组件中的至少两个组件定义的容限策略是不同的，根据所述多个组件中的至少两个组件生成用于将组件的状态转换成包括可存储位序列的检查点文件的指令序列，在容错策略中定义的频率，启动流处理应用的执行，以及在执行流处理应用期间将检查点文件存储在故障恢复之后可访问的位置。

9. 发明授权

US08499292B2 Virtual execution environment for streaming languages 有权
标题翻译：用于流式传输语言的虚拟执行环境
公开(公告)号：US08499292B2
公开(公告)日：2013-07-30
申请号：US12719364
申请日：2010-03-08
申请人： Henrique Andrade , Jim Challenger , Bugra Gedik , Robert Grimm , Martin J. Hirzel , Vibhore Kumar , Robert Soule , Kun-Lung Wu
发明人： Henrique Andrade , Jim Challenger , Bugra Gedik , Robert Grimm , Martin J. Hirzel , Vibhore Kumar , Robert Soule , Kun-Lung Wu
IPC分类号： G06F9/45
摘要： A virtual execution environment (VEE) for a streaming Intermediate Language (IL), wherein the streaming IL represents a streaming program, communicates streaming data in queues, stores data-at-rest in variables, and determines data by functions, where inputs are read from the queues and the variables, and outputs are written to the queues and the variables.
摘要翻译：用于流式传输中间语言（IL）的虚拟执行环境（VEE），其中流IL表示流式传输程序，在队列中传送流数据，将静态数据存储在变量中，并通过功能确定数据，其中输入被读取从队列和变量，并将输出写入队列和变量。

10. 发明申请

US20110219362A1 Virtual Execution Environment for Streaming Languages 有权
标题翻译：流语言的虚拟执行环境
公开(公告)号：US20110219362A1
公开(公告)日：2011-09-08
申请号：US12719364
申请日：2010-03-08
申请人： Henrique Andrade , Jim Challenger , Bugra Gedik , Robert Grimm , Martin J. Hirzel , Vibhore Kumar , Robert Soule , Kun-Lung Wu
发明人： Henrique Andrade , Jim Challenger , Bugra Gedik , Robert Grimm , Martin J. Hirzel , Vibhore Kumar , Robert Soule , Kun-Lung Wu
IPC分类号： G06F9/45
摘要： A virtual execution environment (VEE) for a streaming Intermediate Language (IL), wherein the streaming IL represents a streaming program, communicates streaming data in queues, stores data-at-rest in variables, and determines data by functions, where inputs are read from the queues and the variables, and outputs are written to the queues and the variables.
摘要翻译：用于流式传输中间语言（IL）的虚拟执行环境（VEE），其中流IL表示流式传输程序，在队列中传送流数据，将静态数据存储在变量中，并通过功能确定数据，其中输入被读取从队列和变量，并将输出写入队列和变量。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式