Module batcher 

Logical-table and ordinary-table batching implementations.

Modules

flow_notifier 🔒

flow_sender 🔒

logical_table

table

Table-scoped RecordBatch accumulation before bulk routing and encoding.

Enums

BatchingProtocol

Ingestion protocols that can opt into pending-row batching.

Constants

PENDING_ROWS_BATCH_SYNC_ENV 🔒

Controls whether batching waits for storage before replying to the client.

Functions

pending_rows_batch_sync_enabled

Returns whether pending-row batch submissions wait for the flush result before replying to the client (synchronous mode), controlled by the PENDING_ROWS_BATCH_SYNC environment variable and defaulting to true.