risingwave_connector::sink::iceberg::compaction

Function spawn_compaction_client

Source 
pub fn spawn_compaction_client(
    config: &IcebergConfig,
) -> Result<(UnboundedSender<()>, Sender<()>)>