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

1. 发明授权

US08990452B2 Dynamic reduction of stream backpressure 有权
标题翻译：动态减少流背压
公开(公告)号：US08990452B2
公开(公告)日：2015-03-24
申请号：US13190694
申请日：2011-07-26
申请人： Michael J. Branson , Ryan K. Cradick , John M. Santosuosso
发明人： Michael J. Branson , Ryan K. Cradick , John M. Santosuosso
IPC分类号： G06F3/00 , G06F9/46 , G06F9/48 , G06F9/50
CPC分类号： G06F9/4887 , G06F9/4843 , G06F9/5083 , G06F17/30516 , G06F17/30958
摘要： Techniques are described for eliminating backpressure in a distributed system by changing the rate data flows through a processing element. Backpressure occurs when data throughput in a processing element begins to decrease, for example, if new processing elements are added to the operating chart or if the distributed system is required to process more data. Indicators of backpressure (current or future) may be monitored. Once current backpressure or potential backpressure is identified, the operator graph or data rates may be altered to alleviate the backpressure. For example, a processing element may reduce the data rates it sends to processing elements that are downstream in the operator graph, or processing elements and/or data paths may be eliminated. In one embodiment, processing elements and associate data paths may be prioritized so that more important execution paths are maintained. In another embodiment, if a request to add one or more processing elements may cause future backpressure, the request may be refused.
摘要翻译：描述了通过改变通过处理元件的速率数据流来消除分布式系统中的背压的技术。当处理元件中的数据吞吐量开始减少时，例如，如果将新的处理元素添加到操作图表中，或者分布式系统是否需要处理更多数据，就会发生背压。背压指示器（当前或将来）可能被监控。一旦确定了当前的背压或潜在背压，则可以改变操作者图或数据速率以减轻背压。例如，处理元件可以将其发送到处理元件的数据速率降低在操作符图形中的下游，或者可以消除处理元件和/或数据路径。在一个实施例中，可以对处理元件和关联数据路径进行优先排列，从而保持更重要的执行路径。在另一个实施例中，如果添加一个或多个处理单元的请求可能导致未来的背压，则该请求可能被拒绝。

2. 发明授权

US08732300B2 Application monitoring in a stream database environment 有权
标题翻译：流数据库环境中的应用程序监控
公开(公告)号：US08732300B2
公开(公告)日：2014-05-20
申请号：US12987335
申请日：2011-01-10
申请人： Eric L. Barsness , Ryan K. Cradick , Michael D. Pfeifer , John M. Santosuosso
发明人： Eric L. Barsness , Ryan K. Cradick , Michael D. Pfeifer , John M. Santosuosso
IPC分类号： G06F15/173 , G06F15/16 , H04L12/24 , H04L29/08 , H04L29/06
CPC分类号： H04L29/08072 , G06F17/30516 , H04L29/06 , H04L41/12 , H04L41/22
摘要： Methods and systems for monitoring a stream application are disclosed. The stream application is composed from a plurality of processing elements executing on one or more compute nodes. A graphical user interface display presents a user with at least a portion of an operator graph in a running stream application. The operator graph represents the plurality of processing elements, and links between processing elements, corresponding to a flow of data tuples through the stream application. A monitoring application then monitors user interactions with the presentation of the portion of the operator graph on the graphical user interface display and identifies at least a first modification to the stream application based on a processing state of the stream application and the monitored user interactions.
摘要翻译：公开了用于监视流应用的方法和系统。流应用由在一个或多个计算节点上执行的多个处理元件组成。图形用户界面显示器向用户呈现运行流应用中的运算符图的至少一部分。运算符图表示多个处理元件，以及处理元件之间的链接，对应于通过流应用的数据元组流。监视应用程序然后基于图形用户界面显示器上的操作员图形的部分显示来监视用户交互，并且基于流应用程序的处理状态和所监视的用户交互来识别流应用程序的至少第一修改。

3. 发明申请

US20120179809A1 APPLICATION MONITORING IN A STREAM DATABASE ENVIRONMENT 有权
标题翻译：应用监测在流域数据库环境中
公开(公告)号：US20120179809A1
公开(公告)日：2012-07-12
申请号：US12987335
申请日：2011-01-10
申请人： ERIC L. BARSNESS , RYAN K. CRADICK , MICHAEL D. PFEIFER , JOHN M. SANTOSUOSSO
发明人： ERIC L. BARSNESS , RYAN K. CRADICK , MICHAEL D. PFEIFER , JOHN M. SANTOSUOSSO
IPC分类号： G06F15/173
CPC分类号： H04L29/08072 , G06F17/30516 , H04L29/06 , H04L41/12 , H04L41/22
摘要： Methods and systems for monitoring a stream application are disclosed. The stream application is composed from a plurality of processing elements executing on one or more compute nodes. A graphical user interface display presents a user with at least a portion of an operator graph in a running stream application. The operator graph represents the plurality of processing elements, and links between processing elements, corresponding to a flow of data tuples through the stream application. A monitoring application then monitors user interactions with the presentation of the portion of the operator graph on the graphical user interface display and identifies at least a first modification to the stream application based on a processing state of the stream application and the monitored user interactions.
摘要翻译：公开了用于监视流应用的方法和系统。流应用由在一个或多个计算节点上执行的多个处理元件组成。图形用户界面显示器向用户呈现运行流应用中的运算符图的至少一部分。运算符图表示多个处理元件，以及处理元件之间的链接，对应于通过流应用的数据元组流。监视应用程序然后基于图形用户界面显示器上的操作员图形的部分显示来监视用户交互，并且基于流应用程序的处理状态和所监视的用户交互来识别流应用程序的至少第一修改。

4. 发明申请

US20120137178A1 STREAM BASED DEBUGGING TECHNIQUES 失效
标题翻译：基于流的调试技术
公开(公告)号：US20120137178A1
公开(公告)日：2012-05-31
申请号：US12956424
申请日：2010-11-30
申请人： ERIC L. BARSNESS , RYAN K. CRADICK , MICHAEL D. PFEIFER , JOHN M. SANTOSUOSSO
发明人： ERIC L. BARSNESS , RYAN K. CRADICK , MICHAEL D. PFEIFER , JOHN M. SANTOSUOSSO
IPC分类号： G06F11/36
CPC分类号： G06F11/362
摘要： Techniques are described for debugging a processing element (or elements) in a stream based database application in a manner that reduces the impact of debugging the processing element (or elements) on the overall running environment by selectively fusing (or un-fusing) processing elements running on a group of compute nodes. In addition to fusing and un-fusing processing elements or otherwise modifying a state of the stream application, a debugging application and stream manager may modify data flows within the application stream in a variety of ways to minimize any disruption resulting from a debugging session.
摘要翻译：描述了用于以基于流的数据库应用程序调试处理元件（或元件）的技术，其方法是通过选择性地熔化（或取消融合）处理元件来减少调试处理元件（或元件）对整个运行环境的影响运行在一组计算节点上。调试应用程序和流管理器除了融合和取消定制处理元件或以其他方式修改流应用程序的状态之外，还可以以各种方式修改应用程序流内的数据流，以最小化调试会话导致的任何中断。

5. 发明授权

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可能会处于空闲状态。为了利用这些可用的硬件资源，流程序员可以识别可被克隆的一个或多个处理元件。克隆的处理元件可以用于生成与包括原始处理元件的执行路径平行的不同执行路径。因为克隆的处理元素包含与原始处理元素相同的操作符，所以先前仅流过原始处理元素的数据流可以被分割并通过原始和克隆处理元素发送。以这种方式，并行执行路径可以使用未充分利用的硬件资源来增加数据流的吞吐量。

6. 发明授权

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.
摘要翻译：用于执行操作的方法，系统和计算机程序产品，包括提供包括一个或多个操作者的多个处理元件，配置成处理流数据元组的操作符，建立多个操作符的操作符图，定义至少一个执行的操作符图路径，其中第一运营商被配置为从至少一个上游运营商接收数据元组，并向至少一个下游运营商传输数据元组，为每个运营商提供缓冲器，该缓冲器被配置为保存需要在缓冲器中接收多个数据元组的处理的数据元组与运算符相关联，所述数据元组包括至少一个属性，确定所述第一缓冲器中存在积压，从所述第一缓冲器中选择至少一个数据元组，检查所选数据元组的属性以识别候选元组，以及执行候选元组的第二个操作。

7. 发明授权

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.
摘要翻译：用于执行操作的方法，系统和计算机程序产品，所述操作包括提供包括一个或多个操作者的多个处理元件，所述操作符被配置为处理流数据元组。操作然后建立多个运算符的运算符图，运算符图定义至少一个执行路径，其中多个运算符中的第一运算符被配置为从至少一个上游运算符接收数据元组，并将数据元组传输到至少一个下游运营商。操作然后定义断点，断点包括条件，基于至少一个操作者的窗口中的数据元组的属性值的条件，该窗口包括操作者中的多个数据元组。该操作在检测到条件的发生时触发断点以停止运算符图中的多个运算符中的每一个的处理。

8. 发明申请

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利用率或元组速率），以确定动态连接是否损害性能。如果是这样，可以优化流计算系统以减轻动态连接的影响。例如，特定的运算符可以从处理元件中被引用，并且被移动到具有可用计算资源的计算节点。此外，流计算应用可以克隆数据流，以便将发送数据流的工作负载分配给所连接的作业。

9. 发明申请

US20130031263A1 DYNAMIC RUNTIME CHOOSING OF PROCESSING COMMUNICATION METHODS 有权
标题翻译：加工通信方式动态运行时间选择
公开(公告)号：US20130031263A1
公开(公告)日：2013-01-31
申请号：US13190757
申请日：2011-07-26
申请人： Ryan K. Cradick , John M. Santosuosso , Brandon W. Schulz
发明人： Ryan K. Cradick , John M. Santosuosso , Brandon W. Schulz
IPC分类号： G06F15/16
CPC分类号： H04L69/08 , H04L69/18
摘要： Techniques are described for assigning and changing communication protocols for a pair of processing elements. The communication protocol determines how the pair of processing elements transmits data in a stream application. The pair may be assigned a communication protocol (e.g., TCP/IP or a protocol that uses a relational database, shared file system, or shared memory) before the operator graph begins to stream data. This assignment may be based on a priority of the processing elements and/or a priority of the communication protocols. After the operator graph begins to stream data, the pair of processing elements may switch to a different communication protocol. The decision to switch the communication protocol may be based on whether the pair of processing elements or assigned communication protocol is meeting established performance standards for the stream application.
摘要翻译：描述了用于分配和改变一对处理元件的通信协议的技术。通信协议确定一对处理元件如何在流应用中传输数据。在操作员图开始流传输数据之前，该对可被分配通信协议（例如，TCP / IP或使用关系数据库，共享文件系统或共享存储器的协议）。该分配可以基于处理元件的优先级和/或通信协议的优先级。在运算符图开始流数据之后，该对处理单元可以切换到不同的通信协议。切换通信协议的决定可以基于一对处理元件或分配的通信协议是否满足流应用的已建立的性能标准。

10. 发明授权

US08327337B2 Stream based debugging techniques 失效
标题翻译：基于流的调试技术
公开(公告)号：US08327337B2
公开(公告)日：2012-12-04
申请号：US12956424
申请日：2010-11-30
申请人： Eric L. Barsness , Ryan K. Cradick , Michael D. Pfeifer , John M. Santosuosso
发明人： Eric L. Barsness , Ryan K. Cradick , Michael D. Pfeifer , John M. Santosuosso
IPC分类号： G06F9/44 , G06F11/00
CPC分类号： G06F11/362
摘要： Techniques are described for debugging a processing element (or elements) in a stream based database application in a manner that reduces the impact of debugging the processing element (or elements) on the overall running environment by selectively fusing (or un-fusing) processing elements running on a group of compute nodes. In addition to fusing and un-fusing processing elements or otherwise modifying a state of the stream application, a debugging application and stream manager may modify data flows within the application stream in a variety of ways to minimize any disruption resulting from a debugging session.
摘要翻译：描述了用于以基于流的数据库应用程序调试处理元件（或元件）的技术，其方法是通过选择性地熔化（或取消融合）处理元件来减少调试处理元件（或元件）对整个运行环境的影响运行在一组计算节点上。调试应用程序和流管理器除了融合和取消定制处理元件或以其他方式修改流应用程序的状态之外，还可以以各种方式修改应用程序流内的数据流，以最小化调试会话导致的任何中断。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式