Apply Spotless formatting (#54644)

Author: tlrx

gradle/formatting.gradle

@@ -142,8 +142,6 @@ def projectPathsToExclude = [
   ':x-pack:plugin:monitoring',
   ':x-pack:plugin:ql',
   ':x-pack:plugin:rollup',
-  ':x-pack:plugin:searchable-snapshots',
-  ':x-pack:plugin:searchable-snapshots:qa',
   ':x-pack:plugin:search-business-rules',
   ':x-pack:plugin:security',
   ':x-pack:plugin:security:cli',

x-pack/plugin/searchable-snapshots/qa/azure/src/test/java/org/elasticsearch/xpack/searchablesnapshots/AzureSearchableSnapshotsIT.java

@@ -26,11 +26,6 @@ protected Settings repositorySettings() {
         final String basePath = System.getProperty("test.azure.base_path");
         assertThat(basePath, not(blankOrNullString()));
 
-        return Settings.builder()
-            .put("client", "searchable_snapshots")
-            .put("container", container)
-            .put("base_path", basePath)
-            .build();
+        return Settings.builder().put("client", "searchable_snapshots").put("container", container).put("base_path", basePath).build();
     }
 }
-

x-pack/plugin/searchable-snapshots/qa/s3/src/test/java/org/elasticsearch/xpack/searchablesnapshots/s3/S3SearchableSnapshotsIT.java

@@ -26,10 +26,6 @@ protected Settings repositorySettings() {
         final String basePath = System.getProperty("test.s3.base_path");
         assertThat(basePath, not(blankOrNullString()));
 
-        return Settings.builder()
-            .put("client", "searchable_snapshots")
-            .put("bucket", bucket)
-            .put("base_path", basePath)
-            .build();
+        return Settings.builder().put("client", "searchable_snapshots").put("bucket", bucket).put("base_path", basePath).build();
     }
 }

x-pack/plugin/searchable-snapshots/src/main/java/org/elasticsearch/index/store/BaseSearchableSnapshotIndexInput.java

@@ -44,8 +44,11 @@ public BaseSearchableSnapshotIndexInput(
         this.blobContainer = Objects.requireNonNull(blobContainer);
         this.fileInfo = Objects.requireNonNull(fileInfo);
         this.context = Objects.requireNonNull(context);
-        assert fileInfo.metadata().hashEqualsContents() == false
-            : "this method should only be used with blobs that are NOT stored in metadata's hash field (fileInfo: " + fileInfo + ')';
+        assert fileInfo.metadata()
+            .hashEqualsContents() == false : "this method should only be used with blobs that are NOT stored in metadata's hash field "
+                + "(fileInfo: "
+                + fileInfo
+                + ')';
         this.stats = Objects.requireNonNull(stats);
         this.offset = offset;
         this.length = length;
@@ -101,8 +104,13 @@ public final void close() throws IOException {
     protected InputStream openInputStream(final long position, final long length) throws IOException {
         assert assertCurrentThreadMayAccessBlobStore();
         if (fileInfo.numberOfParts() == 1L) {
-            assert position + length <= fileInfo.partBytes(0)
-                : "cannot read [" + position + "-" + (position + length) + "] from [" + fileInfo + "]";
+            assert position + length <= fileInfo.partBytes(0) : "cannot read ["
+                + position
+                + "-"
+                + (position + length)
+                + "] from ["
+                + fileInfo
+                + "]";
             return blobContainer.readBlob(fileInfo.partName(0L), position, length);
         } else {
             final long startPart = getPartNumberForPosition(position);
@@ -112,8 +120,9 @@ protected InputStream openInputStream(final long position, final long length) th
                 protected InputStream openSlice(long slice) throws IOException {
                     final long currentPart = startPart + slice;
                     final long startInPart = (currentPart == startPart) ? getRelativePositionInPart(position) : 0L;
-                    final long endInPart
-                        = (currentPart == endPart) ? getRelativePositionInPart(position + length) : getLengthOfPart(currentPart);
+                    final long endInPart = (currentPart == endPart)
+                        ? getRelativePositionInPart(position + length)
+                        : getLengthOfPart(currentPart);
                     return blobContainer.readBlob(fileInfo.partName(currentPart), startInPart, endInPart - startInPart);
                 }
             };
@@ -137,8 +146,7 @@ protected final boolean assertCurrentThreadMayAccessBlobStore() {
 
             // Unit tests access the blob store on the main test thread; simplest just to permit this rather than have them override this
             // method somehow.
-            || threadName.startsWith("TEST-")
-            : "current thread [" + Thread.currentThread() + "] may not read " + fileInfo;
+            || threadName.startsWith("TEST-") : "current thread [" + Thread.currentThread() + "] may not read " + fileInfo;
         return true;
     }
 

x-pack/plugin/searchable-snapshots/src/main/java/org/elasticsearch/index/store/InMemoryNoOpCommitDirectory.java

@@ -67,12 +67,10 @@ public long fileLength(String name) throws IOException {
     }
 
     @Override
-    public void sync(Collection<String> names) {
-    }
+    public void sync(Collection<String> names) {}
 
     @Override
-    public void syncMetaData() {
-    }
+    public void syncMetaData() {}
 
     @Override
     public IndexOutput createOutput(String name, IOContext context) throws IOException {

x-pack/plugin/searchable-snapshots/src/main/java/org/elasticsearch/index/store/SearchableSnapshotDirectory.java

@@ -249,7 +249,13 @@ public IndexInput openInput(final String name, final IOContext context) throws I
             return new CachedBlobContainerIndexInput(this, fileInfo, context, inputStats);
         } else {
             return new DirectBlobContainerIndexInput(
-                blobContainer(), fileInfo, context, inputStats, getUncachedChunkSize(), bufferSize(context));
+                blobContainer(),
+                fileInfo,
+                context,
+                inputStats,
+                getUncachedChunkSize(),
+                bufferSize(context)
+            );
         }
     }
 
@@ -271,11 +277,13 @@ public String toString() {
         return this.getClass().getSimpleName() + "@" + snapshot().snapshot() + " lockFactory=" + lockFactory;
     }
 
-    public static Directory create(RepositoriesService repositories,
-                                   CacheService cache,
-                                   IndexSettings indexSettings,
-                                   ShardPath shardPath,
-                                   LongSupplier currentTimeNanosSupplier) throws IOException {
+    public static Directory create(
+        RepositoriesService repositories,
+        CacheService cache,
+        IndexSettings indexSettings,
+        ShardPath shardPath,
+        LongSupplier currentTimeNanosSupplier
+    ) throws IOException {
 
         final Repository repository = repositories.repository(SNAPSHOT_REPOSITORY_SETTING.get(indexSettings.getSettings()));
         if (repository instanceof BlobStoreRepository == false) {
@@ -289,10 +297,12 @@ public static Directory create(RepositoriesService repositories,
             SNAPSHOT_SNAPSHOT_ID_SETTING.get(indexSettings.getSettings())
         );
 
-        final LazyInitializable<BlobContainer, RuntimeException> lazyBlobContainer
-            = new LazyInitializable<>(() -> blobStoreRepository.shardContainer(indexId, shardPath.getShardId().id()));
-        final LazyInitializable<BlobStoreIndexShardSnapshot, RuntimeException> lazySnapshot
-            = new LazyInitializable<>(() -> blobStoreRepository.loadShardSnapshot(lazyBlobContainer.getOrCompute(), snapshotId));
+        final LazyInitializable<BlobContainer, RuntimeException> lazyBlobContainer = new LazyInitializable<>(
+            () -> blobStoreRepository.shardContainer(indexId, shardPath.getShardId().id())
+        );
+        final LazyInitializable<BlobStoreIndexShardSnapshot, RuntimeException> lazySnapshot = new LazyInitializable<>(
+            () -> blobStoreRepository.loadShardSnapshot(lazyBlobContainer.getOrCompute(), snapshotId)
+        );
 
         final Path cacheDir = shardPath.getDataPath().resolve("snapshots").resolve(snapshotId.getUUID());
         Files.createDirectories(cacheDir);

x-pack/plugin/searchable-snapshots/src/main/java/org/elasticsearch/index/store/cache/CacheFile.java

@@ -34,9 +34,11 @@ public interface EvictionListener {
         void onEviction(CacheFile evictedCacheFile);
     }
 
-    private static final StandardOpenOption[] OPEN_OPTIONS = new StandardOpenOption[]{
-        StandardOpenOption.READ, StandardOpenOption.WRITE, StandardOpenOption.CREATE, StandardOpenOption.SPARSE
-    };
+    private static final StandardOpenOption[] OPEN_OPTIONS = new StandardOpenOption[] {
+        StandardOpenOption.READ,
+        StandardOpenOption.WRITE,
+        StandardOpenOption.CREATE,
+        StandardOpenOption.SPARSE };
 
     private final AbstractRefCounted refCounter = new AbstractRefCounted("CacheFile") {
         @Override
@@ -218,15 +220,22 @@ private boolean invariant() {
 
     @Override
     public String toString() {
-        return "CacheFile{" +
-            "desc='" + description + '\'' +
-            ", file=" + file +
-            ", length=" + tracker.getLength() +
-            ", channel=" + (channel != null ? "yes" : "no") +
-            ", listeners=" + listeners.size() +
-            ", evicted=" + evicted +
-            ", tracker=" + tracker +
-            '}';
+        return "CacheFile{"
+            + "desc='"
+            + description
+            + "', file="
+            + file
+            + ", length="
+            + tracker.getLength()
+            + ", channel="
+            + (channel != null ? "yes" : "no")
+            + ", listeners="
+            + listeners.size()
+            + ", evicted="
+            + evicted
+            + ", tracker="
+            + tracker
+            + '}';
     }
 
     private void ensureOpen() {
@@ -235,9 +244,11 @@ private void ensureOpen() {
         }
     }
 
-    CompletableFuture<Integer> fetchRange(long position,
-                                          CheckedBiFunction<Long, Long, Integer, IOException> onRangeAvailable,
-                                          CheckedBiConsumer<Long, Long, IOException> onRangeMissing) {
+    CompletableFuture<Integer> fetchRange(
+        long position,
+        CheckedBiFunction<Long, Long, Integer, IOException> onRangeAvailable,
+        CheckedBiConsumer<Long, Long, IOException> onRangeMissing
+    ) {
         final CompletableFuture<Integer> future = new CompletableFuture<>();
         try {
             if (position < 0 || position > tracker.getLength()) {
@@ -248,18 +259,20 @@ CompletableFuture<Integer> fetchRange(long position,
             final long rangeStart = (position / rangeSize) * rangeSize;
             final long rangeEnd = Math.min(rangeStart + rangeSize, tracker.getLength());
 
-            final List<SparseFileTracker.Gap> gaps = tracker.waitForRange(rangeStart, rangeEnd,
+            final List<SparseFileTracker.Gap> gaps = tracker.waitForRange(
+                rangeStart,
+                rangeEnd,
                 ActionListener.wrap(
                     rangeReady -> future.complete(onRangeAvailable.apply(rangeStart, rangeEnd)),
-                    rangeFailure -> future.completeExceptionally(rangeFailure)));
+                    rangeFailure -> future.completeExceptionally(rangeFailure)
+                )
+            );
 
             if (gaps.size() > 0) {
                 final SparseFileTracker.Gap range = gaps.get(0);
                 assert gaps.size() == 1 : "expected 1 range to fetch but got " + gaps.size();
-                assert range.start == rangeStart
-                    : "range/gap start mismatch (" + range.start + ',' + rangeStart + ')';
-                assert range.end == rangeEnd
-                    : "range/gap end mismatch (" + range.end + ',' + rangeEnd + ')';
+                assert range.start == rangeStart : "range/gap start mismatch (" + range.start + ',' + rangeStart + ')';
+                assert range.end == rangeEnd : "range/gap end mismatch (" + range.end + ',' + rangeEnd + ')';
 
                 try {
                     ensureOpen();

x-pack/plugin/searchable-snapshots/src/main/java/org/elasticsearch/index/store/cache/CacheKey.java

@@ -63,12 +63,7 @@ public int hashCode() {
 
     @Override
     public String toString() {
-        return "[" +
-            "snapshotId=" + snapshotId +
-            ", indexId=" + indexId +
-            ", shardId=" + shardId +
-            ", fileName='" + fileName + '\'' +
-            ']';
+        return "[" + "snapshotId=" + snapshotId + ", indexId=" + indexId + ", shardId=" + shardId + ", fileName='" + fileName + "']";
     }
 
     public boolean belongsTo(SnapshotId snapshotId, IndexId indexId, ShardId shardId) {