公开(公告)号：US20150378797A1

公开(公告)日：2015-12-31

申请号：US14849074

申请日：2015-09-09

Applicant: Huawei Technologies Co., Ltd.

Inventor： Songshan Zhang ,  Fengbin Fang ,  Yuzhang Li

IPC: G06F9/54

CPC classification number: G06F9/542 ,  G06F17/30516

Abstract: An event processing method in a stream processing system includes matching a basic event with basic events stored in engine memories corresponding to each matching mode in a rule engine, to determine an engine memory including the basic event, and when it is determined that the engine memory including the basic event is an engine memory corresponding to a full-loop mode, inputting the basic event into the full-loop mode of the rule engine, adding a full-loop identifier to the basic event. This method implements classification processing on complex events by using different matching modes of the rule engine, improving performance of processing a complex event in an Event Stream Processing (ESP) service processing process.

Abstract translation: 流处理系统中的事件处理方法包括将基本事件与存储在与规则引擎中的每个匹配模式相对应的引擎存储器中的基本事件进行匹配，以确定包括基本事件的引擎存储器，以及何时确定引擎存储器 包括基本事件是对应于全循环模式的引擎存储器，将基本事件输入规则引擎的全环模式，向基本事件添加全环标识符。 该方法通过使用规则引擎的不同匹配模式实现对复杂事件的分类处理，提高了处理事件流处理（ESP）服务处理过程中复杂事件的性能。

公开(公告)号：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.

公开(公告)号：US09483332B2

公开(公告)日：2016-11-01

申请号：US14849074

申请日：2015-09-09

Applicant: Huawei Technologies Co., Ltd.

Inventor： Songshan Zhang ,  Fengbin Fang ,  Yuzhang Li

IPC: G06F9/54 ,  G06F17/30

CPC classification number: G06F9/542 ,  G06F17/30516

Abstract: An event processing method in a stream processing system includes matching a basic event with basic events stored in engine memories corresponding to each matching mode in a rule engine, to determine an engine memory including the basic event, and when it is determined that the engine memory including the basic event is an engine memory corresponding to a full-loop mode, inputting the basic event into the full-loop mode of the rule engine, adding a full-loop identifier to the basic event. This method implements classification processing on complex events by using different matching modes of the rule engine, improving performance of processing a complex event in an Event Stream Processing (ESP) service processing process.

Abstract translation: 流处理系统中的事件处理方法包括将基本事件与存储在与规则引擎中的每个匹配模式相对应的引擎存储器中的基本事件进行匹配，以确定包括基本事件的引擎存储器，以及何时确定引擎存储器 包括基本事件是对应于全循环模式的引擎存储器，将基本事件输入规则引擎的全环模式，向基本事件添加全环标识符。 该方法通过使用规则引擎的不同匹配模式实现对复杂事件的分类处理，提高了处理事件流处理（ESP）服务处理过程中复杂事件的性能。