File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 1
1
diff --git a/cpp/src/arrow/dataset/file_parquet.cc b/cpp/src/arrow/dataset/file_parquet.cc
2
- index 1f8b6cc488..586a5122a5 100644
2
+ index 1f8b6cc488..6ac6642fdb 100644
3
3
--- a/cpp/src/arrow/dataset/file_parquet.cc
4
4
+++ b/cpp/src/arrow/dataset/file_parquet.cc
5
5
@@ -26,16 +26,23 @@
@@ -55,9 +55,9 @@ index 1f8b6cc488..586a5122a5 100644
55
55
+ field_ref.GetOneOrNone(*next));
56
56
+ if (column) {
57
57
+ if (this->cols_to_skip_.count(field->name())) {
58
- + out_cols.emplace_back(std::move(column));
59
58
+ // Maintain the original input type.
60
59
+ out_schema_fields.emplace_back(field->WithType(column->type()));
60
+ + out_cols.emplace_back(std::move(column));
61
61
+ continue;
62
62
+ }
63
63
+ if (!column->type()->Equals(field->type())) {
@@ -69,8 +69,8 @@ index 1f8b6cc488..586a5122a5 100644
69
69
+ column = converted.make_array();
70
70
+ changed = true;
71
71
+ }
72
- + out_cols.emplace_back(std::move(column));
73
72
+ out_schema_fields.emplace_back(field->Copy());
73
+ + out_cols.emplace_back(std::move(column));
74
74
+ // XXX Do we need to handle the else case? What happens when the column
75
75
+ // doesn't exist, e.g. all null or all the same value?
76
76
+ }
You can’t perform that action at this time.
0 commit comments