risingwave_connector::sink::test_sink

Function build_box_coordinator

Source 
fn build_box_coordinator(db: DatabaseConnection) -> BoxCoordinator