公开(公告)号：US09436454B1

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

申请号：US14043672

申请日：2013-10-01

Applicant: Google Inc.

Inventor： Sushant Jain ,  Yi Feng ,  Anurag Agarwal ,  Nahi OJeil

IPC: G06F9/44 ,  G06F12/0866 ,  H04W72/04 ,  G06F9/445

CPC classification number: G06F8/65

Abstract: Scalable systems and methods for delivering ordered data updates from a plurality of data sources are provided. A described method includes receiving, a data update from a data source and assigning a global sequence identifier and a previous global sequence identifier to the data update. The global sequence identifier indicates a position of the data update in a sequence of data updates received from a plurality of data sources. The previous global sequence identifier is a global sequence identifier assigned to a preceding data update received from the same data source. The method further includes determining whether the preceding data update from the same data source has been delivered by comparing the previous global sequence identifier with a low water mark. The low water mark is an upper bound on a range of global sequence identifiers associated with data updates that have been delivered.

Abstract translation: 提供了用于从多个数据源传送有序数据更新的可扩展系统和方法。 所描述的方法包括从数据源接收数据更新，并将全局序列标识符和先前全局序列标识符分配给数据更新。 全局序列标识符指示从多个数据源接收的数据更新序列中的数据更新的位置。 先前的全局序列标识符是分配给从相同数据源接收的先前数据更新的全局序列标识符。 该方法还包括通过将先前的全局序列标识符与低水位标记进行比较来确定来自相同数据源的先前数据更新是否已被传送。 低水位标记是与已传送的数据更新相关联的全局序列标识符的范围上的上限。