Thalweg · API reference ← Main docs

Module sink

Module sink 

Source
Expand description

ZerobusSink: the assembly that wires catalog provisioning, the stream pool, and the ADR-0060 ack lane into the [BatchSink] and [Sink] substrate traits.

start provisions the table through the catalog (reconcile → register → vend credentials → precondition check), then opens a bandwidth-sized pool. push/send reconcile types at the write boundary, encode the batch to Arrow IPC, submit fire-and-forget, and hand a typed confirmation to the ack lane — coverage advances only on the durable ack.

Structs§

ZerobusSink
A Databricks Zerobus sink for one target table.
ZerobusSinkDeps
The dependencies a ZerobusSink is built from.