This is an automated email from the ASF dual-hosted git repository.
Jackie-Jiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 0e540de467a Use plain component names for the MultiValueLimit record
(#19482)
0e540de467a is described below
commit 0e540de467ac058d7b0cbd364cab8b5da498c3ef
Author: Xiaotian (Jackie) Jiang <[email protected]>
AuthorDate: Tue Sep 8 10:54:52 2026 -0700
Use plain component names for the MultiValueLimit record (#19482)
---
.../segment/local/indexsegment/mutable/MutableSegmentImpl.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/indexsegment/mutable/MutableSegmentImpl.java
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/indexsegment/mutable/MutableSegmentImpl.java
index ea54e6f9bd1..4fec4e25c7d 100644
---
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/indexsegment/mutable/MutableSegmentImpl.java
+++
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/indexsegment/mutable/MutableSegmentImpl.java
@@ -828,13 +828,13 @@ public class MutableSegmentImpl implements MutableSegment
{
/// @throws IllegalStateException if a multi-value column exceeds its
maximum number of values
private void validateNumMultiValues(GenericRow row) {
for (MultiValueLimit limit : _multiValueLimits) {
- Object value = row.getValue(limit._column);
+ Object value = row.getValue(limit.column());
if (value != null) {
int numValues = ((Object[]) value).length;
- if (numValues > limit._maxNumMultiValues) {
+ if (numValues > limit.maxNumMultiValues()) {
throw new IllegalStateException(
String.format("Number of values: %d in MV column: %s exceeds the
maximum allowed: %d", numValues,
- limit._column, limit._maxNumMultiValues));
+ limit.column(), limit.maxNumMultiValues()));
}
}
}
@@ -1688,7 +1688,7 @@ public class MutableSegmentImpl implements MutableSegment
{
}
/// Per-column cap on the number of values in a multi-value entry, as
configured on the mutable index context.
- private record MultiValueLimit(String _column, int _maxNumMultiValues) {
+ private record MultiValueLimit(String column, int maxNumMultiValues) {
}
private class IndexContainer implements Closeable {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]