risingwave_meta::rpc::ddl_controller

Function clean_all_rows_by_sink_id

Source 
async fn clean_all_rows_by_sink_id(
    db: &DatabaseConnection,
    sink_id: i32,
) -> MetaResult<()>