build_sink_coordinator

risingwave_connector::sink::test_sink

Function build_sink_coordinator 

Source 
fn build_sink_coordinator(
    sink_param: SinkParam,
    iceberg_compact_stat_sender: Option<UnboundedSender<IcebergSinkCompactionUpdate>>,
) -> SinkCommitCoordinator