-
公开(公告)号：US10255917B2
公开(公告)日：2019-04-09
申请号：US15475772
申请日：2017-03-31
摘要： A computer-implemented method includes exchanging device data, associated with a first participating user device, with the one or more second participating user devices; receiving audio data associated with a voice command; exchanging the audio data with the one or more second participating user devices; identifying, by the first participating user device, a voice command based on exchanging the audio data; determining which one of the first participating user device or the one or more second participating user devices should respond to the voice command based on details of the voice command and the exchanging the device data; responding to the voice command based on determining that the first participating user device should respond to the voice command; and signaling a particular second participating user device to respond to the voice command based on determining that the particular second participating user device should respond to the voice command.
-
公开(公告)号：US20180341683A1
公开(公告)日：2018-11-29
申请号：US16049866
申请日：2018-07-31
IPC分类号： G06F17/30
CPC分类号： G06F16/24568 , G06F3/0481 , G06F3/0604 , G06F3/0634 , G06F3/0653 , G06F3/0673
摘要： Managing a streaming environment of an operator graph by performing corrective actions based on a threshold of changes in state being reached. An operator graph includes states of information stored within a memory of a first processing element configured to process a set of tuples. The memory of the first processing element is monitored. A change in the information from a first state to a second state is identified, based on the monitoring. The change from the first state to the second state is recorded. A determination is made if the change from the first state to the second state has caused a threshold of changes between the states of the information to be reached. A corrective action is performed that modifies a configuration of the operator graph in response to the threshold of changes between the states of the information being reached.
-
公开(公告)号：US10037356B2
公开(公告)日：2018-07-31
申请号：US14841745
申请日：2015-09-01
发明人： Ryan K. Cradick , Jason A. Nikolai
IPC分类号： G06F17/30
CPC分类号： G06F16/24568 , G06F16/252
摘要： A stream of tuples to be processed by a plurality processing elements executing on two or more compute nodes is received. Each compute node stores one or more of the processing elements having one or more stream operators. It is determined whether an overhead parameter associated with a first streams service located at a first stream operator is outside of a first overhead criterion. The first streams service is ended at the first stream operator and a second streams service is instantiated at a second stream operator when the overhead parameter associated with the first streams service is outside of the first overhead criterion. The second stream operator is different from the first stream operator. The method may include determining whether the first streams service samples a first data attribute of tuples or measures performance.
-
公开(公告)号：US09946631B1
公开(公告)日：2018-04-17
申请号：US15705330
申请日：2017-09-15
CPC分类号： G06F11/366 , G06F9/4843 , G06F17/30516
摘要： Disclosed aspects relate to debug management in a distributed batch data processing environment which uses a shared pool of configurable computing resources. A debug configuration to fire a breakpoint based on an achievement of a debug criterion may be initiated in the distributed batch data processing environment. A data block may be detected in the distributed batch data processing environment. The data block may be analyzed with respect to the debug criterion by a debug management engine. Achievement of the debug criterion by the data block may be determined by the debug management engine. In response to determining the achievement of the debug criterion by the data block, the breakpoint may be fired based on the achievement of the debug criterion.
-
公开(公告)号：US20170337067A1
公开(公告)日：2017-11-23
申请号：US15159358
申请日：2016-05-19
CPC分类号： G06F9/46 , G06F9/5005 , G06F11/30
摘要： Adjusting a computing environment for processing a data stream involves identifying one or more dummy tuples in the data stream processed by the computing environment. Propagation of the identified dummy tuples to be processed through a plurality of operators in the computing environment is controlled in order to control adjustment of the computing environment. The computing environment is adjusted based on the processing of the propagated dummy tuples.
-
公开(公告)号：US20170220631A1
公开(公告)日：2017-08-03
申请号：US15488788
申请日：2017-04-17
IPC分类号： G06F17/30
CPC分类号： G06F16/2379 , G06F3/013 , G06F3/0481 , G06F3/04842 , G06F9/451 , G06F16/23 , G06F16/2393 , G06F16/3326 , G06F16/3334 , G06F16/335 , G06F16/34 , G06F17/2247
摘要： A mechanism is provided to implement an action for an intended selection of content element due to dynamically shifting content. For a set of content elements displayed in a user interface, changes to locations of the set of content elements and a set of user interactions with the set of content elements are analyzed. A determination is made as to whether a loading of a dynamic content element will cause a user's intended selection of the content element within the set of content elements to be erroneously performed. Responsive to determining that the loading of the dynamic content element will cause the user's intended selection of the content element to be erroneously performed, the action for the intended selection of the content element that takes into account the loading of the dynamic content element is implemented.
-
公开(公告)号：US20170060959A1
公开(公告)日：2017-03-02
申请号：US14841745
申请日：2015-09-01
发明人： Ryan K. Cradick , Jason A. Nikolai
IPC分类号： G06F17/30
CPC分类号： G06F17/30516 , G06F17/3056
摘要： A stream of tuples to be processed by a plurality processing elements executing on two or more compute nodes is received. Each compute node stores one or more of the processing elements having one or more stream operators. It is determined whether an overhead parameter associated with a first streams service located at a first stream operator is outside of a first overhead criterion. The first streams service is ended at the first stream operator and a second streams service is instantiated at a second stream operator when the overhead parameter associated with the first streams service is outside of the first overhead criterion. The second stream operator is different from the first stream operator. The method may include determining whether the first streams service samples a first data attribute of tuples or measures performance.
摘要翻译： 接收要由在两个或多个计算节点上执行的多个处理元件处理的元组流。 每个计算节点存储具有一个或多个流操作符的一个或多个处理元件。 确定与位于第一流操作符处的第一流服务相关联的开销参数是否在第一开销标准之外。 第一流服务在第一流服务器处结束，并且当与第一流服务相关联的开销参数在第一开销标准之外时，第二流服务被实例化在第二流服务器。 第二流运算符与第一流运算符不同。 该方法可以包括确定第一流服务是否采用元组的第一数据属性或测量性能。
-
公开(公告)号：US20170033979A1
公开(公告)日：2017-02-02
申请号：US14815430
申请日：2015-07-31
CPC分类号： G06F11/1402 , G06F11/3006 , G06F11/3409 , G06F2201/805 , H04L41/0654 , H04L41/0672 , H04L41/0816 , H04L43/08 , H04L43/0817 , H04L67/025
摘要： A streams manager intelligently restores multiple consistent regions of streaming applications in a streaming environment to increase performance and reduce overloading of other operators and resources. The streams manager detects a failure that affects multiple consistent regions and determines a preferred schedule to restore the multiple consistent regions by analyzing the relationships of the operators and resources associated with the multiple consistent regions. The streams manager may create a dependency graph that maps the interrelationships of the operators and resources associated with the consistent regions of the streaming application and then consult the dependency graph to determine the schedule to restore the multiple consistent regions affected by the failure.
摘要翻译： 流管理器在流媒体环境中智能地恢复流应用的多个一致区域，以提高性能并减少其他运营商和资源的超载。 流管理器检测到影响多个一致区域的故障，并且通过分析与多个一致区域相关联的运营商和资源的关系来确定优选调度以恢复多个一致区域。 流管理器可以创建依赖图，其映射与流应用的一致区域相关联的运算符和资源的相互关系，然后参考依赖关系图以确定恢复受故障影响的多个一致区域的调度。
-
公开(公告)号：US20170031764A1
公开(公告)日：2017-02-02
申请号：US14814220
申请日：2015-07-30
CPC分类号： G06F11/1402 , G06F11/3006 , G06F11/3409 , G06F2201/805 , H04L41/0654 , H04L41/0672 , H04L41/0816 , H04L43/08 , H04L43/0817 , H04L67/025
摘要： A streams manager intelligently restores multiple consistent regions of streaming applications in a streaming environment to increase performance and reduce overloading of other operators and resources. The streams manager detects a failure that affects multiple consistent regions and determines a preferred schedule to restore the multiple consistent regions by analyzing the relationships of the operators and resources associated with the multiple consistent regions. The streams manager may create a dependency graph that maps the interrelationships of the operators and resources associated with the consistent regions of the streaming application and then consult the dependency graph to determine the schedule to restore the multiple consistent regions affected by the failure.
-
公开(公告)号：US09389911B2
公开(公告)日：2016-07-12
申请号：US13682008
申请日：2012-11-20
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.
摘要翻译： 描述了通过改变通过处理元件的速率数据流来消除分布式系统中的背压的技术。 当处理元件中的数据吞吐量开始减少时，例如，如果将新的处理元素添加到操作图表中，或者分布式系统是否需要处理更多数据，就会发生背压。 背压指示器（当前或将来）可能被监控。 一旦确定了当前的背压或潜在背压，则可以改变操作者图或数据速率以减轻背压。 例如，处理元件可以将其发送到处理元件的数据速率降低在操作符图形中的下游，或者可以消除处理元件和/或数据路径。 在一个实施例中，可以对处理元件和关联数据路径进行优先排列，从而保持更重要的执行路径。
-
-
-
-
-
-
-
-
-
搜索结果
67 条记录 (耗时 0.029 秒)
