diff --git a/writer/src/main/java/io/github/dfa1/vortex/writer/encode/OnPairEncodingEncoder.java b/writer/src/main/java/io/github/dfa1/vortex/writer/encode/OnPairEncodingEncoder.java index 525431dc8..c109acd43 100644 --- a/writer/src/main/java/io/github/dfa1/vortex/writer/encode/OnPairEncodingEncoder.java +++ b/writer/src/main/java/io/github/dfa1/vortex/writer/encode/OnPairEncodingEncoder.java @@ -227,12 +227,12 @@ static Trie train(VarBinBytes.Rows rows) { } long prev = trie.longestMatch(bytes, start, end); int pos = start + Trie.length(prev); - if (threshold.scanned(Trie.length(prev))) { + if (threshold.scan(Trie.length(prev))) { break; } while (pos < end) { long curr = trie.longestMatch(bytes, pos, end); - if (threshold.scanned(Trie.length(curr))) { + if (threshold.scan(Trie.length(curr))) { return trie; } int prevLen = Trie.length(prev); @@ -279,8 +279,10 @@ private static final class Threshold { this.nextCheck = checkInterval; } + /// Counts `n` more bytes scanned. + /// /// @return `true` once the scan budget is exhausted - boolean scanned(int n) { + boolean scan(int n) { scanned += n; return scanned > budget; }