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

1. 发明授权

US09405553B2 Processing element management in a streaming data system 有权
标题翻译：流数据系统中的处理元件管理
公开(公告)号：US09405553B2
公开(公告)日：2016-08-02
申请号：US13361287
申请日：2012-01-30
申请人： Michael J. Branson , Ryan K. Cradick , John M. Santosuosso , Brandon W. Schulz
发明人： Michael J. Branson , Ryan K. Cradick , John M. Santosuosso , Brandon W. Schulz
IPC分类号： G06F15/16 , G06F9/44 , G06F9/50
CPC分类号： G06F9/5011 , G06F9/44 , G06F9/4881 , G06F9/505 , G06F2209/502
摘要： Stream applications may inefficiently use the hardware resources that execute the processing elements of the data stream. For example, a compute node may host four processing elements and execute each using a CPU. However, other CPUs on the compute node may sit idle. To take advantage of these available hardware resources, a stream programmer may identify one or more processing elements that may be cloned. The cloned processing elements may be used to generate a different execution path that is parallel to the execution path that includes the original processing elements. Because the cloned processing elements contain the same operators as the original processing elements, the data stream that was previously flowing through only the original processing element may be split and sent through both the original and cloned processing elements. In this manner, the parallel execution path may use underutilized hardware resources to increase the throughput of the data stream.
摘要翻译：流应用可能会低效地使用执行数据流处理元素的硬件资源。例如，计算节点可以托管四个处理元件，并使用CPU执行每个处理元件。但是，计算节点上的其他CPU可能会处于空闲状态。为了利用这些可用的硬件资源，流程序员可以识别可被克隆的一个或多个处理元件。克隆的处理元件可以用于生成与包括原始处理元件的执行路径平行的不同执行路径。因为克隆的处理元素包含与原始处理元素相同的操作符，所以先前仅流过原始处理元素的数据流可以被分割并通过原始和克隆处理元素发送。以这种方式，并行执行路径可以使用未充分利用的硬件资源来增加数据流的吞吐量。

2. 发明授权

US09015339B2 Monitoring streams buffering to optimize operator procressing 有权
标题翻译：监控流缓冲以优化操作员执行
公开(公告)号：US09015339B2
公开(公告)日：2015-04-21
申请号：US13455982
申请日：2012-04-25
申请人： Michael J. Branson , Ryan K. Cradick , John M. Santosuosso , Brandon W. Schulz
发明人： Michael J. Branson , Ryan K. Cradick , John M. Santosuosso , Brandon W. Schulz
IPC分类号： G06F15/16 , H04L29/08 , H04L12/825
CPC分类号： H04L67/104 , H04L47/25
摘要： Method, system and computer program product for performing an operation, including providing a plurality of processing elements comprising one or more operators, the operators configured to process streaming data tuples, establishing an operator graph of multiple operators, the operator graph defining at least one execution path in which a first operator is configured to receive data tuples from at least one upstream operator and transmit data tuples to at least one downstream operator, providing each operator a buffer configured to hold data tuples requiring processing receiving a plurality of data tuples in a buffer associated with an operator, the data tuples comprising at least one attribute, determining a backlog exists in the first buffer, selecting at least one data tuple from the first buffer, examining an attribute of the selected data tuples to identify a candidate tuple, and performing a second operation on the candidate tuple.
摘要翻译：用于执行操作的方法，系统和计算机程序产品，包括提供包括一个或多个操作者的多个处理元件，配置成处理流数据元组的操作符，建立多个操作符的操作符图，定义至少一个执行的操作符图路径，其中第一运营商被配置为从至少一个上游运营商接收数据元组，并向至少一个下游运营商传输数据元组，为每个运营商提供缓冲器，该缓冲器被配置为保存需要在缓冲器中接收多个数据元组的处理的数据元组与运算符相关联，所述数据元组包括至少一个属性，确定所述第一缓冲器中存在积压，从所述第一缓冲器中选择至少一个数据元组，检查所选数据元组的属性以识别候选元组，以及执行候选元组的第二个操作。

3. 发明授权

US08924939B2 Streams debugging within a windowing condition 有权
标题翻译：在开窗状态下流调试
公开(公告)号：US08924939B2
公开(公告)日：2014-12-30
申请号：US13467369
申请日：2012-05-09
申请人： Michael J. Branson , Ryan K. Cradick , John M. Santosuosso , Brandon W. Schulz
发明人： Michael J. Branson , Ryan K. Cradick , John M. Santosuosso , Brandon W. Schulz
IPC分类号： G06F9/44
CPC分类号： G06F11/362 , G06F11/3636
摘要： Method, system and computer program product for performing an operation, the operation including providing a plurality of processing elements comprising one or more operators, the operators configured to process streaming data tuples. The operation then establishes an operator graph of multiple operators, the operator graph defining at least one execution path in which a first operator of the plurality of operators is configured to receive data tuples from at least one upstream operator and transmit data tuples to at least one downstream operator. The operation then defines a breakpoint, the breakpoint comprising a condition, the condition based on attribute values of data tuples in a window of at least one operator, the window comprising a plurality of data tuples in an operator. The operation, upon detecting occurrence of the condition, triggers the breakpoint to halt processing by each of the plurality of operators in the operator graph.
摘要翻译：用于执行操作的方法，系统和计算机程序产品，所述操作包括提供包括一个或多个操作者的多个处理元件，所述操作符被配置为处理流数据元组。操作然后建立多个运算符的运算符图，运算符图定义至少一个执行路径，其中多个运算符中的第一运算符被配置为从至少一个上游运算符接收数据元组，并将数据元组传输到至少一个下游运营商。操作然后定义断点，断点包括条件，基于至少一个操作者的窗口中的数据元组的属性值的条件，该窗口包括操作者中的多个数据元组。该操作在检测到条件的发生时触发断点以停止运算符图中的多个运算符中的每一个的处理。

4. 发明授权

US08813082B2 Thread priority based on object creation rates 有权
标题翻译：基于对象创建速率的线程优先级
公开(公告)号：US08813082B2
公开(公告)日：2014-08-19
申请号：US11425846
申请日：2006-06-22
申请人： Eric L. Barsness , John M. Santosuosso , John J. Stecher
发明人： Eric L. Barsness , John M. Santosuosso , John J. Stecher
IPC分类号： G06F9/46 , G06F9/455 , G06F12/00
CPC分类号： G06F9/4881
摘要： A method and apparatus for managing thread priority based on object creation rates. Embodiments of the invention provide a thread monitor configured to reduce the execution priority of a thread creating a sufficient number of new objects to be disruptive of system performance. Thus, although the thread may still create a large number of objects, by monitoring object creation rates and reducing the execution priority of such a thread, overall system performance may be improved. In other words, a given thread may still “misbehave,” but receive fewer opportunities to do so.
摘要翻译：一种基于对象创建速率来管理线程优先级的方法和装置。本发明的实施例提供一种线程监视器，其被配置为减少线程的执行优先级，从而创建足够数量的新对象以破坏系统性能。因此，虽然线程仍然可以创建大量对象，但是通过监视对象创建速率并降低这种线程的执行优先级，可以提高整体系统性能。换句话说，给定的线程可能仍然“不正当”，但是获得更少的机会来这样做。

5. 发明授权

US08595736B2 Parsing an application to find serial and parallel data segments to minimize mitigation overhead between serial and parallel compute nodes 有权
标题翻译：分析应用程序以找到串行和并行数据段，以最大限度地减少串行和并行计算节点之间的缓解开销
公开(公告)号：US08595736B2
公开(公告)日：2013-11-26
申请号：US13440065
申请日：2012-04-05
申请人： Eric L. Barsness , David L. Darrington , Amanda E. Peters , John M. Santosuosso
发明人： Eric L. Barsness , David L. Darrington , Amanda E. Peters , John M. Santosuosso
IPC分类号： G06F9/46
CPC分类号： G06F11/3495 , G06F8/456 , G06F9/5083 , G06F11/3404 , G06F11/3433
摘要： Methods, systems, and products are disclosed for executing an application on a parallel computer having a plurality of nodes. Executing an application on a parallel computer includes: booting up a first subset of a plurality of nodes in a serial processing mode; booting up a second subset of the plurality of nodes in a parallel processing mode; profiling, prior to application execution, an application to identify serial segments of the application, parallel segments of the application, and application data utilized by each of the serial segments and the parallel segments; and executing the application on the plurality of nodes, including migrating, in dependence upon the profile for the application upon encountering the parallel segments during execution, only specific portions of the application and the application data from the nodes booted up in the serial processing mode to the nodes booted up in the parallel processing mode.
摘要翻译：公开了用于在具有多个节点的并行计算机上执行应用的方法，系统和产品。在并行计算机上执行应用包括：以串行处理模式引导多个节点的第一子集; 以并行处理模式引导所述多个节点的第二子集; 在应用程序执行之前，分析应用程序以识别应用的串行段，应用程序的并行段以及每个串行段和并行段所使用的应用程序数据; 以及在所述多个节点上执行所述应用，包括在执行期间遇到所述并行段时根据所述应用的简档仅迁移所述应用的特定部分和来自所述节点的应用数据，所述节点以串行处理模式被引导到节点以并行处理模式启动。

6. 发明申请

US20130290966A1 OPERATOR GRAPH CHANGES IN RESPONSE TO DYNAMIC CONNECTIONS IN STREAM COMPUTING APPLICATIONS 有权
标题翻译：操作员图形改变对流动计算应用中的动态连接的响应
公开(公告)号：US20130290966A1
公开(公告)日：2013-10-31
申请号：US13456600
申请日：2012-04-26
申请人： Michael J. Branson , Ryan K. Cradick , John M. Santosuosso , Brandon W. Schulz
发明人： Michael J. Branson , Ryan K. Cradick , John M. Santosuosso , Brandon W. Schulz
IPC分类号： G06F9/46
CPC分类号： G06F9/48 , G06F9/5083 , G06F11/3433
摘要： A stream computing application may permit one job to connect to a data stream of a different job. As more and more jobs dynamically connect to the data stream, the connections may have a negative impact on the performance of the job that generates the data stream. Accordingly, a variety of metrics and statistics (e.g., CPU utilization or tuple rate) may be monitored to determine if the dynamic connections are harming performance. If so, the stream computing system may be optimized to mitigate the effects of the dynamic connections. For example, particular operators may be unfused from a processing element and moved to a compute node that has available computing resources. Additionally, the stream computing application may clone the data stream in order to distribute the workload of transmitting the data stream to the connected jobs.
摘要翻译：流计算应用可以允许一个作业连接到不同作业的数据流。随着越来越多的作业动态地连接到数据流，连接可能对生成数据流的作业的性能产生负面影响。因此，可以监视各种指标和统计（例如，CPU利用率或元组速率），以确定动态连接是否损害性能。如果是这样，可以优化流计算系统以减轻动态连接的影响。例如，特定的运算符可以从处理元件中被引用，并且被移动到具有可用计算资源的计算节点。此外，流计算应用可以克隆数据流，以便将发送数据流的工作负载分配给所连接的作业。

7. 发明授权

US08572274B2 Estimating load shed data in streaming database applications 有权
标题翻译：在流数据库应用程序中估计负载流数据
公开(公告)号：US08572274B2
公开(公告)日：2013-10-29
申请号：US13029165
申请日：2011-02-17
申请人： Eric L. Barsness , John M. Santosuosso
发明人： Eric L. Barsness , John M. Santosuosso
IPC分类号： G06F15/16
CPC分类号： H04L29/06476 , G06F9/5083 , H04L65/60
摘要： Techniques are disclosed for processing data streams containing data tuples, where some of the data tuples are load shed. Load shedding refers to a process of selectively discarding some data tuples, e.g., when the amount of received data becomes too overwhelming to manage. When operations are invoked that depend on the values (or count) of the load shed tuples, the value (or counts) of the load shed tuples may be used to perform such operations. For example, an aggregation operation may return the sum, average, mean and/or variance associated with a plurality of tuples processed by a node of the stream application.
摘要翻译：公开了用于处理包含数据元组的数据流的技术，其中一些数据元组被加载。负载脱落是指选择性地丢弃一些数据元组的过程，例如当接收到的数据的量变得太大而不能管理时。当调用取决于负载转出元组的值（或计数）的操作时，可以使用负载转出元组的值（或计数）来执行此类操作。例如，聚合操作可以返回与流应用的节点处理的多个元组相关联的和，平均，平均值和/或方差。

8. 发明授权

US08554747B2 Active memory expansion in a database environment to query needed/uneeded results 有权
公开(公告)号：US08554747B2
公开(公告)日：2013-10-08
申请号：US12944455
申请日：2010-11-11
申请人： Eric L. Barsness , Paul S. Nelsestuen , John M. Santosuosso
发明人： Eric L. Barsness , Paul S. Nelsestuen , John M. Santosuosso
IPC分类号： G06F17/30
CPC分类号： G06F17/30153 , G06F17/30442
摘要： Techniques are described for estimating and managing memory compression for request processing. Embodiments of the invention may generally include receiving a request for data, determining if the requested data contains any compressed data, and sending the requesting entity only the uncompressed data. A separate embodiment generally includes receiving a request for data, determining if the requested data contains any compressed data, gathering uncompression criteria about the requested data, and using the uncompression criteria to selectively determine what portion of the compressed data to uncompress.

9. 发明申请

US20130179586A1 TRIGGERING WINDOW CONDITIONS USING EXCEPTION HANDLING 有权
标题翻译：使用异常处理触发窗口条件
公开(公告)号：US20130179586A1
公开(公告)日：2013-07-11
申请号：US13347974
申请日：2012-01-11
申请人： Michael J. Branson , John M. Santosuosso , Brandon W. Schulz
发明人： Michael J. Branson , John M. Santosuosso , Brandon W. Schulz
IPC分类号： G06F15/16
CPC分类号： G06F3/0481 , G06F5/06 , G06F9/44 , G06F15/163 , G06F17/30 , H04N21/435
摘要： In a stream computing application, data may be transmitted between operators using tuples. However, the receiving operator may not evaluate these tuples as they arrive but instead wait to evaluate a group of tuples—i.e., a window. A window is typically triggered when a buffer associated with the receiving operator reaches a maximum window size or when a predetermined time period has expired. Additionally, a window may be triggered by a monitoring a tuple rate—i.e., the rate at which the operator receives the tuples. If the tuple rate exceeds or falls below a threshold, a window may be triggered. Further, the number of exceptions, or the rate at which an operator throws exceptions, may be monitored. If either of these parameters satisfies a threshold, a window may be triggered, thereby instructing an operator to evaluate the tuples contained within the window.
摘要翻译：在流计算应用中，可以使用元组在运营商之间传输数据。然而，接收运算符可能不会在这些元组到达时评估这些元组，而是等待评估一组元组，即一个窗口。当与接收运算符相关联的缓冲器达到最大窗口大小或者当预定时间段到期时，通常触发窗口。另外，可以通过监视元组速率（即，操作者接收元组的速率）来触发窗口。如果元组速率超过或低于阈值，则可能会触发一个窗口。此外，可以监视异常的数量，或者操作者引发异常的速率。如果这些参数中的任一个满足阈值，则可以触发窗口，从而指示操作者评估窗口中包含的元组。

10. 发明申请

US20130166942A1 UNFUSING A FAILING PART OF AN OPERATOR GRAPH 有权
公开(公告)号：US20130166942A1
公开(公告)日：2013-06-27
申请号：US13334348
申请日：2011-12-22
申请人： Michael J. Branson , John M. Santosuosso , Brandon W. Schulz
发明人： Michael J. Branson , John M. Santosuosso , Brandon W. Schulz
IPC分类号： G06F11/20
CPC分类号： G06F11/0793 , G06F11/0709 , G06F11/0754 , G06F11/2025 , G06F11/2035 , G06F11/3433
摘要： Techniques for managing a fused processing element are described. Embodiments receive streaming data to be processed by a plurality of processing elements. Additionally, an operator graph of the plurality of processing elements is established. The operator graph defines at least one execution path and wherein at least one of the processing elements of the operator graph is configured to receive data from at least one upstream processing element and transmit data to at least one downstream processing element. Embodiments detect an error condition has been satisfied at a first one of the plurality of processing elements, wherein the first processing element contains a plurality of fused operators. At least one of the plurality of fused operators is selected for removal from the first processing element. Embodiments then remove the selected at least one fused operator from the first processing element.

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式