pub fn get_columns_from_sink( session: &SessionImpl, sink_name: ObjectName, ) -> Result<Vec<ColumnCatalog>, RwError>