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

1. 发明授权

US09098350B2 Adaptive auto-pipelining for stream processing applications 有权
标题翻译：用于流处理应用的自适应自适应流水线
公开(公告)号：US09098350B2
公开(公告)日：2015-08-04
申请号：US13669968
申请日：2012-11-06
申请人： International Business Machines Corporation
发明人： Bugra Gedik , Scott A. Schneider , Yuzhe Tang , Kun-Lung Wu
IPC分类号： G06F9/46 , G06F9/50
CPC分类号： G06F9/5083 , G06F9/505 , G06F2209/5022 , G06F2209/508
摘要： An embodiment of the invention provides a method for adaptive auto-pipelining of a stream processing application, wherein the stream processing application includes one or more threads. Runtime of the stream processing application is initiated with a stream processing application manager. The stream processing application is monitored with a monitoring module during the runtime, wherein the monitoring of the stream processing application includes identifying threads in the stream processing application that execute operators in a data flow graph, and determining an amount of work that each of the threads are performing on operators of the logical data flow graph. A processor identifies one or more operators in the data flow graph to add one or more additional threads based on the monitoring of the stream processing application during the runtime.
摘要翻译：本发明的实施例提供了一种用于流处理应用的自适应自动流水线化的方法，其中流处理应用包括一个或多个线程。流处理应用程序的运行时间由流处理应用程序管理器启动。流程处理应用程序在运行时间期间由监控模块进行监控，其中流处理应用程序的监视包括识别流处理应用程序中执行数据流图中运算符的线程，以及确定每个线程的工作量在逻辑数据流图的运算符上执行。处理器识别数据流图中的一个或多个运算符，以在运行时期间基于流处理应用的监视来添加一个或多个附加线程。

2. 发明申请

US20140101668A1 Adaptive Auto-Pipelining for Stream Processing Applications 审中-公开
标题翻译：适用于流处理应用的自动流水线
公开(公告)号：US20140101668A1
公开(公告)日：2014-04-10
申请号：US13669968
申请日：2012-11-06
申请人： INTERNATIONAL BUSINESS MACHINES CORPORATION
发明人： Bugra Gedik , Scott A. Schneider , Yuzhe Tang , Kun-Lung Wu
IPC分类号： G06F9/46
CPC分类号： G06F9/5083 , G06F9/505 , G06F2209/5022 , G06F2209/508
摘要： An embodiment of the invention provides a method for adaptive auto-pipelining of a stream processing application, wherein the stream processing application includes one or more threads. Runtime of the stream processing application is initiated with a stream processing application manager. The stream processing application is monitored with a monitoring module during the runtime, wherein the monitoring of the stream processing application includes identifying threads in the stream processing application that execute operators in a data flow graph, and determining an amount of work that each of the threads are performing on operators of the logical data flow graph. A processor identifies one or more operators in the data flow graph to add one or more additional threads based on the monitoring of the stream processing application during the runtime.
摘要翻译：本发明的实施例提供了一种用于流处理应用的自适应自动流水线化的方法，其中流处理应用包括一个或多个线程。流处理应用程序的运行时间由流处理应用程序管理器启动。流程处理应用程序在运行时间期间由监控模块进行监控，其中流处理应用程序的监视包括识别流处理应用程序中执行数据流图中运算符的线程，以及确定每个线程的工作量在逻辑数据流图的运算符上执行。处理器识别数据流图中的一个或多个运算符，以在运行时期间基于流处理应用的监视来添加一个或多个附加线程。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式