create_table_if_not_exists_impl

risingwave_connector::sink::iceberg

Function create_table_if_not_exists_impl 

Source 
async fn create_table_if_not_exists_impl(
    config: &IcebergConfig,
    param: &SinkParam,
) -> Result<()>