risingwave_connector::sink::test_sink

Function build_box_writer

source 
pub fn build_box_writer(
    param: SinkParam,
    writer_param: SinkWriterParam,
) -> BoxWriter<()>