risingwave_connector::sink

Function build_sink

source 
pub fn build_sink(param: SinkParam) -> Result<SinkImpl>