Merge pull request #157 from JanKaul/glue-catalog-list

create glue catalog list

Author: JanKaul

catalogs/iceberg-file-catalog/src/lib.rs

@@ -556,7 +556,7 @@ impl FileCatalog {
         });
         files
             .into_iter()
-            .last()
+            .next_back()
             .ok_or(IcebergError::CatalogNotFound)
     }
 
@@ -588,7 +588,7 @@ fn trim_start_path(path: &str) -> &str {
 
 fn parse_version(path: &str) -> Result<u64, IcebergError> {
     path.split('/')
-        .last()
+        .next_back()
         .ok_or(IcebergError::InvalidFormat("Metadata location".to_owned()))?
         .trim_start_matches('v')
         .trim_end_matches(".metadata.json")

catalogs/iceberg-glue-catalog/src/lib.rs

@@ -20,7 +20,7 @@ use iceberg_rust::{
         identifier::Identifier,
         namespace::Namespace,
         tabular::Tabular,
-        Catalog,
+        Catalog, CatalogList,
     },
     error::Error as IcebergError,
     materialized_view::MaterializedView,
@@ -948,6 +948,40 @@ impl Catalog for GlueCatalog {
     }
 }
 
+#[derive(Debug, Clone)]
+pub struct GlueCatalogList {
+    name: String,
+    config: SdkConfig,
+    object_store_builder: ObjectStoreBuilder,
+}
+
+impl GlueCatalogList {
+    pub fn new(name: &str, config: &SdkConfig, object_store_builder: ObjectStoreBuilder) -> Self {
+        Self {
+            name: name.to_owned(),
+            config: config.to_owned(),
+            object_store_builder,
+        }
+    }
+}
+
+#[async_trait]
+impl CatalogList for GlueCatalogList {
+    fn catalog(&self, name: &str) -> Option<Arc<dyn Catalog>> {
+        if self.name == name {
+            Some(Arc::new(
+                GlueCatalog::new(&self.config, &self.name, self.object_store_builder.clone())
+                    .unwrap(),
+            ))
+        } else {
+            None
+        }
+    }
+    async fn list_catalogs(&self) -> Vec<String> {
+        vec![self.name.clone()]
+    }
+}
+
 #[cfg(test)]
 pub mod tests {
     use aws_config::{BehaviorVersion, Region};

iceberg-rust/src/table/mod.rs

@@ -192,7 +192,7 @@ impl Table {
     ///
     /// # Returns
     /// * `Result<Vec<ManifestListEntry>, Error>` - Vector of manifest entries in the range,
-    ///    or an empty vector if no current snapshot exists
+    ///   or an empty vector if no current snapshot exists
     ///
     /// # Errors
     /// Returns an error if: