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

1. 发明授权

US08125984B2 Method, system, and computer program product for implementing stream processing using a reconfigurable optical switch 有权
标题翻译：用于使用可重构光开关实现流处理的方法，系统和计算机程序产品
公开(公告)号：US08125984B2
公开(公告)日：2012-02-28
申请号：US12052814
申请日：2008-03-21
申请人： James R. Giles , Nagui Halim , Kirsten W. Hildrum , Daniel M. Kuchta , Yoonho Park , Deepak Rajan , Laurent Schares , Eugen Schenfeld , Phillippe L. Selo , Marc Taubenblatt , Rohit Wagle , Joel L. Wolf , Xiaolan J. Zhang
发明人： James R. Giles , Nagui Halim , Kirsten W. Hildrum , Daniel M. Kuchta , Yoonho Park , Deepak Rajan , Laurent Schares , Eugen Schenfeld , Phillippe L. Selo , Marc Taubenblatt , Rohit Wagle , Joel L. Wolf , Xiaolan J. Zhang
IPC分类号： H04L12/66
CPC分类号： H04L41/0816 , H04L67/125
摘要： A method, system, and computer program product for implementing stream processing are provided. The system includes an application framework and applications containing dataflow graphs managed by the application framework running on a first network. The system also includes at least one circuit switch in the first network having a configuration that is controlled by the application framework, a plurality of processing nodes interconnected by the first network over one of wireline and wireless links, and a second network for providing at least one of control and additional data transfer over the first network. The application framework reconfigures circuit switches in response to monitoring aspects of the applications and the first network.
摘要翻译：提供了一种用于实现流处理的方法，系统和计算机程序产品。该系统包括一个应用程序框架和包含由在第一个网络上运行的应用程序框架管理的数据流图的应用程序。该系统还包括第一网络中的至少一个电路交换机，其具有由应用框架控制的配置，由有线和无线链路之一由第一网络互连的多个处理节点以及用于至少提供至少通过第一个网络进行控制和附加数据传输之一。响应于应用和第一网络的监控方面，应用框架重新配置电路交换机。

2. 发明申请

US20090241123A1 METHOD, APPARATUS, AND COMPUTER PROGRAM PRODUCT FOR SCHEDULING WORK IN A STREAM-ORIENTED COMPUTER SYSTEM WITH CONFIGURABLE NETWORKS 有权
标题翻译：在具有可配置网络的面向流行的计算机系统中调度工作的方法，装置和计算机程序产品
公开(公告)号：US20090241123A1
公开(公告)日：2009-09-24
申请号：US12052836
申请日：2008-03-21
申请人： Nikhil Bansal , Kirsten W. Hildrum , James Giles , Deepak Rajan , Philippe L. Seto , Eugen Schenfeld , Rohit Wagle , Joel L. Wolf , Xiaolan J. Zhang
发明人： Nikhil Bansal , Kirsten W. Hildrum , James Giles , Deepak Rajan , Philippe L. Seto , Eugen Schenfeld , Rohit Wagle , Joel L. Wolf , Xiaolan J. Zhang
IPC分类号： G06F9/50
CPC分类号： G06F9/5066 , G06F9/4881 , G06F2209/483 , H04L67/325
摘要： A method, apparatus, and computer program product for scheduling stream-based applications in a distributed computer system with configurable networks are provided. The method includes choosing, at a highest temporal level, jobs that will run, an optimal template alternative for the jobs that will run, network topology, and candidate processing nodes for processing elements of the optimal template alternative for each running job to maximize importance of work performed by the system. The method further includes making, at a medium temporal level, fractional allocations and re-allocations of the candidate processing elements to the processing nodes in the system to react to changing importance of the work. The method also includes revising, at a lowest temporal level, the fractional allocations and re-allocations on a continual basis to react to burstiness of the work, and to differences between projected and real progress of the work.
摘要翻译：提供了一种用于在具有可配置网络的分布式计算机系统中调度基于流的应用的方法，装置和计算机程序产品。该方法包括在最高时间级别选择将运行的作业，用于将运行的作业的最佳模板替代物，网络拓扑和候选处理节点，用于处理每个正在运行的作业的最佳模板替代物的元素以最大化重要性系统执行的工作。该方法还包括在中等时间级别将候选处理元件的分数分配和重新分配到系统中的处理节点，以对工作的不断变化的重要性作出反应。该方法还包括在最低时间级别修改分数分配和连续重新分配以对工作的突发性作出反应，以及对工作的预测和实际进展之间的差异进行修改。

3. 发明授权

US08595732B2 Reducing the response time of flexible highly data parallel task by assigning task sets using dynamic combined longest processing time scheme 失效
标题翻译：通过使用动态组合最长处理时间方案分配任务集，减少灵活高度并行任务的响应时间
公开(公告)号：US08595732B2
公开(公告)日：2013-11-26
申请号：US12946475
申请日：2010-11-15
申请人： Kirsten W. Hildrum , Rohit M. Khandekar , Vibhore Kumar , Sujay S. Parekh , Deepak Rajan , Joel L. Wolf , Kun-Lung Wu
发明人： Kirsten W. Hildrum , Rohit M. Khandekar , Vibhore Kumar , Sujay S. Parekh , Deepak Rajan , Joel L. Wolf , Kun-Lung Wu
IPC分类号： G06F15/16
CPC分类号： G06F9/4881
摘要： A method for scheduling a data processing job includes receiving the data processing job formed of a plurality of computing units, combining the plurality of computing units into a plurality of sets of tasks, each set including tasks of about equal estimated size, and different sets having different sized tasks, and assigning the tasks to a plurality of processors using a dynamic longest processing time (DLPT) scheme.
摘要翻译：一种用于调度数据处理作业的方法包括：接收由多个计算单元组成的数据处理作业，将多个计算单元组合成多组任务，每组任务包括约等于估计大小的任务，以及具有不同大小的任务，以及使用动态最长处理时间（DLPT）方案将任务分配给多个处理器。

4. 发明授权

US08473783B2 Fault tolerance in distributed systems 失效
标题翻译：分布式系统容错
公开(公告)号：US08473783B2
公开(公告)日：2013-06-25
申请号：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/00
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.
摘要翻译：容错在分布式系统中提供。避免复制和回滚请求的复杂性; 相反，容忍分布式系统的组件中的本地故障。通过将与所请求的操作相关的状态存储在组件上，将数据存储器（例如关系数据库）中的存储状态保持为异步处理操作请求，并且如果发生故障，则可以容忍本地故障，使用所存储的重新启动组件状态从数据存储。

5. 发明申请

US20120304188A1 Scheduling Flows in a Multi-Platform Cluster Environment 有权
标题翻译：在多平台集群环境中调度流程
公开(公告)号：US20120304188A1
公开(公告)日：2012-11-29
申请号：US13116368
申请日：2011-05-26
申请人： Andrey Balmin , Anshul Dawra , Kirsten W. Hildrum , Rohit M. Khandekar , Deepak Rajan , Joel L. Wolf
发明人： Andrey Balmin , Anshul Dawra , Kirsten W. Hildrum , Rohit M. Khandekar , Deepak Rajan , Joel L. Wolf
IPC分类号： G06F9/46
CPC分类号： G06F9/52 , G06F9/5016 , G06F9/5077 , G06F2209/5014 , G06F2209/504 , Y02D10/22
摘要： Techniques for scheduling multiple flows in a multi-platform cluster environment are provided. The techniques include partitioning a cluster into one or more platform containers associated with one or more platforms in the cluster, scheduling one or more flows in each of the one or more platform containers, wherein the one or more flows are created as one or more flow containers, scheduling one or more individual jobs into the one or more flow containers to create a moldable schedule of one or more jobs, flows and platforms, and automatically converting the moldable schedule into a malleable schedule.
摘要翻译：提供了在多平台集群环境中调度多个流的技术。这些技术包括将集群划分成与集群中的一个或多个平台相关联的一个或多个平台容器，调度一个或多个平台容器中的每个平台容器中的一个或多个流，其中，一个或多个流被创建为一个或多个流容器，将一个或多个单独作业调度到所述一个或多个流动容器中，以创建一个或多个作业，流动和平台的可模制计划，以及将可模制计划自动转换成可延展的计划。

6. 发明授权

US08484649B2 Amortizing costs of shared scans 失效
标题翻译：摊销共享扫描成本
公开(公告)号：US08484649B2
公开(公告)日：2013-07-09
申请号：US12984909
申请日：2011-01-05
申请人： Kirsten W. Hildrum , Rohit M. Khandekar , Sujay S. Parekh , Deepak Rajan , Joel L. Wolf , Kun-Lung Wu
发明人： Kirsten W. Hildrum , Rohit M. Khandekar , Sujay S. Parekh , Deepak Rajan , Joel L. Wolf , Kun-Lung Wu
IPC分类号： G06F9/46
CPC分类号： G06F9/4843
摘要： Techniques for scheduling a plurality of jobs sharing input are provided. The techniques include partitioning one or more input datasets into multiple subcomponents, analyzing a plurality of jobs to determine which of the plurality of jobs require scanning of one or more common subcomponents of the one or more input datasets, and scheduling a plurality of jobs that require scanning of one or more common subcomponents of the one or more input datasets, facilitating a single scanning of the one or more common subcomponents to be used as input by each of the plurality of jobs.
摘要翻译：提供了用于调度多个作业共享输入的技术。这些技术包括将一个或多个输入数据集划分成多个子组件，分析多个作业以确定多个作业中的哪个作业需要扫描一个或多个输入数据集的一个或多个公共子组件，以及调度需要扫描所述一个或多个输入数据集中的一个或多个通用子部件，便于对所述一个或多个公共子部件进行单次扫描以用作多个作业中的每个作业的输入。

7. 发明申请

US20120304186A1 Scheduling Mapreduce Jobs in the Presence of Priority Classes 审中-公开
标题翻译：在优先课程中安排Mapreduce工作
公开(公告)号：US20120304186A1
公开(公告)日：2012-11-29
申请号：US13116378
申请日：2011-05-26
申请人： Andrey Balmin , Kirsten W. Hildrum , Rohit M. Khandekar , Deepak Rajan , Joel L. Wolf
发明人： Andrey Balmin , Kirsten W. Hildrum , Rohit M. Khandekar , Deepak Rajan , Joel L. Wolf
IPC分类号： G06F9/46 , G06F9/50
CPC分类号： G06F9/46 , G06F9/4881 , G06F9/50
摘要： Techniques for scheduling one or more MapReduce jobs in a presence of one or more priority classes are provided. The techniques include obtaining a preferred ordering for one or more MapReduce jobs, wherein the preferred ordering comprises one or more priority classes, prioritizing the one or more priority classes subject to one or more dynamic minimum slot guarantees for each priority class, and iteratively employing a MapReduce scheduler, once per priority class, in priority class order, to optimize performance of the one or more MapReduce jobs.
摘要翻译：提供了在存在一个或多个优先级类别的情况下调度一个或多个MapReduce作业的技术。这些技术包括获得一个或多个MapReduce作业的优选顺序，其中优选顺序包括一个或多个优先级等级，对于每个优先级类别，受限于一个或多个动态最小时隙保证的一个或多个优先级类别进行优先级排序，并迭代地使用 MapReduce调度程序每优先级一次，按优先级顺序排列，以优化一个或多个MapReduce作业的性能。

8. 发明申请

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

9. 发明申请

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

10. 发明授权

US08930954B2 Scheduling parallel data tasks 有权
标题翻译：调度并行数据任务
公开(公告)号：US08930954B2
公开(公告)日：2015-01-06
申请号：US12853925
申请日：2010-08-10
申请人： Kirsten W. Hildrum , Rohit M. Khandekar , Vibhore Kumar , Sujay S. Parekh , Deepak Rajan , Joel L. Wolf , Kun-Lung Wu
发明人： Kirsten W. Hildrum , Rohit M. Khandekar , Vibhore Kumar , Sujay S. Parekh , Deepak Rajan , Joel L. Wolf , Kun-Lung Wu
IPC分类号： G06F9/46 , G06F9/48
CPC分类号： G06F9/50 , G06F9/46 , G06F9/4881 , G06F9/4887 , G06F9/5038 , G06F2209/483
摘要： A method for allocating parallel, independent, data tasks includes receiving data tasks, each of the data tasks having a penalty function, determining a generic ordering of the data tasks according to the penalty functions, wherein the generic ordering includes solving an aggregate objective function of the penalty functions, the method further including determining a schedule of the data tasks given the generic ordering, which packs the data tasks to be performed.
摘要翻译：一种用于分配并行，独立的数据任务的方法包括接收数据任务，每个数据任务具有惩罚功能，根据惩罚函数确定数据任务的通用排序，其中通用排序包括解决总体目标函数所述惩罚功能，所述方法还包括确定给定所述通用排序的数据任务的调度，其对要执行的数据任务进行打包。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式