Module iceberg_compaction 

Modules

gc 🔒

manual 🔒

schedule 🔒

stream 🔒

Structs

IcebergCompactionManager

IcebergCompactionManagerInner 🔒

IcebergCompactionScheduleStatus

SinkRecoveryState 🔒

Functions

is_iceberg_sink

User-created iceberg sinks have arbitrary names, so identify them by the connector property instead of the __iceberg_sink_ name prefix.

Type Aliases

CompactorChangeRx 🔒

CompactorChangeTx 🔒

IcebergCompactionManagerRef

ManualCompactionWaiter 🔒