公开(公告)号：US20150100592A1

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

申请号：US14045517

申请日：2013-10-03

Applicant: Google Inc.

Inventor： Alexander Gourkov Balikov ,  Marian Dvorsky ,  Yonggang Zhao

IPC: G06F17/30

CPC classification number: G06F17/30345 ,  G06F9/5066

Abstract: A method includes receiving a request to perform a shuffle operation on a data stream; receiving at least a portion of the data stream including a plurality of records, each including a key; storing each of the plurality of records in a persistent storage location assigned to a key range corresponding to keys included in the plurality of records; receiving a request from a consumer for a subset of the plurality of records including a range of keys; and upon receiving the request from the consumer, providing the subset of the plurality of records including the range of keys from the one or more persistent storage locations.

Abstract translation: 一种方法包括：接收对数据流执行随机操作的请求; 接收包括多个记录的数据流的至少一部分，每个记录包括一个密钥; 将所述多个记录中的每一个存储在分配给与包括在所述多个记录中的键相对应的键范围的永久存储位置中; 从消费者接收包括一系列键的多个记录的子集的请求; 并且在从所述消费者接收到所述请求时，提供所述多个记录的子集，包括来自所述一个或多个持久存储位置的密钥范围。