Skip to content

Commit 3038220

Browse files
committed
setRequestedSchema
1 parent 0ea55b7 commit 3038220

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1121,13 +1121,17 @@ public List<BlockMetaData> getRowGroups() {
11211121
return blocks;
11221122
}
11231123

1124-
public void setRequestedSchema(MessageType projection) {
1124+
public void setRequestedSchema(List<ColumnDescriptor> columns) {
11251125
paths.clear();
1126-
for (ColumnDescriptor col : projection.getColumns()) {
1126+
for (ColumnDescriptor col : columns) {
11271127
paths.put(ColumnPath.get(col.getPath()), col);
11281128
}
11291129
}
11301130

1131+
public void setRequestedSchema(MessageType projection) {
1132+
setRequestedSchema(projection.getColumns());
1133+
}
1134+
11311135
public void appendTo(ParquetFileWriter writer) throws IOException {
11321136
writer.appendRowGroups(f, blocks, true);
11331137
}

0 commit comments

Comments
 (0)