risingwave_connector::sink::test_sink

Function build_box_coordinator

Source 
fn build_box_coordinator(
    db: DatabaseConnection,
    sink_param: SinkParam,
    iceberg_compact_stat_sender: Option<UnboundedSender<IcebergSinkCompactionUpdate>>,
) -> BoxCoordinator