Structs§
- Batch
Key 🔒 - Catalog
Manager 🔒Physical Flush Adapter - Flush
Batch 🔒 - Flush
Region 🔒Write - Flush
Waiter 🔒 - Node
Manager 🔒Physical Flush Adapter - Partition
Manager 🔒Physical Flush Adapter - Pending
Batch 🔒 - Pending
Rows Batcher - Prometheus remote write pending rows batcher.
- Pending
Worker 🔒 - Physical
Table Metadata - Planned
Region 🔒Batch - Resolved
Region 🔒Batch - Table
Batch - Table
Resolution 🔒Plan - Intermediate planning state for resolving and preparing logical tables before row-to-batch alignment.
Enums§
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§
- Pending
Rows Schema Alterer - Physical
Flush Catalog Provider - Physical
Flush Node Requester - Physical
Flush Partition Provider
Functions§
- batch_
key_ 🔒from_ ctx - columns_
taxonomy 🔒 - Classifies columns in a logical-table batch for sparse primary-key conversion.
- concat_
modified_ 🔒batches - Concatenates all modified batches into a single large batch.
- drain_
batch 🔒 - encode_
region_ 🔒write_ requests - flush_
batch 🔒 - flush_
batch_ physical - Flushes a batch of logical table rows by transforming them into the physical table format and writing them to the appropriate datanode regions.
- flush_
region_ 🔒writes_ concurrently - notify_
waiters 🔒 - plan_
region_ 🔒batch - plan_
region_ 🔒batches - prepare_
physical_ 🔒region_ routing_ batch - record_
batch_ 🔒to_ ipc - remove_
worker_ 🔒if_ same_ channel - resolve_
region_ 🔒targets - should_
close_ 🔒worker_ on_ idle_ timeout - should_
dispatch_ 🔒concurrently - spawn_
flush 🔒 - split_
combined_ 🔒batch_ by_ region - start_
worker 🔒 - strip_
partition_ 🔒columns_ from_ batch - transform_
logical_ 🔒batches_ to_ physical - Transforms logical table batches into physical format (sparse primary key encoding).