-
公开(公告)号：US20220138061A1
公开(公告)日：2022-05-05
申请号：US17084974
申请日：2020-10-30
摘要： An embodiment includes monitoring a distributed computing application at runtime for occurrence of a condition, where the condition includes occurrence of a degradation condition on a processing element (PE). The embodiment also includes starting a provisional PE on a second node at runtime while maintaining runtime operation of the PE. The embodiment compares operation of the PE to operation of the provisional PE based on a performance metric associated with the computing resource. The embodiment connects the provisional PE to replace the stream of tuples from the PE to a downstream PE with a stream of tuples from the provisional PE to the downstream PE.
-
公开(公告)号：US20220057457A1
公开(公告)日：2022-02-24
申请号：US16997205
申请日：2020-08-19
摘要： Information indicating a source of electric current can be transmitted alongside or within the electric current itself, enabling downstream recipients to identify a source of their electricity. The information may be embedded directly into the electric current, such as by adding a modulated carrier signal to an alternating current before transmitting the current to a downstream recipient.
-
公开(公告)号：US11163754B2
公开(公告)日：2021-11-02
申请号：US16392718
申请日：2019-04-24
IPC分类号： G06F16/23 , G06F16/2455
摘要： The method can include receiving the first stream of tuples to be processed by the stream operator hosted by one or more computer processors, the stream operator having at least one input port and a condition input port. The method can also include receiving, at runtime, a customized condition at the condition input port of the stream operator. The method can also include monitoring a first group of one or more tuples from the first stream of tuples at a first window of the stream operator. The method can also include determining whether the first group of one or more tuples at the first window fulfills the customized condition. The method can also include deleting, in response to the first group of one or more tuples fulfilling the customized condition, the first group of one or more tuples.
-
公开(公告)号：US20210263822A1
公开(公告)日：2021-08-26
申请号：US17315340
申请日：2021-05-09
IPC分类号： G06F11/30 , G06F11/34 , G06F16/2458 , G06F16/2455
摘要： Feedback tuples are implemented in a stream computing environment to provide data flow status information for use in detecting, identifying and/or handling data flow anomalies for a stream computing application.
-
公开(公告)号：US10528550B2
公开(公告)日：2020-01-07
申请号：US14692842
申请日：2015-04-22
IPC分类号： G06F16/23 , G06F16/2455
摘要： The method can include receiving the first stream of tuples to be processed by the stream operator hosted by one or more computer processors, the stream operator having at least one input port and a condition input port. The method can also include receiving, at runtime, a customized condition at the condition input port of the stream operator. The method can also include monitoring a first group of one or more tuples from the first stream of tuples at a first window of the stream operator. The method can also include determining whether the first group of one or more tuples at the first window fulfills the customized condition. The method can also include deleting, in response to the first group of one or more tuples fulfilling the customized condition, the first group of one or more tuples.
-
公开(公告)号：US10515080B2
公开(公告)日：2019-12-24
申请号：US15798773
申请日：2017-10-31
IPC分类号： G06F16/2453 , G06F16/2455 , G06F16/2457 , G06F16/2458 , G06F16/9535
摘要： Profiling data characterizing a data streaming application is used to predict data which will need to be retrieved by a processing element during execution of the data streaming application. Data is retrieved responsive to the prediction, in advance of actual demand by the processing element which requires it. Prediction may be based at least in part on upstream tuple contents, and could include other historical data retrieval patterns. In some embodiments, retrieval of predicted data may be delayed so that data is retrieved just in time.
-
公开(公告)号：US20190340180A1
公开(公告)日：2019-11-07
申请号：US16514728
申请日：2019-07-17
IPC分类号： G06F16/2457 , G06F16/2455 , G06F16/2453 , G06F16/2458 , G06F16/9535
摘要： Profiling data characterizing a data streaming application is used to predict data which will need to be retrieved by a processing element during execution of the data streaming application. Data is retrieved responsive to the prediction, in advance of actual demand by the processing element which requires it. Prediction may be based at least in part on upstream tuple contents, and could include other historical data retrieval patterns. In some embodiments, retrieval of predicted data may be delayed so that data is retrieved just in time.
-
公开(公告)号：US20190251081A1
公开(公告)日：2019-08-15
申请号：US16392718
申请日：2019-04-24
IPC分类号： G06F16/23 , G06F16/2455
CPC分类号： G06F16/2379 , G06F16/24568
摘要： The method can include receiving the first stream of tuples to be processed by the stream operator hosted by one or more computer processors, the stream operator having at least one input port and a condition input port. The method can also include receiving, at runtime, a customized condition at the condition input port of the stream operator. The method can also include monitoring a first group of one or more tuples from the first stream of tuples at a first window of the stream operator. The method can also include determining whether the first group of one or more tuples at the first window fulfills the customized condition. The method can also include deleting, in response to the first group of one or more tuples fulfilling the customized condition, the first group of one or more tuples.
-
公开(公告)号：US20190236073A1
公开(公告)日：2019-08-01
申请号：US16381494
申请日：2019-04-11
IPC分类号： G06F16/2455 , G06F16/2457 , H04L29/06 , G06F16/901
CPC分类号： G06F16/24568 , G06F16/24573 , G06F16/9024 , H04L65/601
摘要： Embodiments of the present disclosure include a method, a system, and a computer program product for determining wait times of tuples within a streaming environment. The method includes monitoring one or more tuples being processed within an operator graph where the operator graph includes a first processing element and a queue of the first processing element. The method includes recording a wait time of the one or more tuples within the queue of the first processing element. The method includes recording a processing time time of the one or more tuples within the first processing element. The method includes displaying the wait time and the processing time of the one or more tuples. The method includes optimizing a configuration of the operator graph, in response to recording the processing time of the one or more tuples.
-
公开(公告)号：US10346385B2
公开(公告)日：2019-07-09
申请号：US15265818
申请日：2016-09-14
摘要： Tuple attribute locking is implemented in a stream computing environment to selectively inhibit access to one or more attributes of tuples by stream operators.
-
-
-
-
-
-
-
-
-
搜索结果
505 条记录 (耗时 0.035 秒)
