Module pending_rows_batcher 

Structs

BatchKey 🔒

FlushBatch 🔒

FlushRegionWrite 🔒

FlushWaiter 🔒

PendingBatch 🔒

PendingRowsBatcher

Prometheus remote write pending rows batcher.

PendingWorker 🔒

TableBatch 🔒

TableResolutionPlan 🔒

Intermediate planning state for resolving and preparing logical tables before row-to-batch alignment.

Enums

FlushWriteResult 🔒

WorkerCommand 🔒

Constants

PENDING_ROWS_BATCH_SYNC_ENV 🔒

Whether wait for ingestion result before reply to client.

PHYSICAL_REGION_ESSENTIAL_COLUMN_COUNT 🔒

PHYSICAL_TABLE_KEY 🔒

WORKER_IDLE_TIMEOUT_MULTIPLIER 🔒

Traits

PendingRowsSchemaAlterer

Functions

batch_key_from_ctx 🔒

columns_taxonomy 🔒

Classifies columns in a logical-table batch for sparse primary-key conversion.

drain_batch 🔒

flush_batch 🔒

flush_batch_physical 🔒

Attempts to flush all table batches by transforming them into the physical table format (sparse primary key encoding) and writing directly to the physical data regions.

flush_region_writes_concurrently 🔒

flush_with_error 🔒

mark_flush_failure 🔒

notify_waiters 🔒

record_batch_to_ipc 🔒

remove_worker_if_same_channel 🔒

should_close_worker_on_idle_timeout 🔒

should_dispatch_concurrently 🔒

spawn_flush 🔒

start_worker 🔒

strip_partition_columns_from_batch 🔒

Type Aliases

PendingRowsSchemaAltererRef