We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 168f7c1 commit 90c761cCopy full SHA for 90c761c
1 file changed
catalogs/iceberg-rest-catalog/src/catalog.rs
@@ -750,6 +750,21 @@ pub mod tests {
750
.expect("Failed to list Tables");
751
assert_eq!(tables[0].to_string(), "tpch.lineitem".to_owned());
752
753
+ assert_eq!(
754
+ iceberg_catalog
755
+ .tabular_exists(&Identifier::new(&["tpch".to_owned()], "lineitem"))
756
+ .await
757
+ .map_err(|s| s.to_string()),
758
+ Ok(true)
759
+ );
760
761
762
+ .tabular_exists(&Identifier::new(&["tpch".to_owned()], "non_existing_table"))
763
764
765
+ Ok(false)
766
767
+
768
let sql = "insert into warehouse.tpch.lineitem select * from lineitem;";
769
770
let plan = ctx.state().create_logical_plan(sql).await.unwrap();
0 commit comments