Skip to content

Commit f8ba337

Browse files
committed
fmt
1 parent 78aa0af commit f8ba337

2 files changed

Lines changed: 2 additions & 5 deletions

File tree

datafusion_iceberg/src/table/mod.rs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -993,10 +993,7 @@ impl DataSink for IcebergDataSink {
993993
let metadata_files =
994994
write_parquet_data_files(&table, data, context, self.0.branch.as_deref()).await?;
995995

996-
let count = metadata_files
997-
.iter()
998-
.map(|x| x.record_count())
999-
.sum::<i64>();
996+
let count = metadata_files.iter().map(|x| x.record_count()).sum::<i64>();
1000997

1001998
table
1002999
.new_transaction(self.0.branch.as_deref())

iceberg-rust/tests/empty_schema_manifest_test.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ use iceberg_rust_spec::spec::types::{PrimitiveType, StructField, Type};
8181
use iceberg_rust_spec::util::strip_prefix;
8282
use iceberg_sql_catalog::SqlCatalog;
8383
use object_store::path::Path as ObjectPath;
84-
use object_store::ObjectStore;
84+
use object_store::ObjectStoreExt;
8585

8686
/// Test for verifying behavior when a manifest file has a schema with zero fields.
8787
///

0 commit comments

Comments
 (0)