Skip to content

Commit db65403

Browse files
committed
Add more info in iceberg table
Signed-off-by: Xuanwo <[email protected]>
1 parent fd15437 commit db65403

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

src/query/storages/iceberg/src/table.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -308,7 +308,7 @@ impl IcebergTable {
308308
.collect();
309309

310310
Ok((
311-
PartStatistics::new_estimated(None, read_rows, read_bytes, parts.len(), total_files),
311+
PartStatistics::new_exact(read_rows, read_bytes, parts.len(), total_files),
312312
Partitions::create(PartitionsShuffleKind::Mod, parts),
313313
))
314314
}
@@ -392,4 +392,8 @@ impl Table for IcebergTable {
392392
fn support_prewhere(&self) -> bool {
393393
false
394394
}
395+
396+
fn has_exact_total_row_count(&self) -> bool {
397+
true
398+
}
395399
}

0 commit comments

Comments
 (0)