INGST-04: Batch-buffered writes to ClickHouse #4
Reference in New Issue
Block a user
Delete Branch "%!s()"
Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?
Ingestion uses an in-memory batch buffer with configurable flush interval and batch size for ClickHouse writes. ClickHouse requires batch inserts (1K-10K rows) — row-by-row inserts cause "too many parts" errors.
Category: Data Ingestion
REQ-ID: INGST-04
Implemented in Phase 1.
WriteBufferaccumulates records in-memory andClickHouseFlushSchedulerflushes to ClickHouse on a configurable interval (default 1000ms) or when batch size (default 5000) is reached. Key files:WriteBuffer.java,ClickHouseFlushScheduler.java.