公开(公告)号：US09052971B2

公开(公告)日：2015-06-09

申请号：US13548158

申请日：2012-07-12

申请人： Joachin H. Frank ,  Ming Li ,  Liangzhao Zeng

发明人： Joachin H. Frank ,  Ming Li ,  Liangzhao Zeng

IPC分类号： G06F3/00 ,  G06F9/44 ,  G06F9/46 ,  G06F13/00 ,  G06F9/54

CPC分类号： G06F9/542 ,  G06F2209/546

摘要： Processing events in a distributed environment. There is provided an apparatus which includes a central queue for receiving events and tracking their progress through filtering, correlation, and update processing of stateful target objects, at least one filtering node, at least one correlation node and at least one update node. The central queue receives events in their order of arrival, each event having an entry in the central queue. Processing of events is divided into three pipelined stages in the order of filtering, correlating and updating. A result for each event of each of filtering the events, correlating the events and updating the target object is recorded in the central queue as part of the event's queue entry. The method may be performed by one or more computing devices. The exemplary embodiments detect and compensate for any erroneous results due to unsynchronized parallel processing, and guarantee an eventually correct outcome.

摘要翻译： 在分布式环境中处理事件。 提供了一种装置，其包括用于接收事件并通过对状态目标对象，至少一个过滤节点，至少一个相关节点和至少一个更新节点进行过滤，相关和更新处理来跟踪其进展的中心队列。 中心队列以其到达顺序接收事件，每个事件在中心队列中具有条目。 事件处理按照过滤，关联和更新的顺序分为三个流水线阶段。 每个过滤事件，关联事件和更新目标对象的每个事件的结果作为事件队列条目的一部分记录在中央队列中。 该方法可以由一个或多个计算设备执行。 示例性实施例检测并补偿由于不同步并行处理引起的任何错误结果，并且保证最终正确的结果。

公开(公告)号：US20140019995A1

公开(公告)日：2014-01-16

申请号：US13548158

申请日：2012-07-12

申请人： Joachin H. Frank ,  Ming Li ,  Liangzhao Zeng

发明人： Joachin H. Frank ,  Ming Li ,  Liangzhao Zeng

IPC分类号： G06F9/46

CPC分类号： G06F9/542 ,  G06F2209/546

摘要： Processing events in a distributed environment. There is provided an apparatus which includes a central queue for receiving events and tracking their progress through filtering, correlation, and update processing of stateful target objects, at least one filtering node, at least one correlation node and at least one update node. The central queue receives events in their order of arrival, each event having an entry in the central queue. Processing of events is divided into three pipelined stages in the order of filtering, correlating and updating. A result for each event of each of filtering the events, correlating the events and updating the target object is recorded in the central queue as part of the event's queue entry. The method may be performed by one or more computing devices. The exemplary embodiments detect and compensate for any erroneous results due to unsynchronized parallel processing, and guarantee an eventually correct outcome.

摘要翻译： 在分布式环境中处理事件。 提供了一种装置，其包括用于接收事件并通过对状态目标对象，至少一个过滤节点，至少一个相关节点和至少一个更新节点进行过滤，相关和更新处理来跟踪其进展的中心队列。 中心队列以其到达顺序接收事件，每个事件在中心队列中具有条目。 事件处理按照过滤，关联和更新的顺序分为三个流水线阶段。 每个过滤事件，关联事件和更新目标对象的每个事件的结果作为事件队列条目的一部分记录在中央队列中。 该方法可以由一个或多个计算设备执行。 示例性实施例检测并补偿由于不同步并行处理引起的任何错误结果，并且保证最终正确的结果。