Module iceberg_compaction

risingwave_storage::hummock::compactor

Module iceberg_compaction 

Source

Modules§

iceberg_compactor_runner 🔒

Structs§

IcebergTaskMeta
Task metadata for queue operations.
IcebergTaskQueue
FIFO task queue with parallelism-based scheduling for Iceberg compaction.
IcebergTaskQueueInner 🔒
Internal storage for the task queue.
PoppedIcebergTask

Enums§

PushResult

Type Aliases§

TaskKey 🔒
Unique key combining (task_id, plan_index) since one task can have multiple plans.