会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 72. 发明申请
    • Distributed Joint Admission Control And Dynamic Resource Allocation In Stream Processing Networks
    • 流处理网络中的分布式联合接入控制和动态资源分配
    • US20080304516A1
    • 2008-12-11
    • US11758706
    • 2007-06-06
    • Hanhua FengZhen LiuHonghui XiaLi Zhang
    • Hanhua FengZhen LiuHonghui XiaLi Zhang
    • H04J3/16
    • G06F9/5066G06F9/5038
    • Methods and apparatus operating in a stream processing network perform load shedding and dynamic resource allocation so as to meet a pre-determined utility criterion. Load shedding is envisioned as an admission control problem encompassing source nodes admitting workflows into the stream processing network. A primal-dual approach is used to decompose the admission control and resource allocation problems. The admission control operates as a push-and-pull process with sources pushing workflows into the stream processing network and sinks pulling processed workflows from the network. A virtual queue is maintained at each node to account for both queue backlogs and credits from sinks. Nodes of the stream processing network maintain shadow prices for each of the workflows and share congestion information with neighbor nodes. At each node, resources are devoted to the workflow with the maximum product of downstream pressure and processing rate, where the downstream pressure is defined as the backlog difference between neighbor nodes. The primal-dual controller iteratively adjusts the admission rates and resource allocation using local congestion feedback. The iterative controlling procedure further uses an interior-point method to improve the speed of convergence towards optimal admission and allocation decisions.
    • 在流处理网络中操作的方法和装置执行卸载和动态资源分配,以满足预定的效用标准。 负载脱落被设想为包括允许流程处理网络中的工作流的源节点的准入控制问题。 使用原始双重方法来分解入学控制和资源分配问题。 准入控制作为推拉过程进行操作,其中源将工作流推送到流处理网络并且从网络中吸收经处理的工作流。 每个节点都维护一个虚拟队列,以解决队列积压和来自宿的积分。 流处理网络的节点维护每个工作流的影子价格,并与邻居节点共享拥塞信息。 在每个节点,资源用于工作流程,具有下游压力和处理速率的最大乘积,其中下游压力被定义为相邻节点之间的积压差异。 原始双控制器使用局部拥塞反馈迭代地调整入局速率和资源分配。 迭代控制程序进一步使用内点方法来提高收敛速度以达到最佳准入和分配决策。
    • 73. 发明申请
    • Method for Inter-Site Data Stream Transfer in a Cooperative Data Stream Processing
    • 在协同数据流处理中的站点间数据流传输方法
    • US20080256166A1
    • 2008-10-16
    • US11747694
    • 2007-05-11
    • Michael J. BransonFrederick DouglisZhen LiuFan Ye
    • Michael J. BransonFrederick DouglisZhen LiuFan Ye
    • G06F15/16
    • H04L12/4633H04L69/40
    • A cooperative data stream processing system is provided that utilizes a plurality of independent, autonomous and potentially heterogeneous sites in a cooperative arrangement to process user-defined inquiries over dynamic, continuous streams of data. The system derives jobs from the inquiries and these jobs are executed on the various distributed sites by executing applications containing processing elements on these sites. Therefore, components of a given job can be executed simultaneously and in parallel on a plurality of sites within in the system. The sites associated with a given job execution have the need to share data, both primal and derived. A tunnel mechanism is provided that establishes tunnels between pairs of sites within the system. Each tunnel includes either a sink processing element on an originating site and a source processing element on a destination site or a gateway processing element on each site and a network connection between the sink and source processing elements. The sink and source processing elements are in communication with application processing elements on their respective sites and facilitate the exchange of data between these application processing elements. Tunnels can be establish on demand or in accordance with a prescribed plan and can be job specific of generic to any job executing on a given pair of sites.
    • 提供协作数据流处理系统,其利用协作布置中的多个独立的,自主的和潜在的异构站点来处理关于动态的,连续的数据流的用户定义的查询。 系统从查询中导出作业,这些作业通过执行包含这些站点上的处理元素的应用程序在各种分布式站点上执行。 因此,给定作业的组件可以在系统内的多个站点上同时并行地执行。 与给定作业执行相关联的站点需要共享数据,包括原始数据和派生数据。 提供了一种在系统内的站点对之间建立隧道的隧道机制。 每个隧道包括发起站点上的宿处理元件和目的站点上的源处理元件或每个站点上的网关处理元件以及宿和源处理元件之间的网络连接。 宿和源处理元件与其各自站点上的应用处理元件通信,并且便于这些应用处理元件之间的数据交换。 隧道可以根据需要或按照规定的计划建立,并且可以对于在给定的一对站点上执行的任何作业具有通用性。
    • 79. 发明授权
    • Method and apparatus for failure resilient forwarding of data over a computer network
    • 通过计算机网络对数据进行故障恢复转发的方法和装置
    • US07392319B2
    • 2008-06-24
    • US10830779
    • 2004-04-23
    • Zhen LiuSambit SahuJeremy I. Silber
    • Zhen LiuSambit SahuJeremy I. Silber
    • G06F15/16
    • H04L41/0654H04L45/00H04L67/2842H04L67/2852H04L69/16H04L69/163H04L69/165H04L69/40
    • In one embodiment, the present invention is a method and an apparatus for failure-resilient forwarding of data over a computer network. In one embodiment, a marker is introduced into the data stream, e.g., at the sending node, and allows, in turn, forwarding nodes and/or receivers to efficiently track data stream reception. The marker functions as a checkpoint for the data transport process, and is identified and indexed at each forwarding node and receiver. Each receiver saves the marker prior to delivering data to an application, thereby designating a point in the data stream at which all preceding data is confirmed to have been delivered to the application. Thus, if a forwarding node fails, the receiver may request stream data from an alternate forwarding node by specifying to the alternate forwarding node to provide data starting from the marker.
    • 在一个实施例中,本发明是用于在计算机网络上进行数据故障恢复转发的方法和装置。 在一个实施例中,将标记引入数据流,例如在发送节点处,并且允许转发节点和/或接收器以有效地跟踪数据流接收。 标记用作数据传输过程的检查点,并在每个转发节点和接收器处被识别和索引。 每个接收器在将数据传送到应用程序之前保存标记,从而指定数据流中的所有先前数据被确认已被递送到应用的点。 因此,如果转发节点发生故障,则接收方可以通过指定备用转发节点从标记开始提供数据来从备用转发节点请求流数据。