-
Patent Agency Ranking
公开(公告)号：US09916182B2
公开(公告)日：2018-03-13
申请号：US14331506
申请日：2014-07-15
Applicant: Huawei Technologies Co., Ltd.
Inventor： Jianfeng Qian
CPC classification number: G06F9/5027 , G06F9/5044 , G06F9/505 , G06F11/3404 , G06F11/3433 , G06F11/3466
Abstract: The present invention discloses a method and an apparatus for allocating a stream processing unit, and pertains to the field of communications technologies. The method includes: obtaining a parallelism degree and a resource usage rate of a stream processing component on each computing node, and determining the number of stream processing units according to the parallelism degree; generating a stream processing unit to be allocated, and determining a resource usage rate of the stream processing component as a resource usage rate of a corresponding stream processing unit; and allocating, according to a processing capability of the computing node on which the stream processing component is located and a resource usage rate of an allocated stream processing unit, the stream processing unit to be allocated to a corresponding computing node. According to the present invention, the steam data processing efficiency of a distributed stream processing system is improved.
-
公开(公告)号：US09692667B2
公开(公告)日：2017-06-27
申请号：US14744815
申请日：2015-06-19
Applicant: Huawei Technologies Co., Ltd.
Inventor： Jianfeng Qian
CPC classification number: H04L41/5054 , G06F9/5027 , G06F9/5061 , H04L65/4069 , H04L65/605
Abstract: The invention discloses a stream processing method, which includes: receiving a first stream processing task including one or more stream processing components, a data input and output relationship of the stream processing component, and an identifier of a stream data source; calculating a computing resource required by each stream processing component; and if the first stream processing task includes a first stream processing component which does not meet a preset constraint condition, duplicating the first stream processing component to obtain at least one second stream processing component, so that the data may be allocated to the first stream processing component and the second stream processing component(s), which reduce a probability that system instability and a data processing fault are caused.
-
公开(公告)号：US10116759B2
公开(公告)日：2018-10-30
申请号：US14948993
申请日：2015-11-23
Applicant: Huawei Technologies Co., Ltd.
Inventor： Wei Fan , Jianfeng Qian , Yadong Mu
Abstract: A method and an apparatus for identifying a state of a user of a social network. The identification method includes acquiring a user-event similarity of a user regarding a new event; identifying whether the user is a silent user or a non-activated user according to the user-event similarity; and determining whether the silent user or the non-activated user on the social network is finally in an activated state or a non-activated state. In the foregoing manner, a novel user state model of a social network is designed in the present disclosure, the model includes an activated state, a non-activated state and an unstable silent state, and a final state of a user is inferred precisely under full and comprehensive consideration of factors that may affect the state of the user, such that the state of the user can be accurately and precisely monitored.
-
4.发明申请Method, Apparatus and Computer for Identifying State of User of Social Network 审中-公开用于识别社交网络用户状态的方法，设备和计算机公开(公告)号：US20160088105A1
公开(公告)日：2016-03-24
申请号：US14948993
申请日：2015-11-23
Applicant: Huawei Technologies Co., Ltd.
Inventor： Wei Fan , Jianfeng Qian , Yadong Mu
Abstract: A method and an apparatus for identifying a state of a user of a social network. The identification method includes acquiring a user-event similarity of a user regarding a new event; identifying whether the user is a silent user or a non-activated user according to the user-event similarity; and determining whether the silent user or the non-activated user on the social network is finally in an activated state or a non-activated state. In the foregoing manner, a novel user state model of a social network is designed in the present disclosure, the model includes an activated state, a non-activated state and an unstable silent state, and a final state of a user is inferred precisely under full and comprehensive consideration of factors that may affect the state of the user, such that the state of the user can be accurately and precisely monitored.
Abstract translation: 一种用于识别社交网络的用户的状态的方法和装置。 识别方法包括获取用户关于新事件的用户事件相似性; 根据所述用户事件相似性来识别所述用户是静默用户还是非激活用户; 以及确定所述社交网络上的无声用户或未激活的用户是否处于激活状态或非激活状态。 以上述方式，在本公开中设计了社交网络的新型用户状态模型，该模型包括激活状态，非激活状态和不稳定静音状态，并且精确地推断用户的最终状态 充分和全面地考虑可能影响用户状态的因素，使得用户的状态可以被准确和精确地监视。
-
公开(公告)号：US20150026347A1
公开(公告)日：2015-01-22
申请号：US14331506
申请日：2014-07-15
Applicant: Huawei Technologies Co., Ltd.
Inventor： Jianfeng Qian
IPC: G06F9/50
CPC classification number: G06F9/5027 , G06F9/5044 , G06F9/505 , G06F11/3404 , G06F11/3433 , G06F11/3466
Abstract: The present invention discloses a method and an apparatus for allocating a stream processing unit, and pertains to the field of communications technologies. The method includes: obtaining a parallelism degree and a resource usage rate of a stream processing component on each computing node, and determining the number of stream processing units according to the parallelism degree; generating a stream processing unit to be allocated, and determining a resource usage rate of the stream processing component as a resource usage rate of a corresponding stream processing unit; and allocating, according to a processing capability of the computing node on which the stream processing component is located and a resource usage rate of an allocated stream processing unit, the stream processing unit to be allocated to a corresponding computing node. According to the present invention, the steam data processing efficiency of a distributed stream processing system is improved.
Abstract translation: 本发明公开了一种用于分配流处理单元的方法和装置，并且涉及通信技术领域。 该方法包括：获得每个计算节点上的流处理组件的并行度和资源使用率，并根据并行度确定流处理单元的数量; 生成要分配的流处理单元，并且确定流处理组件的资源使用率作为相应流处理单元的资源使用率; 以及根据流处理组件所在的计算节点的处理能力和所分配的流处理单元的资源使用率来分配要分配给相应计算节点的流处理单元。 根据本发明，提高了分布式流处理系统的蒸汽数据处理效率。
-
-
-
-
Search Results
5
records
(took 0.016 seconds)
