ModulesΒ§
- report π
StructsΒ§
- Compaction
Attempt π - Immutable task parameters captured when the scheduler selects an attempt.
- Compaction
Blocked π - Compaction
Demand π - Compaction
Health π - Outcome history of one sinkβs compaction attempts.
- Compaction
Policy π - Selection parameters are typed in memory and serialized only at dispatch.
- Compaction
Retry π - Compaction
Round π - A boundary always exists while work is active. Beneficial PK-index batches can advance it for new writes; PK-index Full keeps its boundary and policy until drained.
- Compaction
Schedule πConfig - Latest catalog configuration, independent of an in-flight attemptβs frozen policy.
- Compaction
Track π - Iceberg
Compaction πHandle - Iceberg
Compaction Schedule Status - Prepared
Sink πUpdate - Result of the read-only preparation step before applying a sink update.
- Scheduled
Compaction πTask
EnumsΒ§
- Compaction
Track πFinish Action - Compaction
Track πState - Scheduler lifecycle for one sink.
- Sink
Update πKind