Daniel A Mills

US Patent:

20230092367, Mar 23, 2023

Filed:

Oct 24, 2022

Appl. No.:

18/048912

Inventors:

- Bozeman MT, US
Tyler Jones - Redwood City CA, US
Daniel Mills - Seattle WA, US
Daniel E. Sotolongo - Seattle WA, US

International Classification:

G06F 16/23
G06F 16/2455
G06F 16/27
G06F 16/22

Abstract:

Provided herein are systems and methods for a stream object configuration, including configuring and processing streams on views and streams on tables. For example, a method includes parsing, by at least one hardware processor, a received query to determine a plurality of data processing operations associated with a base table. A stream object on the base table is generated. The stream object includes a plurality of query results from executing the plurality of data processing operations and a corresponding plurality of time stamps of times the plurality of query results are obtained. A stream expansion of the stream object is performed. The stream expansion is based on computing changes to the base table from the plurality of data processing operations.

US Patent:

20200225991, Jul 16, 2020

Filed:

Feb 4, 2020

Appl. No.:

16/781467

Inventors:

- Mountain View CA, US
Rafael de Jesús Fernández Moctezuma - Kirkland WA, US
Daniel Mills - Mountain View CA, US
Samuel Green McVeety - Seattle WA, US
Samuel Carl Whittle - Seattle WA, US
Andrei Maksimenka - Sammamish WA, US
Cosmin Ionel Arad - Mountain View CA, US
Mark Brian Shields - Seattle WA, US
Harris Samuel Nover - Mountain View CA, US
Manuel Alfred Fahndrich - Seattle WA, US
Jeffrey Paul Gardner - Seattle WA, US
Mikhail Shmulyan - Seattle WA, US
Reuven Lax - Seattle WA, US
Ahmet Altay - Mountain View CA, US
Craig D. Chambers - Seattle WA, US

International Classification:

G06F 9/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.

US Patent:

20170255491, Sep 7, 2017

Filed:

Dec 30, 2016

Appl. No.:

15/395225

Inventors:

- Mountain View CA, US
Rafael de Jesús Fernández Moctezuma - Kirkland WA, US
Daniel Mills - Mountain view CA, US
Samuel Green McVeety - Seattle WA, US
Samuel Carl Whittle - Seattle WA, US
Andrei Maksimenka - Sammamish WA, US
Cosmin Ionel Arad - Mountain View CA, US
Mark Brian Shields - Seattle WA, US
Harris Samuel Nover - Mountain View CA, US
Manuel Alfred Fahndrich - Seattle WA, US
Jeffrey Paul Gardner - Seattle WA, US
Mikhail Shmulyan - Seattle WA, US
Reuven Lax - Seattle WA, US
Ahmet Altay - Mountain View CA, US
Craig D. Chambers - Seattle WA, US

International Classification:

G06F 9/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.

US Patent:

20160285711, Sep 29, 2016

Filed:

Nov 3, 2015

Appl. No.:

14/931006

Inventors:

- Mountain View CA, US
Robert Bradshaw - Redmond WA, US
Ben Chambers - Seattle WA, US
Craig Chambers - Seattle WA, US
Reuven Lax - Seattle WA, US
Daniel Mills - Seattle WA, US
Frances Perry - Seattle WA, US

Assignee:

Google Inc. - Mountain View CA

International Classification:

H04L 12/26

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.