We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b06ebd2 commit ea35831Copy full SHA for ea35831
src/query/storages/fuse/src/io/read/block/parquet/mod.rs
@@ -95,6 +95,7 @@ impl BlockReader {
95
let mut blocks = Vec::with_capacity(record_batches.len());
96
97
for record_batch in record_batches {
98
+ let num_rows_record_batch = record_batch.num_rows();
99
let mut columns = Vec::with_capacity(self.projected_schema.fields.len());
100
for ((i, field), column_node) in self
101
.projected_schema
@@ -151,7 +152,7 @@ impl BlockReader {
151
152
};
153
columns.push(BlockEntry::new(data_type, value));
154
}
- blocks.push(DataBlock::new(columns, num_rows));
155
+ blocks.push(DataBlock::new(columns, num_rows_record_batch));
156
157
158
Ok(blocks)
0 commit comments