base

sqllocks_spindle.engine.sinks.base

Classes

Sink

Bases: Protocol

Protocol all sinks must implement.

Methods:

open(schema)

Called once before any chunks arrive. Create directories/tables/connections.

write_chunk(table, arrays)

Write one chunk of data for a table. Called once per table per chunk.

close()

Flush, commit, teardown. Called once after all chunks.

FabricConnectionProfile dataclass

Auth profile shared by all Fabric-backed sinks.