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 9b0e2b7b76ab..f9e99ed9f57f 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 @@ -268,8 +268,13 @@ public boolean isMutableSegment() { } // We consider fields whose values have a fixed size to be fixed width fields. FieldSpec.DataType storedType = fieldSpec.getDataType().getStoredType(); - boolean isFieldFixed = (storedType.isFixedWidth() || ( - (storedType.getStoredType() == BYTES || storedType.getStoredType() == BIG_DECIMAL) && fixedByteSize > 0 && consumingAggregatedMetric) + boolean isFieldFixed = ( + storedType.isFixedWidth() + || ( + (storedType.getStoredType() == BYTES + || storedType.getStoredType() == BIG_DECIMAL + ) && fixedByteSize > 0 && consumingAggregatedMetric + ) ); FieldIndexConfigs indexConfigs = Optional.ofNullable(config.getIndexConfigByCol().get(column)) diff --git a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/realtime/impl/forward/FixedByteSVMutableForwardIndex.java b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/realtime/impl/forward/FixedByteSVMutableForwardIndex.java index 8e0982e0497b..9a42deb60332 100644 --- a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/realtime/impl/forward/FixedByteSVMutableForwardIndex.java +++ b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/realtime/impl/forward/FixedByteSVMutableForwardIndex.java @@ -215,7 +215,11 @@ public byte[] getBytes(int docId) { @Override public void setBytes(int docId, byte[] value) { - Preconditions.checkArgument(value.length == _valueSizeInBytes, "Expected value size to be: %s but got: %s ", _valueSizeInBytes, value.length); + Preconditions.checkArgument( + value.length == _valueSizeInBytes, + "Expected value size to be: %s but got: %s ", + _valueSizeInBytes, value.length + ); addBufferIfNeeded(docId); getWriterForRow(docId).setBytes(docId, value); diff --git a/pinot-spi/src/main/java/org/apache/pinot/spi/utils/HyperLogLogUtils.java b/pinot-spi/src/main/java/org/apache/pinot/spi/utils/HyperLogLogUtils.java index bde35e2cbff9..9197cc8e3237 100644 --- a/pinot-spi/src/main/java/org/apache/pinot/spi/utils/HyperLogLogUtils.java +++ b/pinot-spi/src/main/java/org/apache/pinot/spi/utils/HyperLogLogUtils.java @@ -38,4 +38,4 @@ public static int byteSize(HyperLogLog value) { public static int byteSize(int log2m) { return (RegisterSet.getSizeForCount(1 << log2m) + 2) * Integer.BYTES; } -} \ No newline at end of file +} diff --git a/pinot-spi/src/test/java/org/apache/pinot/spi/utils/HyperLogLogUtilsTest.java b/pinot-spi/src/test/java/org/apache/pinot/spi/utils/HyperLogLogUtilsTest.java index 6dfc1a88ed77..2001aa7f49ab 100644 --- a/pinot-spi/src/test/java/org/apache/pinot/spi/utils/HyperLogLogUtilsTest.java +++ b/pinot-spi/src/test/java/org/apache/pinot/spi/utils/HyperLogLogUtilsTest.java @@ -39,7 +39,10 @@ public void testByteSizeWithHLLObject() { int[] testCases = { 1, 2, 3, 4, 5, 6, 7, 8, 9 }; for (int log2m : testCases) { int expectedByteSize = (RegisterSet.getSizeForCount(1 << log2m) + 2) * Integer.BYTES; - assertEquals(HyperLogLogUtils.byteSize(new com.clearspring.analytics.stream.cardinality.HyperLogLog(log2m)), expectedByteSize); + assertEquals( + HyperLogLogUtils.byteSize(new com.clearspring.analytics.stream.cardinality.HyperLogLog(log2m)), + expectedByteSize + ); } } }