risingwave_connector::sink::test_sink

Function build_box_log_sinker

Source 
async fn build_box_log_sinker(
    param: SinkParam,
    writer_param: SinkWriterParam,
) -> Result<BoxLogSinker>