Skip to content

Commit 1d320df

Browse files
author
Jan Kaul
committed
fix file catalog
1 parent f614586 commit 1d320df

File tree

1 file changed

+14
-1
lines changed
  • catalogs/iceberg-file-catalog/src

1 file changed

+14
-1
lines changed

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

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ impl Catalog for FileCatalog {
7474
_namespace: &Namespace,
7575
_properties: Option<HashMap<String, String>>,
7676
) -> Result<HashMap<String, String>, IcebergError> {
77-
todo!()
77+
Ok(HashMap::new())
7878
}
7979
/// Drop a namespace in the catalog
8080
async fn drop_namespace(&self, _namespace: &Namespace) -> Result<(), IcebergError> {
@@ -743,6 +743,19 @@ pub mod tests {
743743

744744
ctx.register_catalog("warehouse", catalog);
745745

746+
let sql = &"CREATE SCHEMA warehouse.tpch;".to_string();
747+
748+
let plan = ctx.state().create_logical_plan(sql).await.unwrap();
749+
750+
let transformed = plan.transform(iceberg_transform).data().unwrap();
751+
752+
ctx.execute_logical_plan(transformed)
753+
.await
754+
.unwrap()
755+
.collect()
756+
.await
757+
.expect("Failed to execute query plan.");
758+
746759
let sql = "CREATE EXTERNAL TABLE lineitem (
747760
L_ORDERKEY BIGINT NOT NULL,
748761
L_PARTKEY BIGINT NOT NULL,

0 commit comments

Comments
 (0)