lakehouse
sqllocks_spindle.engine.sinks.lakehouse
¶
Classes¶
LakehouseSink
¶
Delegate sink that writes chunks to a Fabric Lakehouse Files landing zone.
Thin wrapper around LakehouseFilesWriter. Accumulates numpy array chunks
as DataFrames per table, then flushes via write_all() on close.
Works locally (base_path is a filesystem path) or against OneLake
(base_path is an abfss:// URL). When using an abfss:// path the
azure-storage-file-datalake and azure-identity packages must be
installed (pip install sqllocks-spindle[fabric-files]).
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
base_path
|
str | Path | None
|
Root path for the landing zone. Passed through to
:class: |
None
|
format
|
str
|
Output format — |
'parquet'
|