risingwave_connector::sink

Function build_sink

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