lint fix

apache · Jul 26, 2023 · 38160a4 · 38160a4
1 parent ee0fa5a
commit 38160a4
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 5 deletions.
diff --git a/...src/main/java/org/apache/pinot/segment/local/indexsegment/mutable/MutableSegmentImpl.java b/...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/.../org/apache/pinot/segment/local/realtime/impl/forward/FixedByteSVMutableForwardIndex.java b/.../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
@@ -38,4 +38,4 @@ public static int byteSize(HyperLogLog value) {
   public static int byteSize(int log2m) {
     return (RegisterSet.getSizeForCount(1 << log2m) + 2) * Integer.BYTES;
   }
-}
+}
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
@@ -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
+      );
     }
   }
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -38,4 +38,4 @@ public static int byteSize(HyperLogLog value) { @@
       public static int byteSize(int log2m) {
         return (RegisterSet.getSizeForCount(1 << log2m) + 2) * Integer.BYTES;
       }
-    }
+    }