公开(公告)号：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: 一种方法包括接收对应于流数据或批数据之一的数据以及用于计算的接收数据的内容。 该方法还包括确定所述数据的事件的时间切片中的数据，确定处理时间所接收到的数据的输出结果，并发射至少基于处理时间所接收到的数据的结果的一部分，并且所述事件的时间 。