公开(公告)号：WO2015187400A1

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

申请号：PCT/US2015/032370

申请日：2015-05-26

Applicant: SAS INSTITUTE INC.

Inventor： BAULIER, Gerald Donald ,  DETERS, Vincent L. ,  KOLODZIESKI, Scott J.

IPC: H04L29/14

CPC classification number: H04L41/0663 ,  G06F9/542 ,  G06F11/2007 ,  G06F11/2028 ,  G06F11/2041 ,  G06F2201/85 ,  H04L51/18

Abstract: In a computing device supporting a failover in an event stream processing (ESP) system, an event block object is received. A first status of the computing device as active or standby is determined. When the first status is active, a second status of the computing device as newly active or not newly active is determined. Newly active is determined when the computing device is switched from a standby to an active status. When the second status is newly active, a last published event block object identifier that uniquely identifies a last published event block object is determined. A next event block object is selected from a non-transitory computer-readable medium accessible by the computing device. The next event block object has an event block object identifier that is greater than the determined last published event block object identifier. The selected next event block object is published to an out-messaging network device.

Abstract translation: 在支持事件流处理（ESP）系统中的故障转移的计算设备中，接收事件块对象。 确定计算设备作为活动或待机的第一状态。 当第一状态为活动状态时，确定计算设备的第二状态为新活动或新活动。 当计算设备从待机切换到活动状态时，确定新活动。 当第二状态为新活动时，确定唯一标识最后发布的事件块对象的最后发布的事件块对象标识符。 从计算设备可访问的非暂时计算机可读介质中选择下一个事件块对象。 下一个事件块对象具有大于所确定的最后发布的事件块对象标识符的事件块对象标识符。 所选择的下一个事件块对象被发布到外发消息网络设备。

公开(公告)号：WO2018106426A1

公开(公告)日：2018-06-14

申请号：PCT/US2017/062046

申请日：2017-11-16

Applicant: SAS INSTITUTE INC.

Inventor： KOLODZIESKI, Scott J. ,  DETERS, Vincent L. ,  HUANG, Shu ,  LEVEY, Robert A.

IPC: G06F17/30 ,  G06F9/54 ,  H04L29/08

Abstract: A first computing device manages a cluster of event stream processing (ESP) engines (ESPEs). A local ESP model is created based on information read from a manager configuration file that includes first connection information to connect to the second computing device and second connection information to connect the third computing device. An ESPE is instantiated on the first computing device based on the created local ESP model. The event block object is received from the second computing device in a first source window of the instantiated ESPE. A remote ESP model is deployed to a remote third computing device. The manager configuration file includes an indicator of the remote ESP model. The third computing device to receive the processed event block object is selected. The processed event block object is published to a second source window defined by the remote ESP model deployed to the third computing device.

公开(公告)号：EP3374890B1

公开(公告)日：2020-05-13

申请号：EP17877384.2

申请日：2017-11-16

Applicant: SAS Institute Inc.

Inventor： KOLODZIESKI, Scott J. ,  DETERS, Vincent L. ,  HUANG, Shu ,  LEVEY, Robert A.

IPC: G06F8/60 ,  G06F9/445 ,  G06F9/54 ,  G06F8/70

公开(公告)号：EP3796167A1

公开(公告)日：2021-03-24

申请号：EP20187201.7

申请日：2020-07-22

Applicant: SAS Institute Inc.

Inventor： KOLODZIESKI, Scott J. ,  DETERS, Vincent L. ,  LEVEY, Robert A. ,  HUANG, Shu

IPC: G06F9/50 ,  G06F9/54 ,  G06F16/2455

Abstract: A computing device manages a router. A manager engine is instantiated based on a manager engine definition and instantiates a manager ESPE based on a created manager ESP model. A router configuration file is created based on mapping information read from the manager configuration file that describes connectivity between an event publishing source and a source window of the manager ESPE. A router engine is instantiated based on the created router configuration file. A connector is started to receive an event based on the router configuration file. The event is received in the source window of the manager ESPE processed based on the manager ESP model. A third computing device is selected by the router engine based on a usage metric received from each window of a plurality of windows defined by a remote ESP model configured to further process the processed event when it is received.

公开(公告)号：EP3690640A1

公开(公告)日：2020-08-05

申请号：EP19218074.3

申请日：2017-11-16

Applicant: SAS Institute Inc.

Inventor： KOLODZIESKI, Scott J. ,  DETERS, Vincent L. ,  HUANG, Shu ,  LEVEY, Robert A

IPC: G06F8/60 ,  G06F9/445 ,  G06F9/54 ,  G06F8/70

Abstract: A first computing device manages a cluster of event stream processing (ESP) engines (ESPEs). A local ESP model is created based on information read from a manager configuration file that includes first connection information to connect to the second computing device and second connection information to connect the third computing device. An ESPE is instantiated on the first computing device based on the created local ESP model. The event block object is received from the second computing device in a first source window of the instantiated ESPE. A remote ESP model is deployed to a remote third computing device. The manager configuration file includes an indicator of the remote ESP model. The third computing device to receive the processed event block object is selected. The processed event block object is published to a second source window defined by the remote ESP model deployed to the third computing device.

公开(公告)号：EP3117590B1

公开(公告)日：2018-11-28

申请号：EP15804022.0

申请日：2015-05-26

Applicant: SAS Institute Inc.

Inventor： BAULIER, Gerald Donald ,  DETERS, Vincent L. ,  KOLODZIESKI, Scott J.

IPC: G06F11/20 ,  H04L12/24 ,  H04L12/58

CPC classification number: H04L41/0663 ,  G06F9/542 ,  G06F11/2007 ,  G06F11/2028 ,  G06F11/2041 ,  G06F2201/85 ,  H04L51/18

Abstract: In a computing device supporting a failover in an event stream processing (ESP) system, an event block object is received. A first status of the computing device as active or standby is determined. When the first status is active, a second status of the computing device as newly active or not newly active is determined. Newly active is determined when the computing device is switched from a standby to an active status. When the second status is newly active, a last published event block object identifier that uniquely identifies a last published event block object is determined. A next event block object is selected from a non-transitory computer-readable medium accessible by the computing device. The next event block object has an event block object identifier that is greater than the determined last published event block object identifier. The selected next event block object is published to an out-messaging network device.

公开(公告)号：EP3374890A1

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

申请号：EP17877384.2

申请日：2017-11-16

Applicant: SAS Institute Inc.

Inventor： KOLODZIESKI, Scott J. ,  DETERS, Vincent L. ,  HUANG, Shu ,  LEVEY, Robert A.

IPC: G06F17/30 ,  G06F9/54 ,  H04L29/08

Abstract: A first computing device manages a cluster of event stream processing (ESP) engines (ESPEs). A local ESP model is created based on information read from a manager configuration file that includes first connection information to connect to the second computing device and second connection information to connect the third computing device. An ESPE is instantiated on the first computing device based on the created local ESP model. The event block object is received from the second computing device in a first source window of the instantiated ESPE. A remote ESP model is deployed to a remote third computing device. The manager configuration file includes an indicator of the remote ESP model. The third computing device to receive the processed event block object is selected. The processed event block object is published to a second source window defined by the remote ESP model deployed to the third computing device.

公开(公告)号：EP3117590A1

公开(公告)日：2017-01-18

申请号：EP15804022.0

申请日：2015-05-26

Applicant: SAS Institute Inc.

Inventor： BAULIER, Gerald Donald ,  DETERS, Vincent L. ,  KOLODZIESKI, Scott J.

IPC: H04L29/14

CPC classification number: H04L41/0663 ,  G06F9/542 ,  G06F11/2007 ,  G06F11/2028 ,  G06F11/2041 ,  G06F2201/85 ,  H04L51/18

Abstract: In a computing device supporting a failover in an event stream processing (ESP) system, an event block object is received. A first status of the computing device as active or standby is determined. When the first status is active, a second status of the computing device as newly active or not newly active is determined. Newly active is determined when the computing device is switched from a standby to an active status. When the second status is newly active, a last published event block object identifier that uniquely identifies a last published event block object is determined. A next event block object is selected from a non-transitory computer-readable medium accessible by the computing device. The next event block object has an event block object identifier that is greater than the determined last published event block object identifier. The selected next event block object is published to an out-messaging network device.

Abstract translation: 在支持事件流处理（ESP）系统中的故障切换的计算设备中，接收事件块对象。 确定计算设备作为活动或待机的第一状态。 当第一状态为活动状态时，确定计算设备的第二状态为新活动或非新活动状态。 当计算设备从待机状态切换到活动状态时，确定新活动。 当第二状态新活动时，确定唯一地标识最后发布的事件块对象的最后发布的事件块对象标识符。 从计算设备可访问的非暂时计算机可读介质中选择下一个事件块对象。 下一个事件块对象具有大于确定的最后发布的事件块对象标识符的事件块对象标识符。 所选择的下一个事件块对象被发布到外发消息网络设备。