File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -1876,6 +1876,7 @@ def data_file_statistics_from_parquet_metadata(
1876
1876
1877
1877
col_aggs = {}
1878
1878
1879
+ invalidate_col : Set [int ] = set ()
1879
1880
for r in range (parquet_metadata .num_row_groups ):
1880
1881
# References:
1881
1882
# https://github.com/apache/iceberg/blob/fc381a81a1fdb8f51a0637ca27cd30673bd7aad3/parquet/src/main/java/org/apache/iceberg/parquet/ParquetUtil.java#L232
@@ -1891,8 +1892,6 @@ def data_file_statistics_from_parquet_metadata(
1891
1892
else :
1892
1893
split_offsets .append (data_offset )
1893
1894
1894
- invalidate_col : Set [int ] = set ()
1895
-
1896
1895
for pos in range (parquet_metadata .num_columns ):
1897
1896
column = row_group .column (pos )
1898
1897
field_id = parquet_column_mapping [column .path_in_schema ]
You can’t perform that action at this time.
0 commit comments