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

11. 发明授权

US08656403B2 Negotiation management in data processing systems 失效
标题翻译：数据处理系统中的谈判管理
公开(公告)号：US08656403B2
公开(公告)日：2014-02-18
申请号：US12112142
申请日：2008-04-30
申请人： Bo An , Frederick Douglis , Bradley William Fawcett , Anton V. Riabov , Fan Ye
发明人： Bo An , Frederick Douglis , Bradley William Fawcett , Anton V. Riabov , Fan Ye
IPC分类号： G06F9/46
CPC分类号： G06F9/5038 , G06F2209/5014 , G06F2209/506
摘要： Techniques are disclosed for optimizing schedules used in implementing plans for performing tasks in data processing systems. For example, an automated method of negotiating for resources in a data processing system, wherein the data processing system comprises multiple sites, comprises a negotiation management component of a computer system at a given one of the sites performing the following steps. One or more tasks from at least one source of one or more plans are obtained. Each plan is annotated with one or more needed resources and one or more potential resource providers at one or more sites in the data processing system. An optimized resource negotiation schedule based on the one or more obtained tasks is computed. The schedule comprises an order in which resources are negotiated. In accordance with the optimized resource negotiation schedule, a request for each needed resource is sent to the one or more potential resource providers such that a negotiation process is performed between the negotiation management component and at least one of the potential resource providers.
摘要翻译：公开了用于优化用于在数据处理系统中执行任务的计划中使用的计划的技术。例如，在数据处理系统中协商资源的自动化方法，其中所述数据处理系统包括多个站点，包括在执行以下步骤的给定一个站点处的计算机系统的协商管理组件。获得来自一个或多个计划的至少一个来源的一个或多个任务。每个计划在数据处理系统中的一个或多个站点上用一个或多个所需资源和一个或多个潜在资源提供者进行注释。计算基于一个或多个获得的任务的优化的资源协商调度。时间表包括协商资源的顺序。根据优化的资源协商进度，向所述一个或多个潜在资源提供者发送对每个所需资源的请求，使得在协商管理组件和潜在资源提供者中的至少一个之间执行协商过程。

12. 发明授权

US08417762B2 Mechanism for execution of multi-site jobs in a data stream processing system 失效
标题翻译：在数据流处理系统中执行多站点作业的机制
公开(公告)号：US08417762B2
公开(公告)日：2013-04-09
申请号：US11747813
申请日：2007-05-11
申请人： Michael J. Branson , Frederick Douglis , Fan Ye
发明人： Michael J. Branson , Frederick Douglis , Fan Ye
IPC分类号： G06F15/16 , G06F15/00
CPC分类号： G06F11/203 , G06F9/5027 , G06F11/1438 , G06F11/1446 , G06F2209/5017 , G06F2209/508 , H04L69/40
摘要： A cooperative data stream processing system utilizing a plurality of independent, autonomous and heterogeneous sites in a cooperative arrangement process user-defined job requests over dynamic, continuous streams of data. A distributed plan is created that identifies the processing elements that constitute a job that is derived from user-defined inquiries. These processing elements are arranged into subjobs that are mapped to various sites within the system for execution. The jobs are executed across the plurality of distributed sites in accordance with the distributed plan. The distributed plan also includes requirements for monitoring and back-up of the execution sites in the event of a failure on one of those sites. Execution of the jobs in accordance with the distributed plan is facilitated by the identification of an owner site to which the distributed plan is communicated and which is responsible for driving the execution of the distributed plan.
摘要翻译：在协作安排过程中利用多个独立的，自主的和异构的站点的协作数据流处理系统用户定义的作业通过动态的，连续的数据流请求。创建一个分布式计划，标识构成从用户定义的查询导出的作业的处理元素。这些处理元件被布置成被映射到系统内的各个站点以执行的子对象。根据分布式计划，这些作业在多个分布式站点之间执行。分布式计划还包括在其中一个站点发生故障时监视和备份执行站点的要求。通过识别分配的计划被传达的所有者站点以及负责驱动分布式计划的执行来促进按照分布式计划执行作业。

13. 发明授权

US08219848B2 Mechanism for recovery from site failure in a stream processing system 有权
标题翻译：在流处理系统中从站点故障恢复的机制
公开(公告)号：US08219848B2
公开(公告)日：2012-07-10
申请号：US11733724
申请日：2007-04-10
申请人： Michael John Branson , Frederick Douglis , Bradley William Fawcett , Zhen Liu , Bin Rong , Fan Ye
发明人： Michael John Branson , Frederick Douglis , Bradley William Fawcett , Zhen Liu , Bin Rong , Fan Ye
IPC分类号： G06F11/00
CPC分类号： G06F11/2025 , G06F11/2048 , G06F11/2097
摘要： A failure recovery framework to be used in cooperative data stream processing is provided that can be used in a large-scale stream data analysis environment. Failure recovery supports a plurality of independent distributed sites, each having its own local administration and goals. The distributed sites cooperate in an inter-site back-up mechanism to provide for system recovery from a variety of failures within the system. Failure recovery is both automatic and timely through cooperation among sites. Back-up sites associated with a given primary site are identified. These sites are used to identify failures within the primary site including failures of applications running on the nodes of the primary site. The failed applications are reinstated on one or more nodes within the back-up sites using job management instances local to the back-up sites in combination with previously stored state information and data values for the failed applications. In additions to inter-site mechanisms, each one of the plurality of sites employs an intra-site back-up mechanism to handle failure recoveries within the site.
摘要翻译：提供了可用于协作数据流处理的故障恢复框架，可用于大规模流数据分析环境。故障恢复支持多个独立的分布式站点，每个都有自己的本地管理和目标。分布式站点在站点间备份机制中进行协作，以便从系统内的各种故障提供系统恢复。故障恢复是通过站点之间的合作自动和及时的。识别与给定主要站点相关联的备用站点。这些站点用于识别主站点中的故障，包括在主站点的节点上运行的应用程序的故障。使用备份站点本地的作业管理实例以及先前存储的状态信息和失败应用程序的数据值，在备份站点中的一个或多个节点上恢复失败的应用程序。除了站点间机制之外，多个站点中的每一个都采用站内备用机制来处理站点内的故障恢复。

14. 发明授权

US09537747B2 Publish/subscribe overlay network control system 有权
标题翻译：发布/订阅覆盖网络控制系统
公开(公告)号：US09537747B2
公开(公告)日：2017-01-03
申请号：US12814426
申请日：2010-06-11
申请人： Kyriakos Karenos , Minkyong Kim , Hui Lei , Hao Yang , Fan Ye , Liangzhao Zeng
发明人： Kyriakos Karenos , Minkyong Kim , Hui Lei , Hao Yang , Fan Ye , Liangzhao Zeng
IPC分类号： H04L12/709 , H04L12/751 , H04L12/707 , H04L12/715 , H04L29/08
CPC分类号： H04L45/02 , H04L41/046 , H04L41/12 , H04L45/24 , H04L45/245 , H04L45/64 , H04L67/02
摘要： A system may include an overlay network linking a plurality of publishers, a plurality of subscribers, and a plurality of brokers. The overlay network may include a first computer network having a first network protocol carried by a second computer network having a second network protocol. The system may also include an agent carried by each of the publishers, the subscribers, and the brokers that adjust the network's topology based upon collected runtime data of condition of each link within the network and/or broker availability to any publisher and subscriber.
摘要翻译：系统可以包括链接多个发布者，多个订户和多个经纪人的覆盖网络。覆盖网络可以包括具有由具有第二网络协议的第二计算机网络承载的第一网络协议的第一计算机网络。系统还可以包括由发布者，订户和经纪人承担的代理，所述代理基于收集的网络中每个链路的条件的收集的运行时间数据和/或经纪人对任何发布者和订户的可用性来调整网络的拓扑。

15. 发明授权

US08627333B2 Message queuing with flexible consistency options 有权
标题翻译：消息排队具有灵活的一致性选项
公开(公告)号：US08627333B2
公开(公告)日：2014-01-07
申请号：US13197461
申请日：2011-08-03
申请人： Han Chen , Minkyong Kim , Hui Lei , Fan Ye
发明人： Han Chen , Minkyong Kim , Hui Lei , Fan Ye
IPC分类号： G06F3/00
CPC分类号： G06F9/546 , G06F2209/548
摘要： Embodiments of the invention relate to message queuing. In one embodiment, a request from an application for retrieving a message from a queue is received. The queue is stored across multiple nodes of a distributed storage system. A preference with respect to message order and message duplication associated with the queue is identified. A message sequence index associated with the queue is sampled based on the preference that has been identified. The message is selected in response to the sampling. The message that has been selected is made unavailable to other applications for a given interval of time, while maintaining the message in the queue. The message is sent to the application.
摘要翻译：本发明的实施例涉及消息队列。在一个实施例中，接收来自应用程序的来自队列检索消息的请求。队列存储在分布式存储系统的多个节点上。识别与队列相关联的消息顺序和消息复制的偏好。基于已经识别的偏好，对与队列相关联的消息序列索引进行采样。选择该消息以响应采样。已经选择的消息在给定的时间间隔内对其他应用程序不可用，同时将消息保留在队列中。该消息被发送到应用程序。

16. 发明申请

US20130275569A1 Scalable Common Infrastructure for Information Collection from Networked Devices 有权
公开(公告)号：US20130275569A1
公开(公告)日：2013-10-17
申请号：US13447936
申请日：2012-04-16
申请人： Seraphin Bernard Calo , Raheleh B. Dilmaghani , Douglas M. Freimuth , Raghu K. Ganti , Keith William Grueneberg , Fan Ye
发明人： Seraphin Bernard Calo , Raheleh B. Dilmaghani , Douglas M. Freimuth , Raghu K. Ganti , Keith William Grueneberg , Fan Ye
IPC分类号： G06F15/173
CPC分类号： H04L29/06 , H04L29/08072 , H04L67/22 , H04W4/00
摘要： A common infrastructure collects diverse data and information from large numbers of mobile devices and traditional sensors at Internet scale to support multiple different applications simultaneously. The infrastructure includes a backend phenomenon layer that provides high level abstractions to applications such that they can express their data and information needs in a declarative fashion and coordinate the data collection and processing activities for all applications. An edge layer that manages devices, receives collection requirements from the backend layer, configures and instructs devices for data collection, and conducts aggregation and primitive processing of the data. This layer contains network edge nodes, such as base stations in a cellular network. Each node manages a set of local data generating networked devices. The device agent data layer using common agents on the data generating networked devices receives data collection instructions from the edge layer, performs data collection.

17. 发明申请

US20110125921A1 SYSTEM AND METHOD FOR PROVIDING QUALITY OF SERVICE IN WIDE AREA MESSAGING FABRIC 失效
标题翻译：提供宽域服务质量的系统和方法消息传递
公开(公告)号：US20110125921A1
公开(公告)日：2011-05-26
申请号：US12625437
申请日：2009-11-24
申请人： Kyriakos Karenos , Minkyong Kim , Hui Lei , Dimitrios Pendarakis , Hao Yang , Fan Ye
发明人： Kyriakos Karenos , Minkyong Kim , Hui Lei , Dimitrios Pendarakis , Hao Yang , Fan Ye
IPC分类号： G06F15/173
CPC分类号： H04L45/00 , H04L45/24 , H04L45/302
摘要： Techniques for transmitting data according to at least one quality of service requirement. A message path is calculated specifying a sequence of broker computers selected from a network of interconnected broker computers. The message path is statistically estimated to fulfill the at least one quality of service requirement. Quality of service metrics are received about the network of interconnected broker computers. If the message path is determined not to fulfill the quality of service requirement, a new message path is calculated specifying a new sequence of broker computers selected from the network of interconnected broker computers. The new message path is statistically estimated to fulfill the at least one quality of service requirement.
摘要翻译：根据至少一种服务质量要求传输数据的技术。计算消息路径，指定从互连代理计算机的网络中选择的代理计算机的序列。统计估计消息路径以满足至少一个服务质量要求。收到关于互联经纪电脑网络的服务质量指标。如果消息路径被确定为不满足服务质量要求，则计算新的消息路径，指定从互连代理计算机的网络中选择的新的代理计算机序列。统计估计新消息路径以满足至少一个服务质量要求。

18. 发明授权

US07849069B2 Method and system for federated resource discovery service in distributed systems 失效
标题翻译：分布式系统中联合资源发现服务的方法和系统
公开(公告)号：US07849069B2
公开(公告)日：2010-12-07
申请号：US11471981
申请日：2006-06-21
申请人： Zhen Liu , Hao Yang , Fan Ye
发明人： Zhen Liu , Hao Yang , Fan Ye
IPC分类号： G06F17/30
CPC分类号： G06F17/30545
摘要： Resources disposed within a plurality of distributed and autonomous computing systems, each of which may have its own legacy resource discovery service, are identified and allocated. Resource identification servers disposed within each one of the distributed computing systems communicate resource attribute data to a tree hierarchy of dedicated servers. The resource attribute data are maintained in native formats within the distributed computing systems and are mapped to a common format provided by the dedicated servers. The resource attribute data are aggregated at each node within the tree hierarchy, communicated up through the tree hierarchy to one or more root nodes and replicated down through all of the nodes. Additional system robustness is provided through period resource checks and resource attribute data updates. Resource allocation queries are submitted to any level node within the hierarchy and forwarded to the proper computing system for processing.
摘要翻译：分配在多个分布式和自主的计算系统中的资源，每个计算系统中的每一个可以具有其自己的传统资源发现服务。布置在每个分布式计算系统内的资源识别服务器将资源属性数据传送到专用服务器的树层。资源属性数据以分布式计算系统内的本机格式进行维护，并映射到由专用服务器提供的通用格式。资源属性数据在树层次结构中的每个节点进行聚合，通过树层次结构传递到一个或多个根节点，并通过所有节点进行复制。通过周期资源检查和资源属性数据更新来提供额外的系统稳健性。资源分配查询被提交到层次结构中的任何级节点，并转发到正确的计算系统进行处理。

19. 发明授权

US09218220B2 Elastic and scalable publish/subscribe service 有权
标题翻译：弹性和可扩展的发布/订阅服务
公开(公告)号：US09218220B2
公开(公告)日：2015-12-22
申请号：US13613183
申请日：2012-09-13
申请人： Han Chen , Minkyong Kim , Hui Lei , Ming Li , Fan Ye
发明人： Han Chen , Minkyong Kim , Hui Lei , Ming Li , Fan Ye
IPC分类号： G06F15/16 , G06F9/50 , H04L29/08
CPC分类号： G06F9/5083 , H04L67/1008 , H04L67/18 , H04L67/26
摘要： A system and method are disclosed for an elastic and scalable publish/subscribe scheme. Subscription information is received at a dispatcher node. A plurality of matching nodes is selected in an overlay network to store the subscription information on a computer readable storage medium. Upon receiving an event at a dispatching node, at least one of the matching nodes with the stored subscription information is selected to process the event.
摘要翻译：公开了用于弹性和可扩展的发布/订阅方案的系统和方法。在分配器节点处接收订阅信息。在覆盖网络中选择多个匹配节点以将订阅信息存储在计算机可读存储介质上。在调度节点接收到事件时，选择具有存储的订阅信息的匹配节点中的至少一个来处理该事件。

20. 发明授权

US07506011B2 System and apparatus for optimally trading off the replication overhead and consistency level in distributed applications 失效
标题翻译：用于最佳地折中分布式应用程序中的复制开销和一致性级别的系统和设备
公开(公告)号：US07506011B2
公开(公告)日：2009-03-17
申请号：US11493373
申请日：2006-07-26
申请人： Zhen Liu , Honghui Xia , Hao Yang , Fan Ye
发明人： Zhen Liu , Honghui Xia , Hao Yang , Fan Ye
IPC分类号： G06F17/30
CPC分类号： G06F17/30578 , Y10S707/99932 , Y10S707/99953 , Y10S707/99955
摘要： Methods and systems are provided for optimally trading off replication overhead and consistency levels in distributed data replication where nodes are organized in a hierarchy. The root node has the original data that need to be replicated at all other nodes, and the replicated copies have a freshness threshold that must be satisfied. The data are propagated through periodic updates in the hierarchy. Each node periodically sends data to its child nodes. Given the freshness threshold, an algorithm and its distributed protocol can determine the optimal update period for each link of the hierarchy such that the freshness threshold is satisfied for every node and the overall replication overhead is minimized. The systems and methods can be used in any scenario where replicated data have consistency requirements, such as in a replicate overlay assisted resource discovery system.
摘要翻译：提供了方法和系统，用于最佳地折中分布式数据复制中的复制开销和一致性级别，其中节点被组织在层次结构中。根节点具有需要在所有其他节点进行复制的原始数据，并且复制副本具有必须满足的新鲜度阈值。数据通过层次结构中的定期更新进行传播。每个节点周期性地向其子节点发送数据。给定新鲜度阈值，算法及其分布式协议可以确定层次结构的每个链路的最佳更新周期，使得每个节点满足新鲜度阈值，并将整体复制开销最小化。系统和方法可以在复制数据具有一致性要求的任何情况下使用，例如在复制覆盖辅助资源发现系统中。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式