Skip to content

Commit

Permalink
fix comment
Browse files Browse the repository at this point in the history
  • Loading branch information
leaves12138 committed Dec 10, 2024
1 parent 2cf0a0d commit ddca0f9
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ public class KeyValueDataFileWriter
private long minSeqNumber = Long.MAX_VALUE;
private long maxSeqNumber = Long.MIN_VALUE;
private long deleteRecordCount = 0;
private final KeyStateAbstractor keyStateAbstractor;
private final StateAbstractor stateAbstractor;

public KeyValueDataFileWriter(
FileIO fileIO,
Expand Down Expand Up @@ -122,7 +122,7 @@ public KeyValueDataFileWriter(
this.dataFileIndexWriter =
DataFileIndexWriter.create(
fileIO, dataFileToFileIndexPath(path), valueType, fileIndexOptions);
this.keyStateAbstractor = new KeyStateAbstractor(keyType, valueType, options.thinMode());
this.stateAbstractor = new StateAbstractor(keyType, valueType, options.thinMode());
}

@Override
Expand Down Expand Up @@ -174,7 +174,7 @@ public DataFileMeta result() throws IOException {
}

Pair<SimpleColStats[], SimpleColStats[]> keyValueStats =
keyStateAbstractor.abstractFromValueState(fieldStats());
stateAbstractor.abstractFromValueState(fieldStats());

SimpleStats keyStats = keyStatsConverter.toBinaryAllMode(keyValueStats.getKey());
Pair<List<String>, SimpleStats> valueStatsPair =
Expand Down Expand Up @@ -214,13 +214,13 @@ public void close() throws IOException {
super.close();
}

private static class KeyStateAbstractor {
private static class StateAbstractor {
private final int numKeyFields;
private final int numValueFields;
// if keyStatMapping is not null, means thin mode on.
@Nullable private final int[] keyStatMapping;

public KeyStateAbstractor(RowType keyType, RowType valueType, boolean thinMode) {
public StateAbstractor(RowType keyType, RowType valueType, boolean thinMode) {
this.numKeyFields = keyType.getFieldCount();
this.numValueFields = valueType.getFieldCount();
Map<Integer, Integer> idToIndex = new HashMap<>();
Expand Down

0 comments on commit ddca0f9

Please sign in to comment.