-
公开(公告)号:US10594760B2
公开(公告)日:2020-03-17
申请号:US15452257
申请日:2017-03-07
Applicant: Futurewei Technologies, Inc.
Inventor: Habib Madani , Sanqi Li
Abstract: Various embodiments include devices and methods structured to provide an intelligent event processing offload, which can facilitate an efficient, geo-distributed tiered scalable event streaming and processing interconnect through an embedded adapter interconnect. Event streams received in a data handler from one or more networks can be separated into partitions. The loading of the event streams into the partitions can be tracked to balance the loading by controlling the number of partitions used. Packets of each partition can be sent to a respective reactive router that resides in a controlling application for further processing. Additional devices, systems, and methods can be implemented in a variety of applications.
-
公开(公告)号:US20190327297A1
公开(公告)日:2019-10-24
申请号:US15961769
申请日:2018-04-24
Applicant: Futurewei Technologies, Inc.
Inventor: Habib Madani
Abstract: Systems and methods are provided to process an event stream using nodes arranged as a cluster in which the nodes are in a leader-follower relationship with one node being the leader at any given time. Tracking of node membership and leadership status can be conducted in a manager node for a variety of applications. Each node of the cluster can register in the manager node and can receive the same set of event streams as the other nodes of the cluster. The leader node can process an event of an event stream with the follower nodes tracking the processing by the leader node, where the leader node can publish the processed event. Leadership can be changed from the leader node to another node of the cluster based on a performance criterion of the leader node. Additional systems and methods can be implemented in a variety of applications.
-
公开(公告)号:US20180213018A1
公开(公告)日:2018-07-26
申请号:US15452257
申请日:2017-03-07
Applicant: Futurewei Technologies, Inc.
Inventor: Habib Madani , Sanqi Li
Abstract: Various embodiments include devices and methods structured to provide an intelligent event processing offload, which can facilitate an efficient, geo-distributed tiered scalable event streaming and processing interconnect through an embedded adapter interconnect. Event streams received in a data handler from one or more networks can be separated into partitions. The loading of the event streams into the partitions can be tracked to balance the loading by controlling the number of partitions used. Packets of each partition can be sent to a respective reactive router that resides in a controlling application for further processing. Additional devices, systems, and methods can be implemented in a variety of applications.
-
公开(公告)号:US10826984B2
公开(公告)日:2020-11-03
申请号:US15961769
申请日:2018-04-24
Applicant: Futurewei Technologies, Inc.
Inventor: Habib Madani
Abstract: Systems and methods are provided to process an event stream using nodes arranged as a cluster in which the nodes are in a leader-follower relationship with one node being the leader at any given time. Tracking of node membership and leadership status can be conducted in a manager node for a variety of applications. Each node of the cluster can register in the manager node and can receive the same set of event streams as the other nodes of the cluster. The leader node can process an event of an event stream with the follower nodes tracking the processing by the leader node, where the leader node can publish the processed event. Leadership can be changed from the leader node to another node of the cluster based on a performance criterion of the leader node. Additional systems and methods can be implemented in a variety of applications.
-
-
-