[CI] Auto commit changes from spotless

Author: elasticsearchmachine

server/src/main/java/org/elasticsearch/index/mapper/IdLoader.java

@@ -74,8 +74,8 @@ final class TsIdLoader implements IdLoader {
             this.indexRouting = indexRouting;
         }
 
-        public IdLoader.Leaf leaf(
-            SourceLoader.Leaf leafSourceLoader, LeafStoredFieldLoader loader, LeafReader reader, int[] docIdsInLeaf) throws IOException {
+        public IdLoader.Leaf leaf(SourceLoader.Leaf leafSourceLoader, LeafStoredFieldLoader loader, LeafReader reader, int[] docIdsInLeaf)
+            throws IOException {
             IndexRouting.ExtractFromSource.Builder[] builders = null;
             if (indexRouting != null) {
                 builders = new IndexRouting.ExtractFromSource.Builder[docIdsInLeaf.length];
@@ -134,9 +134,8 @@ public IdLoader.Leaf leaf(
     }
 
     final class LogsdbLoader implements IdLoader {
-        public IdLoader.Leaf leaf(
-            SourceLoader.Leaf leafSourceLoader, LeafStoredFieldLoader loader, LeafReader reader, int[] docIdsInLeaf
-        ) throws IOException {
+        public IdLoader.Leaf leaf(SourceLoader.Leaf leafSourceLoader, LeafStoredFieldLoader loader, LeafReader reader, int[] docIdsInLeaf)
+            throws IOException {
             try {
                 SortedDocValues idDocValues = DocValues.getSorted(reader, IdFieldMapper.NAME);
                 return loadDocValues(idDocValues, docIdsInLeaf);
@@ -164,8 +163,8 @@ final class StoredIdLoader implements IdLoader {
         public StoredIdLoader() {}
 
         @Override
-        public Leaf leaf(
-            SourceLoader.Leaf leafSourceLoader, LeafStoredFieldLoader loader, LeafReader reader, int[] docIdsInLeaf) throws IOException {
+        public Leaf leaf(SourceLoader.Leaf leafSourceLoader, LeafStoredFieldLoader loader, LeafReader reader, int[] docIdsInLeaf)
+            throws IOException {
             return new StoredLeaf(loader);
         }
     }

server/src/main/java/org/elasticsearch/index/mapper/LogsdbIdFieldMapper.java

@@ -17,7 +17,6 @@
 
 import java.util.Collection;
 import java.util.Collections;
-import java.util.List;
 
 /**
  * A mapper for the _id field.
@@ -73,9 +72,7 @@ public boolean isSearchable() {
 
         @Override
         public Query termsQuery(Collection<?> values, SearchExecutionContext context) {
-            var bytesRefs = values.stream()
-                .map(LogsdbIdFieldType::encode)
-                .map(this::indexedValueForSearch).toList();
+            var bytesRefs = values.stream().map(LogsdbIdFieldType::encode).map(this::indexedValueForSearch).toList();
             return SortedDocValuesField.newSlowSetQuery(name(), bytesRefs);
         }
 

x-pack/plugin/logsdb/src/internalClusterTest/java/org/elasticsearch/xpack/logsdb/LogsIdIT.java

@@ -17,16 +17,13 @@
 import org.elasticsearch.action.get.GetRequest;
 import org.elasticsearch.action.index.IndexRequest;
 import org.elasticsearch.action.search.SearchRequest;
-import org.elasticsearch.action.search.SearchResponse;
-import org.elasticsearch.client.Request;
 import org.elasticsearch.cluster.metadata.ComposableIndexTemplate;
 import org.elasticsearch.cluster.metadata.Template;
 import org.elasticsearch.common.compress.CompressedXContent;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.time.DateFormatter;
 import org.elasticsearch.common.time.FormatNames;
 import org.elasticsearch.datastreams.DataStreamsPlugin;
-import org.elasticsearch.index.query.MatchAllQueryBuilder;
 import org.elasticsearch.index.query.TermQueryBuilder;
 import org.elasticsearch.license.LicenseSettings;
 import org.elasticsearch.plugins.Plugin;
@@ -40,14 +37,11 @@
 
 import java.io.IOException;
 import java.time.Instant;
-import java.util.Arrays;
 import java.util.Collection;
-import java.util.Comparator;
 import java.util.List;
 import java.util.UUID;
 import java.util.concurrent.ExecutionException;
 
-import static org.elasticsearch.index.query.QueryBuilders.matchQuery;
 import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertResponse;
 import static org.hamcrest.Matchers.*;
 
@@ -120,9 +114,7 @@ public void testGetByGeneratedId() throws Exception {
         for (int j = 0; j < numDocs; j++) {
             var indexRequest = new IndexRequest(dataStreamName).opType(DocWriteRequest.OpType.CREATE);
             indexRequest.source(
-                DOC.replace("$time", formatInstant(time))
-                    .replace("$uuid", UUID.randomUUID().toString())
-                    .replace("$pod", "pod-" + j),
+                DOC.replace("$time", formatInstant(time)).replace("$uuid", UUID.randomUUID().toString()).replace("$pod", "pod-" + j),
                 XContentType.JSON
             );
             bulkRequest.add(indexRequest);
@@ -160,13 +152,9 @@ public void testGetByProvidedID() throws Exception {
         BulkRequest bulkRequest = new BulkRequest(indexName);
         int numDocs = randomIntBetween(16, 256);
         for (int j = 0; j < numDocs; j++) {
-            var indexRequest = new IndexRequest(indexName)
-                .opType(DocWriteRequest.OpType.INDEX)
-                .id("id-" + j);
+            var indexRequest = new IndexRequest(indexName).opType(DocWriteRequest.OpType.INDEX).id("id-" + j);
             indexRequest.source(
-                DOC.replace("$time", formatInstant(time))
-                    .replace("$uuid", UUID.randomUUID().toString())
-                    .replace("$pod", "pod-" + j),
+                DOC.replace("$time", formatInstant(time)).replace("$uuid", UUID.randomUUID().toString()).replace("$pod", "pod-" + j),
                 XContentType.JSON
             );
             bulkRequest.add(indexRequest);
@@ -215,13 +203,9 @@ public void testMatchByProvidedID() throws Exception {
         BulkRequest bulkRequest = new BulkRequest(indexName);
         int numDocs = randomIntBetween(16, 256);
         for (int j = 0; j < numDocs; j++) {
-            var indexRequest = new IndexRequest(indexName)
-                .opType(DocWriteRequest.OpType.INDEX)
-                .id("id-" + j);
+            var indexRequest = new IndexRequest(indexName).opType(DocWriteRequest.OpType.INDEX).id("id-" + j);
             indexRequest.source(
-                DOC.replace("$time", formatInstant(time))
-                    .replace("$uuid", UUID.randomUUID().toString())
-                    .replace("$pod", "pod-" + j),
+                DOC.replace("$time", formatInstant(time)).replace("$uuid", UUID.randomUUID().toString()).replace("$pod", "pod-" + j),
                 XContentType.JSON
             );
             bulkRequest.add(indexRequest);
@@ -259,7 +243,6 @@ private void createTemplate(String dataStreamName) throws IOException {
         client().execute(TransportPutComposableIndexTemplateAction.TYPE, putTemplateRequest).actionGet();
     }
 
-
     private void checkIndexSearchAndRetrieval(String dataStreamName, boolean routeOnSortFields) throws Exception {
         String[] uuis = {
             UUID.randomUUID().toString(),
@@ -331,9 +314,7 @@ static String formatInstant(Instant instant) {
     public void flush(String index, boolean force) throws IOException, ExecutionException, InterruptedException {
         logger.info("flushing index {} force={}", index, force);
         FlushRequest flushRequest = new FlushRequest(index).force(force);
-        assertResponse(client().admin().indices().flush(flushRequest), response -> {
-            assertEquals(0, response.getFailedShards());
-        });
+        assertResponse(client().admin().indices().flush(flushRequest), response -> { assertEquals(0, response.getFailedShards()); });
     }
 
 }