Query

deltalake.QueryBuilder

QueryBuilder()

QueryBuilder is an API which exposes Apache DataFusion SQL to Python users of the deltalake library.

qb = QueryBuilder()

execute

execute(sql: str) -> RecordBatchReader

Prepares the sql query to be executed.

Example

from deltalake import DeltaTable, QueryBuilder
dt = DeltaTable("my_table")
data = QueryBuilder().register('test', dt).execute("select * from test").read_all()

register

register(table_name: str, delta_table: DeltaTable) -> QueryBuilder

Add a table to the query builder instance by name. Table DeltaTable is available in SQL queries as table_name.

Example

from deltalake import DeltaTable, QueryBuilder
dt = DeltaTable("my_table")
qb = QueryBuilder().register('test', dt)