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

61. 发明授权

US07698106B2 System and method for benchmarking correlated stream processing systems 失效
标题翻译：用于基准相关流处理系统的系统和方法
公开(公告)号：US07698106B2
公开(公告)日：2010-04-13
申请号：US11926208
申请日：2007-10-29
申请人： Kay S. Anderson , Joseph P. Bigus , Eric Bouillet , Parijat Dube , Zhen Liu , Dimitrios Pendarakis
发明人： Kay S. Anderson , Joseph P. Bigus , Eric Bouillet , Parijat Dube , Zhen Liu , Dimitrios Pendarakis
IPC分类号： G06F11/30 , G06F11/00
CPC分类号： G06F11/263
摘要： A system, method, and computer program product for benchmarking a stream processing system are disclosed. The method comprises generating a plurality of correlated test streams. A semantically related data set is embedded within each of the test streams in the plurality of correlated test streams. The plurality of correlated test streams is provided to at least one stream processing system. A summary is generated for each of the semantically related embedded data sets. A common identifier, which is transparent to the system being tested, is embedded within each stream in the plurality of correlated test streams. The common identifier is extracted from the output data set generated by the stream processing system. At least one of the stored copies of the summaries and the common identifier are compared to an output data set including a set of zero or more correlation results generated by the stream processing system.
摘要翻译：公开了一种用于基准流处理系统的系统，方法和计算机程序产品。该方法包括生成多个相关测试流。语义相关的数据集嵌入在多个相关测试流中的每个测试流内。多个相关测试流被提供给至少一个流处理系统。为每个语义相关的嵌入式数据集生成一个摘要。对被测系统透明的公共标识符嵌入在多个相关测试流中的每个流内。从流处理系统生成的输出数据集中提取公共标识符。将总结的存储副本和公共标识符中的至少一个与包括由流处理系统生成的一组零个或多个相关结果的输出数据集进行比较。

62. 发明授权

US07650529B2 Data replica selector 有权
标题翻译：数据副本选择器
公开(公告)号：US07650529B2
公开(公告)日：2010-01-19
申请号：US12145540
申请日：2008-06-25
申请人： Jinliang Fan , Zhen Liu , Dimitrios Pendarakis
发明人： Jinliang Fan , Zhen Liu , Dimitrios Pendarakis
IPC分类号： G06F11/00
CPC分类号： H04L67/1095 , G06F11/202 , G06F11/2053 , H04L67/18 , H04L69/40 , H04W4/02
摘要： There is provided a method and system for replicating data at another location. The system includes a source node that contains data in a data storage area. The source node is coupled to a network of potential replication nodes. The processor determines at least two eligible nodes in the network of nodes and determines the communication cost associated with a each of the eligible nodes. The processor also determines a probability of a concurrent failure of the source node and each of eligible nodes, and selects at least one of the eligible nodes for replication of the data located on the source node. The selection is based on the determined communication costs and probability of concurrent failure.
摘要翻译：提供了在另一个位置复制数据的方法和系统。该系统包括在数据存储区域中包含数据的源节点。源节点耦合到潜在复制节点的网络。处理器确定节点网络中的至少两个合格节点，并确定与每个合格节点相关联的通信成本。处理器还确定源节点和每个合格节点的并发故障的概率，并且选择至少一个合格节点用于复制位于源节点上的数据。选择是基于确定的通信成本和并发故障的概率。

63. 发明申请

US20090300183A1 Distributed Joint Admission Control and Dynamic Resource Allocation in Stream Processing Networks 失效
标题翻译：流处理网络中的分布式联合接纳控制和动态资源分配
公开(公告)号：US20090300183A1
公开(公告)日：2009-12-03
申请号：US12535805
申请日：2009-08-05
申请人： Hanhua Feng , Zhen Liu , Honghui Xia , Li Zhang
发明人： Hanhua Feng , Zhen Liu , Honghui Xia , Li Zhang
IPC分类号： G06F15/173 , G06F15/16
CPC分类号： G06F9/5066 , G06F9/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.
摘要翻译：在流处理网络中操作的方法和装置执行卸载和动态资源分配，以满足预定的效用标准。负载脱落被设想为包括允许流程处理网络中的工作流的源节点的准入控制问题。使用原始双重方法来分解入学控制和资源分配问题。准入控制作为推拉过程进行操作，其中源将工作流推送到流处理网络并且从网络中吸收经处理的工作流。每个节点都维护一个虚拟队列，以解决队列积压和来自宿的积分。流处理网络的节点维护每个工作流的影子价格，并与邻居节点共享拥塞信息。在每个节点，资源用于工作流程，具有下游压力和处理速率的最大乘积，其中下游压力被定义为相邻节点之间的积压差异。原始双控制器使用局部拥塞反馈迭代地调整入局速率和资源分配。迭代控制程序进一步使用内点方法来提高收敛速度以达到最佳准入和分配决策。

64. 发明申请

US20090265718A1 METHOD AND SYSTEM FOR DYNAMIC SOFTWARE RECONFIGURATION TRIGGERED BY COMPONENT- OR SYSTEM- INITIATED EVENTS 有权
标题翻译：通过组件或系统启动事件触发的动态软件重新配置的方法和系统
公开(公告)号：US20090265718A1
公开(公告)日：2009-10-22
申请号：US12106757
申请日：2008-04-21
申请人： Zhen Liu , Anton V. Riabov
发明人： Zhen Liu , Anton V. Riabov
IPC分类号： G06F13/00
CPC分类号： G06F8/60 , G06F8/30 , G06Q10/04 , G06Q10/06
摘要： A method for handling events in compositional applications represented as processing graphs, including: receiving an event notification; modifying a planning domain according to the event notification; generating a new processing graph for a previously deployed processing graph by using the modified planning domain; determining if the new processing graph is different than the previously deployed processing graph; and if the processing graphs are different: reconfiguring the previously deployed processing graph to match the new processing graph; or deploying the new processing graph and replacing the previously deployed processing graph with the newly deployed processing graph.
摘要翻译：用于处理表示为处理图的组成应用中的事件的方法，包括：接收事件通知; 根据事件通知修改规划域; 通过使用修改的规划域为先前部署的处理图生成新的处理图; 确定新处理图是否与先前部署的处理图不同; 并且如果处理图不同：重新配置先前部署的处理图以匹配新的处理图; 或部署新的处理图，并用新部署的处理图替换以前部署的处理图。

65. 发明申请

US20090177910A1 METHOD OF RECOVERING FROM SOFTWARE FAILURES USING REPLANNING 有权
标题翻译：从软件故障中恢复的方法
公开(公告)号：US20090177910A1
公开(公告)日：2009-07-09
申请号：US11971056
申请日：2008-01-08
申请人： Zhen Liu , Anton V. Riabov
发明人： Zhen Liu , Anton V. Riabov
IPC分类号： G06F11/07
CPC分类号： G06F11/3664 , G06F11/3672
摘要： A method for recovering from software failures, includes: receiving failure information that identifies a failing component of a first processing graph; modifying a planning domain that includes a plurality of component descriptions according to the failure information; and composing a second processing graph by using the modified planning domain so that the second processing graph does not include the failing component.
摘要翻译：一种用于从软件故障中恢复的方法包括：接收识别第一处理图的故障组件的故障信息; 根据故障信息修改包括多个组件描述的规划域; 以及通过使用修改的规划域来构成第二处理图，使得第二处理图不包括故障组件。

66. 发明申请

US20090055890A1 SYSTEM AND METHOD FOR SECURITY PLANNING WITH HARD SECURITY CONSTRAINTS 失效
标题翻译：具有硬件安全约束的安全规划系统和方法
公开(公告)号：US20090055890A1
公开(公告)日：2009-02-26
申请号：US12130243
申请日：2008-05-30
申请人： Kay Schwendimann Anderson , Pau-Chen Cheng , Genady Ya. Grabarnik , Paul Ashley Karger , Marc Lelarge , Zhen Liu , Anton Viktotovich Riabov , Pankai Rohatgi , Angela Marie Schuett , Grant Wagner
发明人： Kay Schwendimann Anderson , Pau-Chen Cheng , Genady Ya. Grabarnik , Paul Ashley Karger , Marc Lelarge , Zhen Liu , Anton Viktotovich Riabov , Pankai Rohatgi , Angela Marie Schuett , Grant Wagner
IPC分类号： G06F21/00
CPC分类号： H04L63/10 , H04L63/20
摘要： A method for security planning with hard security constraints includes: receiving security-related requirements of a network to be developed using system inputs and processing components; and generating the network according to the security-related requirements, wherein the network satisfies hard security constraints.
摘要翻译：具有硬安全约束的安全规划方法包括：使用系统输入和处理组件接收要开发的网络的安全相关需求; 并根据安全性要求生成网络，其中网络满足严格的安全约束。

67. 发明申请

US20090024358A1 BENCHMARKING CORRELATED STREAM PROCESSING SYSTEMS 失效
标题翻译：基准相关流程处理系统
公开(公告)号：US20090024358A1
公开(公告)日：2009-01-22
申请号：US12140418
申请日：2008-06-17
申请人： KAY S. ANDERSON , Joseph P. Bigus , Eric Bouillet , Parijat Dube , Zhen Liu , Dimitrios Pendarakis
发明人： KAY S. ANDERSON , Joseph P. Bigus , Eric Bouillet , Parijat Dube , Zhen Liu , Dimitrios Pendarakis
IPC分类号： G06F15/00
CPC分类号： G06F11/263
摘要： A system, method, and computer program product for benchmarking a stream processing system are disclosed. The method comprises generating a plurality of correlated test streams. A semantically related data set is embedded within each of the test streams in the plurality of correlated test streams. The plurality of correlated test streams is provided to at least one stream processing system. A summary is generated for each of the semantically related embedded data sets. A common identifier, which is transparent to the system being tested, is embedded within each stream in the plurality of correlated test streams. The common identifier is extracted from the output data set generated by the stream processing system. At least one of the stored copies of the summaries and the common identifier are compared to an output data set including a set of zero or more correlation results generated by the stream processing system.
摘要翻译：公开了一种用于基准流处理系统的系统，方法和计算机程序产品。该方法包括生成多个相关测试流。语义相关的数据集嵌入在多个相关测试流中的每个测试流内。多个相关测试流被提供给至少一个流处理系统。为每个语义相关的嵌入式数据集生成一个摘要。对被测系统透明的公共标识符嵌入在多个相关测试流中的每个流内。从流处理系统生成的输出数据集中提取公共标识符。将总结的存储副本和公共标识符中的至少一个与包括由流处理系统生成的一组零个或多个相关结果的输出数据集进行比较。

68. 发明授权

US07466656B2 Method, apparatus and program storage device for efficient construction of network overlays through interconnection topology embedding 失效
标题翻译：方法，设备和程序存储设备，通过互连拓扑嵌入有效地构建网络覆盖
公开(公告)号：US07466656B2
公开(公告)日：2008-12-16
申请号：US10973329
申请日：2004-10-26
申请人： Parijat Dube , Zhen Liu , Dimitrios Pendarakis , George V. Popescu
发明人： Parijat Dube , Zhen Liu , Dimitrios Pendarakis , George V. Popescu
IPC分类号： H04L12/26
CPC分类号： H04L41/12 , H04L41/22 , H04L67/104 , H04L67/1044 , H04L67/1089 , H04L67/16
摘要： Methods, apparatuses and program storage devices for constructing a network overlay via embedding an interconnection network in a network overlay graph are provided herein. The network delay distances between pairs of overlay nodes are measured on the shortest network paths. The mapping of the interconnection topology to the network overlay nodes preferably involves assigning 2m m-length binary indexes to the network overlay nodes. There is proposed herein a polynomial time algorithm for interconnection topology embedding using iterative cluster division and node binary index assignment. There is further proposed herein a method for construction of network overlays through interconnection network topology embedding, with the objective of optimizing a quality of service metric (e.g. minimization of the average network overlay routing delay).
摘要翻译：本文提供了通过在网络覆盖图中嵌入互连网络来构建网络覆盖的方法，设备和程序存储设备。在最短的网络路径上测量覆盖节点对之间的网络延迟距离。互连拓扑到网络覆盖节点的映射优选地涉及向网络覆盖节点分配2m m长的二进制索引。本文提出了一种使用迭代集群划分和节点二进制索引分配的互连拓扑嵌入的多项式时间算法。此外还提出了通过互连网络拓扑嵌入来构建网络覆盖的方法，目的是优化服务质量度量（例如，平均网络覆盖路由延迟的最小化）。

69. 发明申请

US20080304516A1 Distributed Joint Admission Control And Dynamic Resource Allocation In Stream Processing Networks 失效
标题翻译：流处理网络中的分布式联合接入控制和动态资源分配
公开(公告)号：US20080304516A1
公开(公告)日：2008-12-11
申请号：US11758706
申请日：2007-06-06
申请人： Hanhua Feng , Zhen Liu , Honghui Xia , Li Zhang
发明人： Hanhua Feng , Zhen Liu , Honghui Xia , Li Zhang
IPC分类号： H04J3/16
CPC分类号： G06F9/5066 , G06F9/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.
摘要翻译：在流处理网络中操作的方法和装置执行卸载和动态资源分配，以满足预定的效用标准。负载脱落被设想为包括允许流程处理网络中的工作流的源节点的准入控制问题。使用原始双重方法来分解入学控制和资源分配问题。准入控制作为推拉过程进行操作，其中源将工作流推送到流处理网络并且从网络中吸收经处理的工作流。每个节点都维护一个虚拟队列，以解决队列积压和来自宿的积分。流处理网络的节点维护每个工作流的影子价格，并与邻居节点共享拥塞信息。在每个节点，资源用于工作流程，具有下游压力和处理速率的最大乘积，其中下游压力被定义为相邻节点之间的积压差异。原始双控制器使用局部拥塞反馈迭代地调整入局速率和资源分配。迭代控制程序进一步使用内点方法来提高收敛速度以达到最佳准入和分配决策。

70. 发明申请

US20080256166A1 Method for Inter-Site Data Stream Transfer in a Cooperative Data Stream Processing 失效
标题翻译：在协同数据流处理中的站点间数据流传输方法
公开(公告)号：US20080256166A1
公开(公告)日：2008-10-16
申请号：US11747694
申请日：2007-05-11
申请人： Michael J. Branson , Frederick Douglis , Zhen Liu , Fan Ye
发明人： Michael J. Branson , Frederick Douglis , Zhen Liu , Fan Ye
IPC分类号： G06F15/16
CPC分类号： H04L12/4633 , H04L69/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.
摘要翻译：提供协作数据流处理系统，其利用协作布置中的多个独立的，自主的和潜在的异构站点来处理关于动态的，连续的数据流的用户定义的查询。系统从查询中导出作业，这些作业通过执行包含这些站点上的处理元素的应用程序在各种分布式站点上执行。因此，给定作业的组件可以在系统内的多个站点上同时并行地执行。与给定作业执行相关联的站点需要共享数据，包括原始数据和派生数据。提供了一种在系统内的站点对之间建立隧道的隧道机制。每个隧道包括发起站点上的宿处理元件和目的站点上的源处理元件或每个站点上的网关处理元件以及宿和源处理元件之间的网络连接。宿和源处理元件与其各自站点上的应用处理元件通信，并且便于这些应用处理元件之间的数据交换。隧道可以根据需要或按照规定的计划建立，并且可以对于在给定的一对站点上执行的任何作业具有通用性。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式