Complex event processing method, apparatus, and system

    公开(公告)号:US10915822B2

    公开(公告)日:2021-02-09

    申请号:US15622754

    申请日:2017-06-14

    Inventor: Shikai Liu

    Abstract: Embodiments of the present invention relate to the field of communications technologies, and provide a complex event processing method, apparatus, and system, so that when complex event processing is performed, a system requiring a synchronous response provides a synchronous response externally and avoids information flooding. A solution provided by the present invention includes: receiving an input event sent by an event source, where the input event includes an identifier of an object and an event type; acquiring, according to a preset database, M mode rules corresponding to the event type; performing mode matching between the input event and the M mode rules separately to acquire N output events; and if N is greater than or equal to 1, sending at least one piece of event information to a real-time decision apparatus, where each piece of the event information includes Q output events and indication information.

    Event processing method and apparatus

    公开(公告)号:US09658903B2

    公开(公告)日:2017-05-23

    申请号:US15336194

    申请日:2016-10-27

    Inventor: Kaihe Ye Shikai Liu

    CPC classification number: G06F9/542 G06F9/46 G06F17/30551

    Abstract: An event processing method and apparatus which relate to the field of data processing technologies and applicable to a device on which a system having a pattern matching function runs, and reduce memory overheads when a complex event processing (CEP) system performs pattern matching in a complex scenario. The method includes performing, by a state machine instance, matching in a current matching period after an Xth event occurs, detecting, by the state machine instance, whether a quantity of events that have currently occurred is greater than 1 when no result indicating successful matching is obtained, and setting a time when an (X+1)th event occurs as a start time of a next matching period when the quantity of events that have currently occurred is greater than 1, and performing matching again in the next matching period.

    Method and Apparatus for Data Integration
    3.
    发明申请

    公开(公告)号:US20170083555A1

    公开(公告)日:2017-03-23

    申请号:US15370654

    申请日:2016-12-06

    Inventor: Shikai Liu Jie Feng

    CPC classification number: G06F16/2272 G06F16/215 G06F16/254

    Abstract: A data integration method and apparatus, where the method includes sampling a first data source (A) at least twice to obtain a first sample data source (a) and a second sample data source (a′), separately calculating an index of each attribute field of the A, a second data source (B), the a, and the a′, determining a decision value of an attribute field Xi of the A according to a difference degree between an index of an attribute field Xi of the a and an index of each attribute field Xi of the a′, and mapping, to the attribute field Xi of the first data source, an attribute field that is of the B and whose index and the attribute field Xi of the A have a difference degree less than the decision value.

    Complex Event Processing Method, Apparatus, and System

    公开(公告)号:US20170278003A1

    公开(公告)日:2017-09-28

    申请号:US15622754

    申请日:2017-06-14

    Inventor: Shikai Liu

    CPC classification number: G06N5/025 G06F9/44

    Abstract: Embodiments of the present invention relate to the field of communications technologies, and provide a complex event processing method, apparatus, and system, so that when complex event processing is performed, a system requiring a synchronous response provides a synchronous response externally and avoids information flooding. A solution provided by the present invention includes: receiving an input event sent by an event source, where the input event includes an identifier of an object and an event type; acquiring, according to a preset database, M mode rules corresponding to the event type; performing mode matching between the input event and the M mode rules separately to acquire N output events; and if N is greater than or equal to 1, sending at least one piece of event information to a real-time decision apparatus, where each piece of the event information includes Q output events and indication information.

    Event Processing Method and Apparatus
    5.
    发明申请
    Event Processing Method and Apparatus 有权
    事件处理方法和装置

    公开(公告)号:US20170046209A1

    公开(公告)日:2017-02-16

    申请号:US15336194

    申请日:2016-10-27

    Inventor: Kaihe Ye Shikai Liu

    CPC classification number: G06F9/542 G06F9/46 G06F17/30551

    Abstract: An event processing method and apparatus which relate to the field of data processing technologies and applicable to a device on which a system having a pattern matching function runs, and reduce memory overheads when a complex event processing (CEP) system performs pattern matching in a complex scenario. The method includes performing, by a state machine instance, matching in a current matching period after an Xth event occurs, detecting, by the state machine instance, whether a quantity of events that have currently occurred is greater than 1 when no result indicating successful matching is obtained, and setting a time when an (X+1)th event occurs as a start time of a next matching period when the quantity of events that have currently occurred is greater than 1, and performing matching again in the next matching period.

    Abstract translation: 涉及数据处理技术领域并适用于具有模式匹配功能的系统的设备运行的事件处理方法和装置,并且当复杂事件处理(CEP)系统在复合体中执行模式匹配时减少存储器开销 情景。 该方法包括:通过状态机实例在第X个事件发生之后的当前匹配周期中执行匹配,由状态机实例检测当没有指示成功匹配的结果时,当前发生的事件的数量是否大于1 并且当当前发生的事件量大于1时,将第(X + 1)事件作为下一个匹配周期的开始时间发生的时间设置,并且在下一个匹配周期中再次执行匹配。

    Method and apparatus for identifying re-subscribed user
    6.
    发明授权
    Method and apparatus for identifying re-subscribed user 有权
    用于识别重新订阅的用户的方法和装置

    公开(公告)号:US09398441B2

    公开(公告)日:2016-07-19

    申请号:US14728470

    申请日:2015-06-02

    Abstract: Embodiments of the present invention provide a method for identifying a re-subscribed user and a corresponding apparatus. Based on call records of a user, communication numbers of the user which meet a preset condition are identified. Then a re-subscribed user is identified by calculating a communication number coincidence rate between users within different charging periods. In accordance with the present invention, call records of users are used as a basis of comparative analysis, thereby improving an accuracy rate of identifying a re-subscribed user; a new method is practiced to sequenced communication numbers of a user and group communication records, thereby effectively reducing the number of calculations and improving calculation efficiency.

    Abstract translation: 本发明的实施例提供了一种用于识别重新订阅的用户和相应装置的方法。 基于用户的呼叫记录,识别满足预设条件的用户的通信号码。 然后,通过计算不同充电时段内的用户之间的通信号码一致率来识别重新订阅的用户。 根据本发明,使用用户的呼叫记录作为比较分析的基础,从而提高识别重新订阅用户的准确率; 实施用户和组通信记录的顺序通信号码的新方法,从而有效减少计算次数并提高计算效率。

    METHOD AND APPARATUS FOR IDENTIFYING RE-SUBSCRIBED USER
    7.
    发明申请
    METHOD AND APPARATUS FOR IDENTIFYING RE-SUBSCRIBED USER 有权
    用于识别重新订阅用户的方法和装置

    公开(公告)号:US20150264556A1

    公开(公告)日:2015-09-17

    申请号:US14728470

    申请日:2015-06-02

    Abstract: Embodiments of the present invention provide a method for identifying a re-subscribed user and a corresponding apparatus. Based on call records of a user, communication numbers of the user which meet a preset condition are identified. Then a re-subscribed user is identified by calculating a communication number coincidence rate between users within different charging periods. In accordance with the present invention, call records of users are used as a basis of comparative analysis, thereby improving an accuracy rate of identifying a re-subscribed user; a new method is practiced to sequenced communication numbers of a user and group communication records, thereby effectively reducing the number of calculations and improving calculation efficiency.

    Abstract translation: 本发明的实施例提供了一种用于识别重新订阅的用户和相应装置的方法。 基于用户的呼叫记录,识别满足预设条件的用户的通信号码。 然后,通过计算不同充电时段内的用户之间的通信号码一致率来识别重新订阅的用户。 根据本发明,使用用户的呼叫记录作为比较分析的基础,从而提高识别重新订阅用户的准确率; 实施用户和组通信记录的顺序通信号码的新方法,从而有效减少计算次数并提高计算效率。

Patent Agency Ranking