会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 2. 发明申请
    • Tracking data processing in an application carried out on a distributed computing system
    • 在分布式计算系统上执行的应用程序中跟踪数据处理
    • US20090300624A1
    • 2009-12-03
    • US12129284
    • 2008-05-29
    • Michael J. BransonZachary A. GarbowJohn M. Santosuosso
    • Michael J. BransonZachary A. GarbowJohn M. Santosuosso
    • G06F9/46
    • G06F17/30445G06F9/5038G06F9/5066G06F2209/506H04L29/06H04L29/08072H04L67/1097Y10S707/99932
    • Methods, systems, and products are disclosed for tracking data processing in an application carried out on a distributed computing system, the distributed computing system including a plurality of computing nodes connected through a data communications network, the application carried out by a plurality of pluggable processing components installed on the plurality of computing nodes, the pluggable processing components including a pluggable processing provider component and a pluggable processing consumer component, that include: identifying, by the provider component, data satisfying predetermined processing criteria, the criteria specifying that the data is relevant to processing provided by the consumer component; passing, by the provider component, the data to the next pluggable processing component in the application for processing, including maintaining access to the data; receiving, by the consumer component, the data during execution of the application; and sending, by the consumer component, a receipt indicating that the consumer component received the data.
    • 公开了用于跟踪在分布式计算系统上执行的应用中的数据处理的方法,系统和产品,所述分布式计算系统包括通过数据通信网络连接的多个计算节点,所述应用由多个可插拔处理 安装在所述多个计算节点上的组件,所述可插拔处理组件包括可插拔处理提供程序组件和可插拔处理用户组件,所述可插入处理组件包括:由所述提供者组件识别满足预定处理标准的数据,所述数据指定所述数据相关 由消费者组件提供的处理; 由提供商组件将数据传递到应用程序中的下一个可插拔处理组件以进行处理,包括维护对数据的访问; 消费者组件在执行应用程序期间接收数据; 并且由消费者组件发送指示消费者组件接收到数据的收据。
    • 6. 发明申请
    • Managing performance of a job performed in a distributed computing system
    • 管理在分布式计算系统中执行的作业的性能
    • US20090300154A1
    • 2009-12-03
    • US12129353
    • 2008-05-29
    • Michael J. BransonZachary A. GarbowJohn M. Santosuosso
    • Michael J. BransonZachary A. GarbowJohn M. Santosuosso
    • G06F15/16
    • G06F9/5066G06F2209/501
    • Methods, systems, and products are disclosed for managing performance of a job performed in a distributed computing system, the distributed computing system comprising a plurality of compute nodes operatively coupled through a data communications network, the job carried out by a plurality of distributed pluggable processing components executing on the plurality of compute nodes, that include: identifying a current configuration of the pluggable processing components carrying out the job, the current configuration specifying a current distribution of the pluggable processing components among the compute nodes; identifying a network topology of the plurality of compute nodes in the data communications network; receiving a plurality of performance indicators produced during execution of the job; and redistributing, to a different compute node, at least one of the pluggable processing components in dependence upon the current configuration, the network topology, and the performance indicators.
    • 公开了用于管理在分布式计算系统中执行的作业的性能的方法,系统和产品,所述分布式计算系统包括通过数据通信网络可操作地耦合的多个计算节点,由多个分布式可插拔处理 在多个计算节点上执行的组件包括:识别执行该作业的可插拔处理组件的当前配置,该当前配置指定计算节点之间的可插拔处理组件的当前分布; 识别数据通信网络中的多个计算节点的网络拓扑; 接收在执行作业期间产生的多个性能指标; 以及根据当前配置,网络拓扑和性能指标,将不同的计算节点重新分配到可插拔处理组件中的至少一个。
    • 7. 发明授权
    • Tracking data processing in an application carried out on a distributed computing system
    • 在分布式计算系统上执行的应用程序中跟踪数据处理
    • US08788644B2
    • 2014-07-22
    • US12129284
    • 2008-05-29
    • Michael J. BransonZachary A. GarbowJohn M. Santosuosso
    • Michael J. BransonZachary A. GarbowJohn M. Santosuosso
    • G06F15/173G06F17/30G06F9/50H04L29/08H04L29/06
    • G06F17/30445G06F9/5038G06F9/5066G06F2209/506H04L29/06H04L29/08072H04L67/1097Y10S707/99932
    • Methods, systems, and products are disclosed for tracking data processing in an application carried out on a distributed computing system, the distributed computing system including a plurality of computing nodes connected through a data communications network, the application carried out by a plurality of pluggable processing components installed on the plurality of computing nodes, the pluggable processing components including a pluggable processing provider component and a pluggable processing consumer component, that include: identifying, by the provider component, data satisfying predetermined processing criteria, the criteria specifying that the data is relevant to processing provided by the consumer component; passing, by the provider component, the data to the next pluggable processing component in the application for processing, including maintaining access to the data; receiving, by the consumer component, the data during execution of the application; and sending, by the consumer component, a receipt indicating that the consumer component received the data.
    • 公开了用于跟踪在分布式计算系统上执行的应用中的数据处理的方法,系统和产品,所述分布式计算系统包括通过数据通信网络连接的多个计算节点,所述应用由多个可插拔处理 安装在所述多个计算节点上的组件,所述可插拔处理组件包括可插拔处理提供程序组件和可插拔处理用户组件,所述可插入处理组件包括:由所述提供者组件识别满足预定处理标准的数据,所述数据指定所述数据相关 由消费者组件提供的处理; 由提供商组件将数据传递到应用程序中的下一个可插拔处理组件以进行处理,包括维护对数据的访问; 消费者组件在执行应用程序期间接收数据; 并且由消费者组件发送指示消费者组件接收到数据的收据。
    • 9. 发明授权
    • Processing element management in a streaming data system
    • 流数据系统中的处理元件管理
    • US09405553B2
    • 2016-08-02
    • US13361287
    • 2012-01-30
    • Michael J. BransonRyan K. CradickJohn M. SantosuossoBrandon W. Schulz
    • Michael J. BransonRyan K. CradickJohn M. SantosuossoBrandon W. Schulz
    • G06F15/16G06F9/44G06F9/50
    • G06F9/5011G06F9/44G06F9/4881G06F9/505G06F2209/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可能会处于空闲状态。 为了利用这些可用的硬件资源,流程序员可以识别可被克隆的一个或多个处理元件。 克隆的处理元件可以用于生成与包括原始处理元件的执行路径平行的不同执行路径。 因为克隆的处理元素包含与原始处理元素相同的操作符,所以先前仅流过原始处理元素的数据流可以被分割并通过原始和克隆处理元素发送。 以这种方式,并行执行路径可以使用未充分利用的硬件资源来增加数据流的吞吐量。
    • 10. 发明授权
    • Monitoring streams buffering to optimize operator procressing
    • 监控流缓冲以优化操作员执行
    • US09015339B2
    • 2015-04-21
    • US13455982
    • 2012-04-25
    • Michael J. BransonRyan K. CradickJohn M. SantosuossoBrandon W. Schulz
    • Michael J. BransonRyan K. CradickJohn M. SantosuossoBrandon W. Schulz
    • G06F15/16H04L29/08H04L12/825
    • H04L67/104H04L47/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.
    • 用于执行操作的方法,系统和计算机程序产品,包括提供包括一个或多个操作者的多个处理元件,配置成处理流数据元组的操作符,建立多个操作符的操作符图,定义至少一个执行的操作符图 路径,其中第一运营商被配置为从至少一个上游运营商接收数据元组,并向至少一个下游运营商传输数据元组,为每个运营商提供缓冲器,该缓冲器被配置为保存需要在缓冲器中接收多个数据元组的处理的数据元组 与运算符相关联,所述数据元组包括至少一个属性,确定所述第一缓冲器中存在积压,从所述第一缓冲器中选择至少一个数据元组,检查所选数据元组的属性以识别候选元组,以及执行 候选元组的第二个操作。