Thalweg · API reference ← Main docs

Module batch_sink

Module batch_sink 

Source
Expand description

The Arrow write substrate: BatchSink and CommitInfo.

A BatchSink is the RecordBatch-level write path a concrete sink (Zerobus, Postgres, Flight, …) implements. push accepts a batch fire-and-forget; finish flushes the current batching window and reports the submitted high-water span. Neither blocks on durable acknowledgement — durability is confirmed out of band and reported through coverage (ADR-0060).

Structs§

CommitInfo
What a completed batching window submitted, for observability and coverage.

Traits§

BatchSink
The RecordBatch-level write substrate a concrete sink implements.