Update 1_register_table.py

ev2900 · Oct 9, 2024 · 28b3e33 · 28b3e33
1 parent 4201858
commit 28b3e33
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/1_register_table.py b/1_register_table.py
@@ -19,3 +19,11 @@
     .config("spark.sql.catalog.glue_catalog.catalog-impl", "org.apache.iceberg.aws.glue.GlueCatalog") \
     .config("spark.sql.catalog.glue_catalog.io-impl", "org.apache.iceberg.aws.s3.S3FileIO") \
     .getOrCreate()
+
+query = f"""
+CALL glue_catalog.system.register_table(
+  table => 'b.b',
+  metadata_file => 's3://b/metadata/Snapshot A.metadata.json'
+"""
+
+spark.sql(query)