Skip to content

Commit cdd2313

Browse files
Review contd.
1 parent 9dce33d commit cdd2313

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

extensions/parquet/table/src/main/java/io/deephaven/parquet/table/location/ParquetTableLocation.java

+3-4
Original file line numberDiff line numberDiff line change
@@ -221,18 +221,17 @@ private RowSet computeIndex(@NotNull final RowGroup[] rowGroups) {
221221
@NotNull
222222
public List<String[]> getDataIndexColumns() {
223223
initialize();
224-
final Map<String, GroupingColumnInfo> localGroupingColumns = groupingColumns;
225-
if (tableInfo.dataIndexes().isEmpty() && localGroupingColumns.isEmpty()) {
224+
if (tableInfo.dataIndexes().isEmpty() && groupingColumns.isEmpty()) {
226225
return List.of();
227226
}
228227
final List<String[]> dataIndexColumns =
229-
new ArrayList<>(tableInfo.dataIndexes().size() + localGroupingColumns.size());
228+
new ArrayList<>(tableInfo.dataIndexes().size() + groupingColumns.size());
230229
// Add the data indexes to the list
231230
tableInfo.dataIndexes().stream()
232231
.map(di -> di.columns().toArray(String[]::new))
233232
.forEach(dataIndexColumns::add);
234233
// Add grouping columns to the list
235-
localGroupingColumns.keySet().stream().map(colName -> new String[] {colName}).forEach(dataIndexColumns::add);
234+
groupingColumns.keySet().stream().map(colName -> new String[] {colName}).forEach(dataIndexColumns::add);
236235
return dataIndexColumns;
237236
}
238237

0 commit comments

Comments
 (0)