-
公开(公告)号:US10831637B2
公开(公告)日:2020-11-10
申请号:US15136889
申请日:2016-04-23
摘要: Aspects of the disclosure relate to managing a set of warning data with respect to an execution phase in a computing environment. In embodiments, the computing environment may include a distributed computing environment or a stream computing environment. The set of warning data may be detected with respect to the execution phase. In embodiments, the set of warning data may be coupled with a computing artifact. In embodiments, the computing artifact may include a compilation which has a computing object in association with the set of warning data. Using the set of warning data, an execution action which pertains to the computing artifact may be determined. In embodiments, the execution action may include a code deployment to a set of computing units, a run-time check modification, or a process attribute modification. The execution action which pertains to the computing artifact may be performed.
-
公开(公告)号:US10671490B2
公开(公告)日:2020-06-02
申请号:US16357304
申请日:2019-03-18
IPC分类号: G06F11/14 , G06F16/901 , G06F16/2455
摘要: A variable checkpoint mechanism in a streams manager checkpoints a streaming application based on periodic time periods for checkpoints. The variable checkpoint mechanism can take a checkpoint before a periodic time period ends when a spike is coming, or can take a checkpoint after the periodic time period ends when there is backpressure in a consistent region of the streaming application. When there is no anticipated spike coming and when there is no backpressure in a consistent region of the streaming application, the checkpoint is performed at the normal end of the periodic time period for checkpoints. In this manner the checkpoint timing of the variable checkpoint mechanism can be adjusted real-time to minimize the negative impact of checkpointing on the performance of the streaming application.
-
公开(公告)号:US20200169587A1
公开(公告)日:2020-05-28
申请号:US16776595
申请日:2020-01-30
摘要: A method, computer program product, and computing device for monitoring network activity associated with streaming a data load through a stream application including a plurality of stream operators deployed on a plurality of computing devices. One or more stream operators with one or more external connections may be identified from the plurality of stream operators. The identified one or more stream operators may be deployed based upon, at least in part, the one or more external connections.
-
公开(公告)号:US10536502B2
公开(公告)日:2020-01-14
申请号:US16391715
申请日:2019-04-23
IPC分类号: G06F15/173 , H04L29/06 , H04L29/08 , H04L12/26 , H04L12/721 , G06F9/50 , G06F11/14 , G06F9/46 , G06F16/2455 , H04L12/24 , H04L12/803 , G06F9/48 , H04N21/00
摘要: Disclosed aspects relate to checkpointing a set of stream computing data with respect to a stream computing environment having a set of windowed stream operators including both a first windowed stream operator and a second windowed stream operator. It may be identified that the first windowed stream operator has a first subset of the set of stream computing data. It may be identified that the second windowed stream operator has the first subset of the set of stream computing data. It may be determined to checkpoint the first subset of the set of stream computing data without a redundant checkpoint related to the first and second windowed stream operators. The set of stream computing data may be checkpointed without the redundant checkpoint of the first subset of the set of stream computing data.
-
公开(公告)号:US10375137B2
公开(公告)日:2019-08-06
申请号:US15633191
申请日:2017-06-26
IPC分类号: G06F11/14 , H04L29/06 , G06F16/901 , G06F16/2455 , H04L12/26 , H04L29/08
摘要: A variable checkpoint mechanism in a streams manager checkpoints a streaming application based on periodic time periods for checkpoints. The variable checkpoint mechanism can take a checkpoint early before a periodic time period ends or late after the periodic time period ends based on predicted size of one or more tuple windows in the streaming application. The time for taking the checkpoint can be selected based on multiple checkpoint timing criteria, which include storage requirement for the checkpoint and predicted backpressure in the flow graph. In this manner the checkpoint timing of the variable checkpoint mechanism can be adjusted real-time to minimize the negative impact of checkpointing on the performance of the streaming application.
-
公开(公告)号:US10318496B2
公开(公告)日:2019-06-11
申请号:US15954684
申请日:2018-04-17
IPC分类号: G06F17/30 , G06F16/21 , G06F16/2455
摘要: Disclosed aspects relate to managing a database management system (DBMS) using a set of stream computing data derived from a stream computing environment. The set of stream computing data which indicates a set of stream computing environment statistics may be collected with respect to the stream computing environment. A proactive database management operation may be determined for performance with respect to the DBMS based on the set of stream computing data which indicates the set of stream computing environment statistics. The proactive database management operation may be performed to manage the DBMS using the set of stream computing data.
-
公开(公告)号:US10255919B2
公开(公告)日:2019-04-09
申请号:US15807188
申请日:2017-11-08
IPC分类号: G10L15/00 , G10L15/26 , G06F17/27 , G10L15/28 , G10L15/22 , H04L29/06 , H04M7/00 , G10L15/08
摘要: A streams controller monitors multiple data streams with speech of a conversation with multiple speakers and uses text analytics and diaritization to identify speakers by their role in the conversation. Diaritization is applied to the audio of a data stream to associate a speaker with an SSRC from the data stream and a speaker identification (ID). The streams controller then runs text analytics on a text version of the speaker's speech to determine a speaker role for the speaker. The speaker role can be used to efficiently monitor conversations in a data stream to provide additional services. For example, speaker role can be used to analyze calls in a call center and provide services such as a transcript of conversations or enhanced customer support.
-
公开(公告)号:US10169377B2
公开(公告)日:2019-01-01
申请号:US15954654
申请日:2018-04-17
IPC分类号: G06F17/30
摘要: Disclosed aspects relate to managing a database management system (DBMS) using a set of stream computing data derived from a stream computing environment. The set of stream computing data which indicates a set of stream computing environment statistics may be collected with respect to the stream computing environment. A proactive database management operation may be determined for performance with respect to the DBMS based on the set of stream computing data which indicates the set of stream computing environment statistics. The proactive database management operation may be performed to manage the DBMS using the set of stream computing data.
-
公开(公告)号:US20180336899A1
公开(公告)日:2018-11-22
申请号:US15807188
申请日:2017-11-08
CPC分类号: G10L15/265 , G06F17/277 , G06F17/279 , G10L15/08 , G10L15/22 , G10L15/26 , G10L15/285 , G10L17/00 , H04L65/1083 , H04L65/608 , H04M3/51 , H04M7/006 , H04M2201/40 , H04M2203/401
摘要: A streams controller monitors multiple data streams with speech of a conversation with multiple speakers and uses text analytics and diaritization to identify speakers by their role in the conversation. Diaritization is applied to the audio of a data stream to associate a speaker with an SSRC from the data stream and a speaker identification (ID). The streams controller then runs text analytics on a text version of the speaker's speech to determine a speaker role for the speaker. The speaker role can be used to efficiently monitor conversations in a data stream to provide additional services. For example, speaker role can be used to analyze calls in a call center and provide services such as a transcript of conversations or enhanced customer support.
-
公开(公告)号:US20180336898A1
公开(公告)日:2018-11-22
申请号:US15598409
申请日:2017-05-18
CPC分类号: G10L15/265 , G06F17/277 , G06F17/279 , G10L15/08 , G10L15/22 , G10L15/26 , G10L15/285 , G10L17/00 , H04L65/1083 , H04L65/608 , H04M3/51 , H04M7/006 , H04M2201/40 , H04M2203/401
摘要: A streams controller monitors multiple data streams with speech of a conversation with multiple speakers and uses text analytics and diaritization to identify speakers by their role in the conversation. Diaritization is applied to the audio of a data stream to associate a speaker with an SSRC from the data stream and a speaker identification (ID). The streams controller then runs text analytics on a text version of the speaker's speech to determine a speaker role for the speaker. The speaker role can be used to efficiently monitor conversations in a data stream to provide additional services. For example, speaker role can be used to analyze calls in a call center and provide services such as a transcript of conversations or enhanced customer support.
-
-
-
-
-
-
-
-
-