@@ -22,9 +22,9 @@ use std::sync::Arc;
2222use datafusion:: catalog:: CatalogProvider ;
2323use datafusion:: prelude:: { SessionConfig , SessionContext } ;
2424use datafusion_sqllogictest:: DataFusion ;
25- use iceberg:: { Catalog , CatalogBuilder , NamespaceIdent , TableCreation } ;
2625use iceberg:: memory:: { MEMORY_CATALOG_WAREHOUSE , MemoryCatalogBuilder } ;
2726use iceberg:: spec:: { NestedField , PrimitiveType , Schema , Transform , Type , UnboundPartitionSpec } ;
27+ use iceberg:: { Catalog , CatalogBuilder , NamespaceIdent , TableCreation } ;
2828use iceberg_datafusion:: IcebergCatalogProvider ;
2929use indicatif:: ProgressBar ;
3030use toml:: Table as TomlTable ;
@@ -87,9 +87,7 @@ impl DataFusionEngine {
8787
8888 // Create a test namespace for INSERT INTO tests
8989 let namespace = NamespaceIdent :: new ( "default" . to_string ( ) ) ;
90- catalog
91- . create_namespace ( & namespace, HashMap :: new ( ) )
92- . await ?;
90+ catalog. create_namespace ( & namespace, HashMap :: new ( ) ) . await ?;
9391
9492 // Create test tables
9593 Self :: create_unpartitioned_table ( & catalog, & namespace) . await ?;
@@ -134,8 +132,7 @@ impl DataFusionEngine {
134132 let schema = Schema :: builder ( )
135133 . with_fields ( vec ! [
136134 NestedField :: required( 1 , "id" , Type :: Primitive ( PrimitiveType :: Int ) ) . into( ) ,
137- NestedField :: required( 2 , "category" , Type :: Primitive ( PrimitiveType :: String ) )
138- . into( ) ,
135+ NestedField :: required( 2 , "category" , Type :: Primitive ( PrimitiveType :: String ) ) . into( ) ,
139136 NestedField :: optional( 3 , "value" , Type :: Primitive ( PrimitiveType :: String ) ) . into( ) ,
140137 ] )
141138 . build ( ) ?;
0 commit comments