INGST-04: Batch-buffered writes to ClickHouse #4

Closed
opened 2026-03-11 11:13:12 +01:00 by claude · 1 comment
Owner

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

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
Author
Owner

Implemented in Phase 1. WriteBuffer accumulates records in-memory and ClickHouseFlushScheduler flushes to ClickHouse on a configurable interval (default 1000ms) or when batch size (default 5000) is reached. Key files: WriteBuffer.java, ClickHouseFlushScheduler.java.

Implemented in Phase 1. `WriteBuffer` accumulates records in-memory and `ClickHouseFlushScheduler` flushes to ClickHouse on a configurable interval (default 1000ms) or when batch size (default 5000) is reached. Key files: `WriteBuffer.java`, `ClickHouseFlushScheduler.java`.
Sign in to join this conversation.