risingwave_connector::sink::iceberg::compaction

Function run_compact

source 
async fn run_compact(
    catalog: String,
    database: String,
    table: String,
    catalog_config: HashMap<String, String>,
    commit_rx: UnboundedReceiver<()>,
)