公开(公告)号：US09461888B2

公开(公告)日：2016-10-04

申请号：US14088665

申请日：2013-11-25

Applicant: Huawei Technologies Co., Ltd.

Inventor： Hewei Liu ,  Yunlong Shi

IPC: G06F15/177 ,  H04L12/24 ,  H04L29/06

CPC classification number: H04L41/0893 ,  H04L41/20 ,  H04L63/0263

Abstract: A policy processing method and network device. The method includes: performing a mixed orchestration on all service rules corresponding to multiple services, so as to construct multiple condition sets; performing, according to the constructed multiple condition sets, unified condition matching on packet feature information of a received network packet, and outputting a condition matching result set; and calling, a service application to execute a policy action corresponding to each condition identifier in the condition matching result set. In solutions of the embodiments of the present invention, by performing a mixed orchestration on multiple service rules, all service rules are organized in a unified manner, information required by all services is extracted in one packet scanning process, and only one matching and rule verification process is required. Thereby, redundant operations between multiple services are reduced, and device integration and performance are improved.

Abstract translation: 策略处理方法和网络设备。 该方法包括：对与多个业务相对应的所有业务规则进行混合编排，构建多个条件集; 根据构造的多个条件集合，对接收到的网络分组的分组特征信息进行统一条件匹配，并输出条件匹配结果集; 并且调用服务应用来执行与条件匹配结果集中的每个条件标识符相对应的策略动作。 在本发明实施例的解决方案中，通过对多个业务规则进行混合编排，所有业务规则以统一的方式组织，所有业务所需的信息在一个分组扫描过程中被提取，只有一个匹配和规则验证 过程是必需的。 因此，减少了多个业务之间的冗余操作，提高了设备​​集成度和性能。

公开(公告)号：US10225150B2

公开(公告)日：2019-03-05

申请号：US15269381

申请日：2016-09-19

Applicant: HUAWEI TECHNOLOGIES CO., LTD.

Inventor： Hewei Liu ,  Yunlong Shi

IPC: G06F15/173 ,  H04L12/24 ,  H04L29/06

Abstract: A policy processing method and network device. The method includes: performing a mixed orchestration on all service rules corresponding to multiple services, so as to construct multiple condition sets; performing, according to the constructed multiple condition sets, unified condition matching on packet feature information of a received network packet, and outputting a condition matching result set; and calling, a service application to execute a policy action corresponding to each condition identifier in the condition matching result set. In solutions of the embodiments of the present invention, by performing a mixed orchestration on multiple service rules, all service rules are organized in a unified manner, information required by all services is extracted in one packet scanning process, and only one matching and rule verification process is required. Thereby, redundant operations between multiple services are reduced, and device integration and performance are improved.

公开(公告)号：US20180367584A1

公开(公告)日：2018-12-20

申请号：US16112236

申请日：2018-08-24

Applicant: HUAWEI TECHNOLOGIES CO.,LTD.

Inventor： Yunlong Shi ,  Mingzhen Xia ,  Cheng He

IPC: H04L29/06 ,  G06F9/50 ,  H04L12/911 ,  H04L12/26

Abstract: A stream computer system and a method for processing a data stream in a stream computing system are disclosed. The method includes a first working node invokes at least one execution unit to process a data stream according to an initial parallelism degree, a control node collects information reflecting data traffic between the first working node and a second working node, and information reflecting data processing speed of the first working node, determines an optimized parallelism degree for the first working node according to the collected information, and adjusts the parallelism degree of the first working node to be consistent with the optimized parallelism degree.

公开(公告)号：US10097595B2

公开(公告)日：2018-10-09

申请号：US15257722

申请日：2016-09-06

Applicant: Huawei Technologies Co., Ltd.

Inventor： Yunlong Shi ,  Mingzhen Xia ,  Cheng He

IPC: H04L29/06 ,  G06F9/50 ,  H04L12/26 ,  H04L12/911

Abstract: A stream computer system and a method for processing a data stream in a stream computing system are disclosed. In an embodiment, the method includes collecting data traffic information between each working node and other working nodes and processing speed information for each working node, determining an optimized parallelism degree for each working node according to the collected data traffic information and processing speed information and adjusting a parallelism degree of the working node according to the optimized parallelism degree of the working node.

公开(公告)号：US20220012288A1

公开(公告)日：2022-01-13

申请号：US17486066

申请日：2021-09-27

Applicant: Huawei Technologies Co., Ltd.

Inventor： Yunlong Shi ,  Fengbin Fang

IPC: G06F16/901 ,  G06F16/2455 ,  G06F16/28 ,  H04L29/08

Abstract: A stream computing method performed by a manager node includes obtaining input channel description information, a structured query language (SQL) statement, and output channel description information, dynamically generating a data flow diagram according to the input channel description information, the SQL statement, and the output channel description information, and controlling, according to the data flow diagram, a worker node to execute a stream computing task.

公开(公告)号：US11132402B2

公开(公告)日：2021-09-28

申请号：US16261014

申请日：2019-01-29

Applicant: Huawei Technologies Co., Ltd.

Inventor： Yunlong Shi ,  Fengbin Fang

IPC: G06F16/901 ,  G06F16/2455 ,  G06F16/28 ,  H04L29/08

Abstract: A stream computing method applicable to a system including a manager node and a worker node, where the manager node, obtains input channel description information, a structured query language (SQL) statement, and output channel description information, dynamically generates a data stream graph according to the input channel description information, the SQL statement, and the output channel description information, and controlling, according to the data stream graph, a worker node to execute a stream computing task.

公开(公告)号：US20190155850A1

公开(公告)日：2019-05-23

申请号：US16261014

申请日：2019-01-29

Applicant: Huawei Technologies Co., Ltd.

Inventor： Yunlong Shi ,  Fengbin Fang

IPC: G06F16/901 ,  G06F16/2455 ,  H04L29/08

Abstract: A stream computing method applicable to a system including a manager node and a worker node, where the manager node, obtains input channel description information, a structured query language (SQL) statement, and output channel description information, dynamically generates a data stream graph according to the input channel description information, the SQL statement, and the output channel description information, and controlling, according to the data stream graph, a worker node to execute a stream computing task.

公开(公告)号：US20160373494A1

公开(公告)日：2016-12-22

申请号：US15257722

申请日：2016-09-06

Applicant: Huawei Technologies Co., Ltd.

Inventor： Yunlong Shi ,  Mingzhen Xia ,  Cheng He

IPC: H04L29/06 ,  H04L12/911 ,  H04L12/26

CPC classification number: H04L65/4015 ,  G06F9/5083 ,  H04L43/045 ,  H04L47/828

Abstract: A stream computer system and a method for processing a data stream in a stream computing system are disclosed. In an embodiment, the method includes collecting data traffic information between each working node and other working nodes and processing speed information for each working node, determining an optimized parallelism degree for each working node according to the collected data traffic information and processing speed information and adjusting a parallelism degree of the working node according to the optimized parallelism degree of the working node.

Abstract translation: 公开了一种流计算机系统和用于在流计算系统中处理数据流的方法。 在一个实施例中，该方法包括：在每个工作节点和其他工作节点之间收集数据业务信息，并为每个工作节点处理速度信息，根据收集的数据业务信息和处理速度信息确定每个工作节点的优化并行度，并调整 根据工作节点的优化并行度，工作节点的并行度。

公开(公告)号：US20140156823A1

公开(公告)日：2014-06-05

申请号：US14088665

申请日：2013-11-25

Applicant: Huawei Technologies Co., Ltd.

Inventor： Hewei Liu ,  Yunlong Shi

IPC: H04L12/24

CPC classification number: H04L41/0893 ,  H04L41/20 ,  H04L63/0263

Abstract: A policy processing method and network device. The method includes: performing a mixed orchestration on all service rules corresponding to multiple services, so as to construct multiple condition sets; performing, according to the constructed multiple condition sets, unified condition matching on packet feature information of a received network packet, and outputting a condition matching result set; and calling, a service application to execute a policy action corresponding to each condition identifier in the condition matching result set. In solutions of the embodiments of the present invention, by performing a mixed orchestration on multiple service rules, all service rules are organized in a unified manner, information required by all services is extracted in one packet scanning process, and only one matching and rule verification process is required. Thereby, redundant operations between multiple services are reduced, and device integration and performance are improved.

Abstract translation: 策略处理方法和网络设备。 该方法包括：对与多个业务相对应的所有业务规则进行混合编排，构建多个条件集; 根据构造的多个条件集合，对接收到的网络分组的分组特征信息进行统一条件匹配，并输出条件匹配结果集; 并且调用服务应用来执行与条件匹配结果集中的每个条件标识符相对应的策略动作。 在本发明实施例的解决方案中，通过对多个业务规则进行混合编排，所有业务规则以统一的方式组织，所有业务所需的信息在一个分组扫描过程中被提取，只有一个匹配和规则验证 过程是必需的。 因此，减少了多个业务之间的冗余操作，提高了设备​​集成度和性能。