-
公开(公告)号：US20170091283A1
公开(公告)日：2017-03-30
申请号：US14870042
申请日：2015-09-30
发明人： Bin Cao , Jessica R. Eidem , Brian R. Muras , Jingdong Sun
摘要： A stream application receives a stream of tuples to be processed by a plurality of processing elements operating on one or more compute nodes. Each processing element has one or more stream operators. The stream application assigns one or more processing cycles to one or more segments of software code. The segments of software code are embedded in one or more tuples of the stream of tuples. The stream application determines that a condition is met based on the processing cycles. The stream application performs an operation based on the processing cycles.
-
32.发明申请ASSET ARRANGEMENT MANAGEMENT FOR A SHARED POOL OF CONFIGURABLE COMPUTING RESOURCES ASSOCIATED WITH A STREAMING APPLICATION 审中-公开与流动应用程序相关的可配置计算资源共享池的资产安排管理公开(公告)号：US20170063724A1
公开(公告)日：2017-03-02
申请号：US15048582
申请日：2016-02-19
发明人： Bin Cao , Jessica R. Eidem , Brian R. Muras , Jingdong Sun
IPC分类号： H04L12/911 , G06F9/455 , H04L12/26
CPC分类号： H04L43/16 , G06F9/45558 , G06F9/5061 , G06F9/5077 , G06F16/24568 , G06F2009/45562 , G06F2009/4557 , G06F2009/45591 , G06F2009/45595 , G06F2209/5011 , H04L41/0896 , H04L43/0876 , H04L47/823
摘要： Disclosed aspects include managing a set of assets of a shared pool of configurable computing resources associated with a streaming application. A stream of tuples to be processed is received by a plurality of processing elements operating on the shared pool of configurable computing resources having the set of assets. A triggering event which corresponds to a data flow of the stream of tuples is detected. Based on the data flow of the stream of tuples, an asset arrangement with respect to the set of assets is determined and established. In embodiments, the stream of tuples may be processed by the plurality of processing elements operating on the shared pool of configurable computing resources having the set of assets.
摘要翻译： 公开的方面包括管理与流应用相关联的可配置计算资源的共享池的一组资产。 要处理的元组流由在具有该资产集合的可配置计算资源的共享池上操作的多个处理元件接收。 检测对应于元组流的数据流的触发事件。 基于元数据流的数据流，确定并建立了相对于资产组合的资产安排。 在实施例中，元组流可以由在具有该资产集合的可配置计算资源的共享池上操作的多个处理元件来处理。
-
公开(公告)号：US20160344778A1
公开(公告)日：2016-11-24
申请号：US14718370
申请日：2015-05-21
发明人： Bin Cao , Jessica R. Eidem , Brian R. Muras , Jingdong Sun
CPC分类号： H04L43/045 , G06F9/455 , G06F17/30516 , H04L41/5019 , H04L43/026 , H04L43/16 , H04L65/40 , H04L65/80
摘要： A streams manager monitors performance of a streaming application and determines if operators are underperforming according to a threshold. When the performance needs to be improved, the streams manager automatically modifies the flow graph to offload or reroute a stream of data, or part of a stream of data, to a similar operator to more efficiently utilize streaming resources. Operators are provided with multiple ports to allow the streams manager to send additional streams to the operator.
-
公开(公告)号：US09298848B2
公开(公告)日：2016-03-29
申请号：US14069688
申请日：2013-11-01
发明人： Bin Cao , Jessica R. Eidem , Brian R. Muras , Jingdong Sun
CPC分类号： G06F17/30958 , G06F9/45533 , G06F9/5066 , G06F17/30516
摘要： Embodiments of the disclosure provide a method, system, and computer program product for managing a template on an operator graph. The method for managing a template on an operator graph can include receiving the template for processing a stream of tuples. The template can have a plurality of template elements operating on one or more computer processors. The method can include calculating a resource requirement of a template element from the template. The method can include calculating a resource availability of a virtual machine. The method can include allocating the template onto the operator graph. The operator graph can have a plurality of processing elements operating on one or more computer processors. The method can also include mapping the template element from the template onto the virtual machine as a function of the resource requirement of the template element and the resource availability of the virtual machine.
摘要翻译： 本公开的实施例提供了一种用于在运营商图上管理模板的方法，系统和计算机程序产品。 用于在运算符图上管理模板的方法可以包括接收用于处理元组流的模板。 模板可以具有在一个或多个计算机处理器上操作的多个模板元素。 该方法可以包括从模板计算模板元素的资源需求。 该方法可以包括计算虚拟机的资源可用性。 该方法可以包括将模板分配到运算符图上。 操作员图可以具有在一个或多个计算机处理器上操作的多个处理元件。 该方法还可以包括将模板元素从模板映射到虚拟机上，作为模板元素的资源需求和虚拟机的资源可用性的函数。
-
公开(公告)号：US20150128135A1
公开(公告)日：2015-05-07
申请号：US14136005
申请日：2013-12-20
发明人： Bin Cao , Jessica R. Eidem , Brian R. Muras , Jingdong Sun
IPC分类号： G06F9/455
CPC分类号： G06F17/30958 , G06F9/45533 , G06F9/5066 , G06F17/30516
摘要： Embodiments of the disclosure provide a method, system, and computer program product for managing a template on an operator graph. The method for managing a template on an operator graph can include receiving the template for processing a stream of tuples. The template can have a plurality of template elements operating on one or more computer processors. The method can include calculating a resource requirement of a template element from the template. The method can include calculating a resource availability of a virtual machine. The method can include allocating the template onto the operator graph. The operator graph can have a plurality of processing elements operating on one or more computer processors. The method can also include mapping the template element from the template onto the virtual machine as a function of the resource requirement of the template element and the resource availability of the virtual machine.
-
公开(公告)号：US11972299B2
公开(公告)日：2024-04-30
申请号：US17353864
申请日：2021-06-22
发明人： Jingdong Sun , Roger Mittelstadt , Rafal Konik , Jessica R. Eidem
CPC分类号： G06F9/5061 , G06F9/468 , G06F9/5077 , G06F9/544 , G06F9/5072 , G06F2209/5014
摘要： A sharable resource of a first user's environment is identified. The sharable resource is configured as sharable in a shared computer environment. A matching resource that is sufficiently similar to the sharable resource is located. The matching resource is used by pre-existing users of the shared computer environment. Agreement from the pre-existing users for the first user to access the matching resource is obtained. The first user is then provided access to the matching resource.
-
公开(公告)号：US11301359B2
公开(公告)日：2022-04-12
申请号：US16736364
申请日：2020-01-07
IPC分类号： G06F11/36
摘要： A method, system and computer program product for facilitating remote debugging of parallel regions in stream computing applications. A stream computing management server (SCMS) communicates a list of processing elements to a debugging interface. Responsive to setting a debugging breakpoint for a processing element of the list of processing elements, the SCMS receives a command to enable remote debugging for the selected processing element. In this regard, the processing element is a part of a parallel channel in a distributed processing environment. The SCMS maps the processing element to an attachment information in the distributed environment. The SCMS dynamically attaches a remote debugger to the processing element based on the attachment information.
-
公开(公告)号：US20220075664A1
公开(公告)日：2022-03-10
申请号：US17016508
申请日：2020-09-10
摘要： Computer software executing on computer hardware that performs the following operations: (i) training a machine learning model to determine allocations of computing resources to processing elements of a stream processing job according to a specified objective; and (ii) allocating a set of computing resources to the processing elements by: allocating to the processing elements a first subset of the set of computing resources based, at least in part, on a minimum resource requirement for the processing elements, and allocating to the processing elements a second subset of the set of computing resources based, at least in part, on an allocation determined using the trained machine learning model.
-
公开(公告)号：US11165846B2
公开(公告)日：2021-11-02
申请号：US16448568
申请日：2019-06-21
发明人： Jingdong Sun , Roger Mittelstadt , Rafal Konik , Jessica R. Eidem
摘要： A streams manager includes a connection converter that allows converting at run-time a static connection to a dynamic connection, and converting at run-time a dynamic connection to a static connection. One or more conversion criteria are defined that determine when a conversion of one or more connections is needed at run-time. When conversion criteria for converting a static connection from a first processing element to a second processing element to a dynamic connection is satisfied, the first processing element interacts with the streams manager and with the second processing element to dynamically change the static connection to a dynamic connection. When conversion criteria for converting a dynamic connection from a first processing element to a second processing element to a static connection is satisfied, the first processing element interacts with the streams manager and with the second processing element to dynamically change the dynamic connection to a static connection.
-
公开(公告)号：US10901998B2
公开(公告)日：2021-01-26
申请号：US15168379
申请日：2016-05-31
发明人： Jessica R. Eidem , Brian R. Muras , Jingdong Sun
IPC分类号： G06F16/2455
摘要： Disclosed aspects relate to managing a stream computing environment. The stream computing environment may have a consistent region that includes a set of stream operators for processing a stream of tuples. An operator modification request with respect to the set of stream operators of the consistent region of the stream computing environment may be received. In response to receiving the operator modification request, a set of tuples of the stream of tuples may be detected in the consistent region. Using the operator modification request, a tuple adjustment action for the set of tuples of the stream of tuples in the consistent region may be determined. Based on the operator modification request, the set of stream operators may be modified. The set of tuples may be processed using the tuple adjustment action.
-
-
-
-
-
-
-
-
-
搜索结果
72 条记录 (耗时 0.022 秒)
