[CI] Auto commit changes from spotless

Author: elasticsearchmachine

benchmarks/src/main/java/org/elasticsearch/benchmark/common/compress/FSSTCompressBenchmark.java

@@ -48,6 +48,7 @@ public static class CompressionMetrics {
     }
 
     private static final int MB_8 = 8 * 1024 * 1024;
+
     private byte[] concatenateTo8mb(byte[] contentBytes) {
         byte[] bytes = new byte[MB_8 + 8];
         int i = 0;
@@ -66,7 +67,7 @@ public void setup() throws IOException {
 
         byte[] contentBytes = FSST.toBytes(content);
         input = concatenateTo8mb(contentBytes);
-        offsets = new int[]{0, MB_8};
+        offsets = new int[] { 0, MB_8 };
         outBuf = new byte[MB_8];
         outOffsets = new int[2];
     }
@@ -100,19 +101,19 @@ public void compressLZ4Fast(Blackhole bh, CompressionMetrics metrics) throws IOE
         metrics.compressionRatio = compressedSize / (double) inputSize;
     }
 
-//    @Benchmark
-//    public void compressLZ4High(Blackhole bh, CompressionMetrics metrics) throws IOException {
-//        int inputSize = offsets[1];
-//
-//        var dataInput = new ByteBuffersDataInput(List.of(ByteBuffer.wrap(input)));
-//        var dataOutput = new ByteArrayDataOutput(outBuf);
-//
-//        Compressor compressor = CompressionMode.HIGH_COMPRESSION.newCompressor();
-//        compressor.compress(dataInput, dataOutput);
-//
-//        long compressedSize = dataOutput.getPosition();
-//        bh.consume(dataOutput);
-//
-//        metrics.compressionRatio = compressedSize / (double) inputSize;
-//    }
+    // @Benchmark
+    // public void compressLZ4High(Blackhole bh, CompressionMetrics metrics) throws IOException {
+    // int inputSize = offsets[1];
+    //
+    // var dataInput = new ByteBuffersDataInput(List.of(ByteBuffer.wrap(input)));
+    // var dataOutput = new ByteArrayDataOutput(outBuf);
+    //
+    // Compressor compressor = CompressionMode.HIGH_COMPRESSION.newCompressor();
+    // compressor.compress(dataInput, dataOutput);
+    //
+    // long compressedSize = dataOutput.getPosition();
+    // bh.consume(dataOutput);
+    //
+    // metrics.compressionRatio = compressedSize / (double) inputSize;
+    // }
 }

benchmarks/src/main/java/org/elasticsearch/benchmark/common/compress/FSSTDecompressBenchmark.java

@@ -25,7 +25,6 @@
 import java.nio.charset.StandardCharsets;
 import java.nio.file.Files;
 import java.nio.file.Path;
-import java.util.Arrays;
 import java.util.List;
 import java.util.concurrent.TimeUnit;
 
@@ -37,8 +36,8 @@
 @State(Scope.Benchmark)
 public class FSSTDecompressBenchmark {
 
-//    @Param({ "fsst", "lz4_high", "lz4_fast" })
-    @Param({"fsst", "lz4_fast"})
+    // @Param({ "fsst", "lz4_high", "lz4_fast" })
+    @Param({ "fsst", "lz4_fast" })
     public String compressionType;
 
     @Param("")
@@ -61,6 +60,7 @@ public class FSSTDecompressBenchmark {
     private FSST.SymbolTable symbolTable;
 
     private static final int MB_8 = 8 * 1024 * 1024;
+
     private byte[] concatenateTo8mb(byte[] contentBytes) {
         byte[] bytes = new byte[MB_8 + 8];
         int i = 0;
@@ -79,7 +79,7 @@ public void setup() throws IOException {
         byte[] contentBytes = FSST.toBytes(content);
         originalSize = MB_8;
         input = concatenateTo8mb(contentBytes);
-        offsets = new int[]{0, originalSize};
+        offsets = new int[] { 0, originalSize };
 
         outBuf = new byte[input.length];
         outOffsets = new int[2];

server/src/main/java/org/elasticsearch/common/compress/fsst/BulkCompressBufferer.java

@@ -104,7 +104,7 @@ private void compressAndWriteBuffer() throws IOException {
 
         finalOutput.writeBytes(outBuf, 0, (int) fullOutLen);
         for (int i = 0; i < numLines; ++i) {
-            int len = outOffsets[i+1] - outOffsets[i];
+            int len = outOffsets[i + 1] - outOffsets[i];
             offsetWriter.addLen(len);
         }
 

server/src/main/java/org/elasticsearch/index/codec/tsdb/es819/ES819TSDBDocValuesConsumer.java

@@ -47,7 +47,6 @@
 import org.elasticsearch.index.codec.tsdb.BinaryDVCompressionMode;
 import org.elasticsearch.index.codec.tsdb.TSDBDocValuesEncoder;
 
-import java.io.Closeable;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Arrays;

server/src/main/java/org/elasticsearch/index/codec/tsdb/es819/ES819TSDBDocValuesFormat.java

@@ -120,7 +120,11 @@ public ES819TSDBDocValuesFormat(BinaryDVCompressionMode binaryDVCompressionMode)
     }
 
     /** Doc values fields format with specified skipIndexIntervalSize. */
-    public ES819TSDBDocValuesFormat(int skipIndexIntervalSize, boolean enableOptimizedMerge, BinaryDVCompressionMode binaryDVCompressionMode) {
+    public ES819TSDBDocValuesFormat(
+        int skipIndexIntervalSize,
+        boolean enableOptimizedMerge,
+        BinaryDVCompressionMode binaryDVCompressionMode
+    ) {
         super(CODEC_NAME);
         if (skipIndexIntervalSize < 2) {
             throw new IllegalArgumentException("skipIndexIntervalSize must be > 1, got [" + skipIndexIntervalSize + "]");

server/src/main/java/org/elasticsearch/index/codec/tsdb/es819/ES819TSDBDocValuesProducer.java

@@ -177,7 +177,6 @@ public NumericDocValues getNumeric(FieldInfo field) throws IOException {
         return getNumeric(entry, -1);
     }
 
-
     @Override
     public BinaryDocValues getBinary(FieldInfo field) throws IOException {
         BinaryEntry entry = binaries.get(field.number);
@@ -280,6 +279,7 @@ public BinaryDocValues getCompressedBinaryFSST(BinaryEntry entry) throws IOExcep
                 return new DenseBinaryDocValues(maxDoc) {
                     final BytesRef inBuf = new BytesRef(new byte[maxCompressedLength], 0, maxCompressedLength);
                     final BytesRef outBuf = new BytesRef(new byte[lengthToAllocate], 0, lengthToAllocate);
+
                     @Override
                     public BytesRef binaryValue() throws IOException {
                         bytesSlice.readBytes((long) doc * maxCompressedLength, inBuf.bytes, 0, maxCompressedLength);
@@ -335,6 +335,7 @@ public BytesRef binaryValue() throws IOException {
                 return new SparseBinaryDocValues(disi) {
                     final BytesRef inBuf = new BytesRef(new byte[maxCompressedLength], 0, 0);
                     final BytesRef outBuf = new BytesRef(new byte[lengthToAllocate], 0, lengthToAllocate);
+
                     @Override
                     public BytesRef binaryValue() throws IOException {
                         final int index = disi.index();
@@ -1584,7 +1585,6 @@ static class BinaryEntry {
         int maxCompressedLength;
         FSST.Decoder decoder;
 
-
         private BinaryEntry(BinaryDVCompressionMode compression) {
             this.compression = compression;
         }

server/src/test/java/org/elasticsearch/index/codec/tsdb/es819/ES819TSDBDocValuesFormatVariableSkipIntervalTests.java

@@ -19,7 +19,9 @@ public class ES819TSDBDocValuesFormatVariableSkipIntervalTests extends ES87TSDBD
     protected Codec getCodec() {
         var compressionMode = ES819TSDBDocValuesFormatTests.randomBinaryDVCompressionMode(random());
         // small interval size to test with many intervals
-        return TestUtil.alwaysDocValuesFormat(new ES819TSDBDocValuesFormat(random().nextInt(4, 16), random().nextBoolean(), compressionMode));
+        return TestUtil.alwaysDocValuesFormat(
+            new ES819TSDBDocValuesFormat(random().nextInt(4, 16), random().nextBoolean(), compressionMode)
+        );
     }
 
     public void testSkipIndexIntervalSize() {