公开(公告)号：US08245122B2

公开(公告)日：2012-08-14

申请号：US11971068

申请日：2008-01-08

申请人： Zhen Liu ,  Anton V. Riabov

发明人： Zhen Liu ,  Anton V. Riabov

IPC分类号： G06F17/00

CPC分类号： G06F17/30867

摘要： A method for determining if a first component can be connected to a second component for inclusion in a processing graph, includes: accessing a first component description, the first component description describing an output object of the first component with a set of tags; accessing a second component description, the second component description describing an input condition of the second component with a set of tags; determining that the first component can be connected to the second component if the set of tags describing the output object includes all tags describing the input condition; and including the first and second connected components in a processing graph if they are connected to each other.

摘要翻译： 一种用于确定第一组件是否可以连接到第二组件以包括在处理图中的方法，包括：访问第一组件描述，所述第一组件描述使用一组标签描述所述第一组件的输出对象; 访问第二组件描述，所述第二组件描述使用一组标签描述所述第二组件的输入状态; 如果描述输出对象的标签集合包括描述输入条件的所有标签，则确定第一组件可以连接到第二组件; 并且如果它们彼此连接，则将第一和第二连接组件包括在处理图中。

公开(公告)号：US08225129B2

公开(公告)日：2012-07-17

申请号：US11733732

申请日：2007-04-10

申请人： Frederick Douglis ,  Zhen Liu ,  Honghui Xia ,  Bin Rong

发明人： Frederick Douglis ,  Zhen Liu ,  Honghui Xia ,  Bin Rong

IPC分类号： G06F11/00

CPC分类号： G06F11/1482 ,  H04L67/1002 ,  H04L67/1031 ,  H04L67/1036 ,  H04L67/1095 ,  H04L69/40

摘要： 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.

摘要翻译： 提供了可用于协作数据流处理的故障恢复框架，可用于大规模流数据分析环境。 故障恢复支持多个独立的分布式站点，每个都有自己的本地管理和目标。 分布式站点在站点间备份机制中进行协作，以便从系统内的各种故障提供系统恢复。 故障恢复是通过站点之间的合作自动和及时的。 识别与给定主要站点相关联的备用站点。 这些站点用于识别主站点中的故障，包括在主站点的节点上运行的应用程序的故障。 使用备份站点本地的作业管理实例以及先前存储的状态信息和失败应用程序的数据值，在备份站点中的一个或多个节点上恢复失败的应用程序。 除了站点间机制之外，多个站点中的每一个都采用站内备用机制来处理站点内的故障恢复。

公开(公告)号：US08185352B2

公开(公告)日：2012-05-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分类号： 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.

摘要翻译： 公开了一种用于基准流处理系统的系统，方法和计算机程序产品。 该方法包括生成多个相关测试流。 语义相关的数据集嵌入在多个相关测试流中的每个测试流内。 多个相关测试流被提供给至少一个流处理系统。 为每个语义相关的嵌入式数据集生成一个摘要。 对被测系统透明的公共标识符嵌入在多个相关测试流中的每个流内。 从流处理系统生成的输出数据集中提取公共标识符。 将总结的存储副本和公共标识符中的至少一个与包括由流处理系统生成的一组零个或多个相关结果的输出数据集进行比较。

公开(公告)号：US08166465B2

公开(公告)日：2012-04-24

申请号：US11695410

申请日：2007-04-02

申请人： Mark D. Feblowitz ,  Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov

发明人： Mark D. Feblowitz ,  Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov

IPC分类号： G06F9/44 ,  G06F9/45 ,  G06F15/16

CPC分类号： H04L65/60

摘要： A method for assembling a stream processing application in which data source descriptions, component descriptions and a stream processing request are input and used to assemble a stream processing graph. Each of the data source descriptions includes a graph pattern that semantically describes an output of a data source, each of the component descriptions includes a graph pattern that semantically describes an input of a component and a graph pattern that semantically describes an output of the component, the stream processing request includes a goal that is represented by a graph pattern that semantically describes a desired stream processing outcome and the stream processing graph includes at least one data source or at least one component that satisfies the desired processing outcome.

摘要翻译： 一种组合流处理应用的方法，其中输入数据源描述，组件描述和流处理请求并用于组合流处理图。 每个数据源描述包括语义上描述数据源的输出的图形模式，每个组件描述包括语义上描述组件的输入的图形模式和语义上描述组件的输出的图形模式， 流处理请求包括由语义上描述期望的流处理结果的图形模式表示的目标，并且流处理图包括满足期望的处理结果的至少一个数据源或至少一个组件。

公开(公告)号：US20120072456A1

公开(公告)日：2012-03-22

申请号：US12884390

申请日：2010-09-17

申请人： Parijat Dube ,  Ankit Jain ,  Zhen Liu ,  Cathy Honghui Xia

发明人： Parijat Dube ,  Ankit Jain ,  Zhen Liu ,  Cathy Honghui Xia

IPC分类号： G06F17/30 ,  G06F9/46

CPC分类号： G06F9/5033 ,  G06F16/24568

摘要： A system, method and computer program product for allocating computing resources to process a plurality of data streams. A system for allocating resources to process a plurality of data streams. The system includes, but is not limited to: a memory device and a processor being connected to the memory device. The system receives at least one query from a user. The system obtains at least one sub-query associated with the at least one query. The system identifies at least one data stream associated with the at least one sub-query. The system computes at least one probability that the at least one sub-query is true. The system assigns the computing resources to process the data streams according to the computed probability.

摘要翻译： 一种用于分配计算资源以处理多个数据流的系统，方法和计算机程序产品。 一种用于分配资源以处理多个数据流的系统。 该系统包括但不限于：存储器件和处理器连接到存储器件。 系统从用户接收至少一个查询。 所述系统获得与所述至少一个查询相关联的至少一个子查询。 系统识别与至少一个子查询相关联的至少一个数据流。 该系统计算至少一个子查询为真的至少一个概率。 系统根据计算的概率分配计算资源来处理数据流。

公开(公告)号：US20120051131A1

公开(公告)日：2012-03-01

申请号：US12871450

申请日：2010-08-30

申请人： Zhen Liu ,  Uma Durairajan ,  Kenway Tam

发明人： Zhen Liu ,  Uma Durairajan ,  Kenway Tam

IPC分类号： G11C16/04

CPC分类号： G11C11/413 ,  G11C7/06 ,  G11C7/1075 ,  G11C8/16

摘要： A hardware arrangement for a memory bitcell, including a primary decoder for decoding a common memory address portion among a plurality of memory addresses, and a plurality of secondary decoders each for decoding an uncommon memory address portion of each of the plurality of memory addresses. The memory bitcell is configured to receive the decoded common memory address portion and output data from a memory entry corresponding to the decoded common memory address portion, and includes a single read port for outputting the data. The hardware arrangement includes a modified sense amplifier (SA) configured to receive the data output on the single read port, and directly receive the plurality of decoded uncommon memory address portions. The plurality of decoded uncommon memory address portions is used to determine whether to enable the modified SA. Data output from the memory bitcell is forwarded when the modified SA is enabled.

摘要翻译： 一种用于存储位单元的硬件装置，包括用于解码多个存储器地址中的公共存储器地址部分的主解码器，以及多个辅助解码器，每个副解码器用于解码多个存储器地址中的每一个的不常见的存储器地址部分。 存储位单元被配置为接收解码的公共存储器地址部分，并且从与解码的公共存储器地址部分相对应的存储器条目输出数据，并且包括用于输出数据的单个读取端口。 硬件装置包括被配置为接收单个读取端口上的数据输出的修改读出放大器（SA），并且直接接收多个经解码的非常见存储器地址部分。 多个解码的不常用存储器地址部分用于确定是否启用修改的SA。 当修改的SA被使能时，来自存储器位单元的数据输出被转发。

公开(公告)号：US20120032120A1

公开(公告)日：2012-02-09

申请号：US13263959

申请日：2010-05-08

申请人： Weihua Tan ,  Zhen Liu

发明人： Weihua Tan ,  Zhen Liu

IPC分类号： H01B1/22

CPC分类号： H01L31/022425 ,  H01B1/22 ,  Y02E10/50

摘要： The present invention discloses a conductive shiny for a solar battery comprising a first-order aluminum powder having a median diameter D50 of about 2-8 um, a second-order powder having a median diameter D50 of about 20-100 nm, a glass powder, and an organic carrier. The conductive slurry may be stable on a screen without leakage through screen, and there are no agglomeration and sedimentation during long-time storage. The present invention further discloses a method of preparing a conductive slurry for a solar battery, comprising steps of mixing a first-order aluminum powder, a second-order powder, a glass powder, and an organic carrier to obtain a mixture; and then ball milling the mixture to obtain the conductive slurry. The method may be simple and easy to realize, so that it's advantageous for mass production in the industry.

摘要翻译： 本发明公开了一种太阳能电池的导电光泽，其包括中等直径D50为约2-8μm的一级铝粉末，中值粒径D50为约20-100nm的二阶粉末，玻璃粉末 ，和有机载体。 导电浆料可以在屏幕上稳定而不会通过筛网渗漏，并且在长时间储存​​期间不存在附聚和沉淀。 本发明还公开了一种制备太阳能电池用导电浆料的方法，包括以下步骤：将一级铝粉末，二级粉末，玻璃粉末和有机载体混合，得到混合物; 然后对混合物进行球磨以获得导电浆料。 该方法可以简单且易于实现，因此有利于工业中的批量生产。

公开(公告)号：US20110191273A1

公开(公告)日：2011-08-04

申请号：US12658135

申请日：2010-02-02

申请人： Genady Grabarnik ,  Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov ,  Irina Rish ,  Larisa Shwartz

发明人： Genady Grabarnik ,  Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov ,  Irina Rish ,  Larisa Shwartz

IPC分类号： G06F15/18 ,  G06N5/02 ,  G06F15/16

CPC分类号： G06F15/18 ,  G06F15/16 ,  G06N5/02

摘要： A method for providing an evaluation/verification of the correctness of an ontology is described. The method includes loading a first ontology associated with a first rule set. an extended ontology and an extended rule set are generated based at least in part on the first ontology and the first rule set. The extended rule set is applied to the extended ontology. The method also includes determining (e.g., by a data processor) a correctness of the extended ontology. Results are generated which include the correctness. Apparatus and computer readable media are also described.

摘要翻译： 描述了提供本体的正确性的评估/验证的方法。 该方法包括加载与第一规则集相关联的第一本体。 至少部分地基于第一本体和第一规则集来生成扩展本体和扩展规则集。 扩展规则集应用于扩展本体。 该方法还包括确定（例如，由数据处理器）扩展本体的正确性。 产生包括正确性的结果。 还描述了装置和计算机可读介质。

公开(公告)号：US07924718B2

公开(公告)日：2011-04-12

申请号：US12535805

申请日：2009-08-05

申请人： Hanhua Feng ,  Zhen Liu ,  Honghui Xia ,  Li Zhang

发明人： Hanhua Feng ,  Zhen Liu ,  Honghui Xia ,  Li Zhang

IPC分类号： G01R31/08

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.

摘要翻译： 在流处理网络中操作的方法和装置执行卸载和动态资源分配，以满足预定的效用标准。 负载脱落被设想为包括允许流程处理网络中的工作流的源节点的准入控制问题。 使用原始双重方法来分解入学控制和资源分配问题。 准入控制作为推拉过程进行操作，其中源将工作流推送到流处理网络并且从网络中吸收经处理的工作流。 每个节点都维护一个虚拟队列，以解决队列积压和来自宿的积分。 流处理网络的节点维护每个工作流的影子价格，并与邻居节点共享拥塞信息。 在每个节点，资源用于工作流程，具有下游压力和处理速率的最大乘积，其中下游压力被定义为相邻节点之间的积压差异。 原始双控制器使用局部拥塞反馈迭代地调整入局速率和资源分配。 迭代控制程序进一步使用内点方法来提高收敛速度以达到最佳准入和分配决策。

公开(公告)号：US07899861B2

公开(公告)日：2011-03-01

申请号：US11695430

申请日：2007-04-02

申请人： Mark D. Feblowitz ,  Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov

发明人： Mark D. Feblowitz ,  Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov

IPC分类号： G06F15/16

CPC分类号： G06F8/34

摘要： A method for constructing a stream processing requests so that a stream processing application satisfying the stream processing request can be assembled, includes: inputting a stream processing request, wherein the stream processing request includes a goal that is represented by a graph pattern that semantically describes a desired stream processing outcome; and assembling a stream processing graph, wherein the stream processing graph is assembled to include at least one processing element that satisfies the desired processing outcome by associating the graph pattern that semantically describes the desired processing outcome with a graph pattern that semantically describes an input of the at least one processing element and a graph pattern that semantically describes an output of the at least one processing element, or to include at least one data source by associating the graph pattern that semantically describes the desired processing outcome with a graph pattern that semantically describes an output of the at least one data source.

摘要翻译： 一种用于构建流处理请求的方法，使得可以组合满足流处理请求的流处理应用，包括：输入流处理请求，其中流处理请求包括由语义上描述 所需流处理结果; 并且组装流处理图，其中流处理图被组合以包括通过将语义上描述期望的处理结果的图形模式与语义上描述所需处理结果的输入的图形模式相关联来满足期望的处理结果的至少一个处理元件 至少一个处理元件和图形图案，其语义地描述所述至少一个处理元件的输出，或者通过将语义上描述所需处理结果的图形模式与语义上描述所述处理结果的图形模式相关联来包括至少一个数据源 输出至少一个数据源。