公开(公告)号：US09680893B2

公开(公告)日：2017-06-13

申请号：US13921662

申请日：2013-06-19

Applicant: Yahoo! Inc.

Inventor： Joy Banerjee ,  Shail Aditya Gupta

IPC: G06F15/16 ,  H04L29/06 ,  G06F9/46

CPC classification number: H04L65/60 ,  G06F9/466 ,  H04L65/602

Abstract: Method, system, and programs for event state management in stream processing. In one example, a batch of events is created from a plurality of input events. The batch is associated with a state and is to be processed in one or more stages. The batch of events is stored in a persistent storage. The state associated with the batch is updated based on results of processing the batch in the one or more stages. The state associated with the batch is retrieved.

公开(公告)号：US20140280766A1

公开(公告)日：2014-09-18

申请号：US13921662

申请日：2013-06-19

Applicant: Yahoo! Inc.

Inventor： Joy Banerjee ,  Shail Aditya Gupta

IPC: H04L29/06

CPC classification number: H04L65/60 ,  G06F9/466 ,  H04L65/602

Abstract: Method, system, and programs for event state management in stream processing. In one example, a batch of events is created from a plurality of input events. The batch is associated with a state and is to be processed in one or more stages. The batch of events is stored in a persistent storage. The state associated with the batch is updated based on results of processing the batch in the one or more stages. The state associated with the batch is retrieved.

Abstract translation: 流处理中事件状态管理的方法，系统和程序。 在一个示例中，从多个输入事件创建一批事件。 该批次与一个状态相关联，并在一个或多个阶段进行处理。 该批事件存储在持久存储器中。 基于在一个或多个阶段处理批次的结果来更新与该批次相关联的状态。 检索与批次关联的状态。