公开(公告)号：US10037187B2

公开(公告)日：2018-07-31

申请号：US14931006

申请日：2015-11-03

Applicant: Google Inc.

Inventor： Tyler Akidau ,  Robert Bradshaw ,  Ben Chambers ,  Craig Chambers ,  Reuven Lax ,  Daniel Mills ,  Frances Perry

IPC: G06F7/00 ,  H04L12/70 ,  H04L12/841

CPC classification number: G06F7/00 ,  H04L47/00 ,  H04L47/28

Abstract: A method includes receiving data corresponding one of streaming data or batch data and a content of the received data for computation. The method also includes determining an event time of the data for slicing the data, determining a processing time to output results of the received data, and emitting at least a portion of the results of the received data based on the processing time and the event time.

公开(公告)号：US20160285711A1

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

申请号：US14931006

申请日：2015-11-03

Applicant: Google Inc.

Inventor： Tyler Akidau ,  Robert Bradshaw ,  Ben Chambers ,  Craig Chambers ,  Reuven Lax ,  Daniel Mills ,  Frances Perry

IPC: H04L12/26

CPC classification number: G06F7/00 ,  H04L47/00 ,  H04L47/28

Abstract: A method includes receiving data corresponding one of streaming data or batch data and a content of the received data for computation. The method also includes determining an event time of the data for slicing the data, determining a processing time to output results of the received data, and emitting at least a portion of the results of the received data based on the processing time and the event time.

Abstract translation: 一种方法包括接收对应于流数据或批数据之一的数据以及用于计算的接收数据的内容。 该方法还包括确定所述数据的事件的时间切片中的数据，确定处理时间所接收到的数据的输出结果，并发射至少基于处理时间所接收到的数据的结果的一部分，并且所述事件的时间 。

公开(公告)号：US20170255491A1

公开(公告)日：2017-09-07

申请号：US15395225

申请日：2016-12-30

Applicant: Google Inc.

Inventor： Robert Bradshaw ,  Rafael de Jesús Fernández Moctezuma ,  Daniel Mills ,  Samuel Green McVeety ,  Samuel Carl Whittle ,  Andrei Maksimenka ,  Cosmin Ionel Arad ,  Mark Brian Shields ,  Harris Samuel Nover ,  Manuel Alfred Fahndrich ,  Jeffrey Paul Gardner ,  Mikhail Shmulyan ,  Reuven Lax ,  Ahmet Altay ,  Craig D. Chambers

IPC: G06F9/50

Abstract: A job that receives as input a data stream is executed. For the job, it is iteratively determined a backlog growth over a first period of time; a backlog volume; and whether to adjust a quantity of processing resources. For each iteration for which the quantity of processing resources allocated to the job are determined to be adjusted, adjusting the quantity of processing resources allocated to the job. For each iteration for which the quantity of processing resources allocated to the job are determined not to be adjusted, maintaining the quantity of processing resources allocated to the job.