The patent badge is an abbreviated version of the USPTO patent document. The patent badge does contain a link to the full patent document.

The patent badge is an abbreviated version of the USPTO patent document. The patent badge covers the following: Patent number, Date patent was issued, Date patent was filed, Title of the patent, Applicant, Inventor, Assignee, Attorney firm, Primary examiner, Assistant examiner, CPCs, and Abstract. The patent badge does contain a link to the full patent document (in Adobe Acrobat format, aka pdf). To download or print any patent click here.

Date of Patent:
Aug. 12, 2025

Filed:

Mar. 18, 2024
Applicant:

Databricks, Inc., San Francisco, CA (US);

Inventors:

Michael Paul Armbrust, Berkeley, CA (US);

Vuk Ercegovac, Campbell, CA (US);

Paul Lappas, Seattle, WA (US);

Xi Liang, Santa Clara, CA (US);

Mukul Murthy, Berkeley, CA (US);

Yannis Papakonstantinou, La Jolla, CA (US);

Nitin Sharma, Sammamish, WA (US);

John Sismanis, Campbell, CA (US);

Joseph Torres, San Francisco, CA (US);

Min Yang, Mountain View, CA (US);

Assignee:

Databricks, Inc., San Francisco, CA (US);

Attorney:
Primary Examiner:
Int. Cl.
CPC ...
G06F 16/25 (2019.01); G06F 16/2455 (2019.01);
U.S. Cl.
CPC ...
G06F 16/254 (2019.01); G06F 16/24568 (2019.01);
Abstract

A system receives ETL specification for processing stream data, including a transform operation represented using a database query specification. The system generates a dataflow graph of a sequence of database queries by decomposing the database query into a first database query that generates an intermediate results table, and a second database query that receives as input the intermediate results table and outputs data used for performing the transform operation. The system executes the sequence of database queries for performing the transform operation on stream data received from the source. When receiving an incremental data set, the system determines an output change set based on the received incremental data set by traversing an execution plan and processing each operator in the execution plan, and computing a change set of a particular operator from the change sets output by the one or more other operators based on the incremental data set.


Find Patent Forward Citations

Loading…