Skip to main content

Module lakehouse

Module lakehouse 

Source
Expand description

R18 lakehouse SQL extensions: delta/hudi providers, AS OF, MERGE INTO.

Structs§

AsOfTableRef
Parsed AS OF qualifier attached to a table reference.
MergeResult
MERGE metrics returned as a single-row batch.
MergeTargetUnsupportedError
Target table format is not Delta or Iceberg.

Functions§

apply_as_of_refs
Apply AS OF qualifiers by re-registering pinned delta/hudi tables.
execute_merge_sql
Parse and execute a MERGE INTO statement when matched.
preprocess_as_of_sql
Strip AS OF clauses and return rewritten SQL plus qualifiers.
register_delta_uri
Register delta.<path> as a logical table name delta_<sanitized>.
register_hudi_uri
Register hudi.<path> table.
register_scan_batches
Register in-memory batches as a DataFusion table.