Skip to content

Commit a222eb4

Browse files
committed
fix projection pushdown index mapping
1 parent 1a71c0f commit a222eb4

File tree

1 file changed

+2
-2
lines changed
  • packages/duckdb_protobuf/src

1 file changed

+2
-2
lines changed

packages/duckdb_protobuf/src/read.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,14 @@ pub fn write_to_output(
1717
) -> Result<(), anyhow::Error> {
1818
let column_key = &ColumnKey::empty();
1919
let fields = value.descriptor().fields().collect::<Vec<_>>();
20-
for field_idx in mappings {
20+
for (output_field_idx, field_idx) in mappings.iter().enumerate() {
2121
let field_idx = *field_idx as usize;
2222
if field_idx >= fields.len() {
2323
continue;
2424
}
2525

2626
let field_descriptor = &fields[field_idx];
27-
let column_vector = output.get_vector(field_idx);
27+
let column_vector = output.get_vector(output_field_idx);
2828
let value = value.get_field(&field_descriptor);
2929

3030
let column_key = column_key.field(&field_descriptor);

0 commit comments

Comments
 (0)