Fix: Gradle Checks

Signed-off-by: sukriti sinha <[email protected]>

Author: sukriti sinha

gradle/run.gradle

@@ -11,7 +11,8 @@
 
 /*
  * Licensed to Elasticsearch under one or more contributor
- * license agreements. See the NOTICE file distributed with
+ * license agreements. See the 
+ NOTICE file distributed with
  * this work for additional information regarding copyright
  * ownership. Elasticsearch licenses this file to you under
  * the Apache License, Version 2.0 (the "License"); you may

server/src/main/java/org/opensearch/action/admin/cluster/remotestore/metadata/RemoteStoreMetadata.java

@@ -10,6 +10,7 @@
 
 import java.io.IOException;
 import java.util.Map;
+
 /**
  * Response model that holds the remote store metadata (segment and translog) for a shard.
  *
@@ -21,11 +22,7 @@ public class RemoteStoreMetadata implements Writeable, ToXContentFragment {
     private final Map<String, Object> translog;
     private final ShardRouting shardRouting;
 
-    public RemoteStoreMetadata(
-        Map<String, Object> segments,
-        Map<String, Object> translog,
-        ShardRouting shardRouting
-    ) {
+    public RemoteStoreMetadata(Map<String, Object> segments, Map<String, Object> translog, ShardRouting shardRouting) {
         this.segments = segments;
         this.translog = translog;
         this.shardRouting = shardRouting;
@@ -47,7 +44,7 @@ public void writeTo(StreamOutput out) throws IOException {
     @Override
     public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
         builder.startObject();
-        
+
         builder.startObject("segments");
         for (Map.Entry<String, Object> entry : segments.entrySet()) {
             builder.field(entry.getKey(), entry.getValue());
@@ -66,4 +63,4 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
     public ShardRouting getShardRouting() {
         return shardRouting;
     }
-}
+}

server/src/main/java/org/opensearch/action/admin/cluster/remotestore/metadata/RemoteStoreMetadataAction.java

@@ -6,20 +6,20 @@
  * compatible open source license.
  */
 
- package org.opensearch.action.admin.cluster.remotestore.metadata;
+package org.opensearch.action.admin.cluster.remotestore.metadata;
 
- import org.opensearch.action.ActionType;
- 
- /**
-  * Action to fetch metadata from remote store
-  *
-  * @opensearch.internal
-  */
+import org.opensearch.action.ActionType;
+
+/**
+ * Action to fetch metadata from remote store
+ *
+ * @opensearch.internal
+ */
 public class RemoteStoreMetadataAction extends ActionType<RemoteStoreMetadataResponse> {
     public static final RemoteStoreMetadataAction INSTANCE = new RemoteStoreMetadataAction();
     public static final String NAME = "cluster:admin/remote_store/metadata";
 
     private RemoteStoreMetadataAction() {
         super(NAME, RemoteStoreMetadataResponse::new);
     }
-}
+}

server/src/main/java/org/opensearch/action/admin/cluster/remotestore/metadata/RemoteStoreMetadataRequest.java

@@ -6,6 +6,7 @@
 import org.opensearch.core.common.io.stream.StreamOutput;
 
 import java.io.IOException;
+
 /**
  * Request object for fetching remote store metadata of shards for a given index.
  *
@@ -50,4 +51,4 @@ public void local(boolean local) {
     public boolean local() {
         return local;
     }
-}
+}

server/src/main/java/org/opensearch/action/admin/cluster/remotestore/metadata/RemoteStoreMetadataRequestBuilder.java

@@ -6,49 +6,49 @@
  * compatible open source license.
  */
 
- package org.opensearch.action.admin.cluster.remotestore.metadata;
+package org.opensearch.action.admin.cluster.remotestore.metadata;
 
- import org.opensearch.action.support.broadcast.BroadcastOperationRequestBuilder;
- import org.opensearch.common.annotation.PublicApi;
- import org.opensearch.common.unit.TimeValue;
- import org.opensearch.transport.client.OpenSearchClient;
- 
- /**
-  * Builder for RemoteStoreMetadataRequest
-  *
-  * @opensearch.api
-  */
- @PublicApi(since = "3.0.0")
- public class RemoteStoreMetadataRequestBuilder extends BroadcastOperationRequestBuilder<
-     RemoteStoreMetadataRequest,
-     RemoteStoreMetadataResponse,
-     RemoteStoreMetadataRequestBuilder> {
- 
-     public RemoteStoreMetadataRequestBuilder(OpenSearchClient client, RemoteStoreMetadataAction action) {
-         super(client, action, new RemoteStoreMetadataRequest());
-     }
- 
-     /**
-      * Sets timeout of request.
-      */
-     public final RemoteStoreMetadataRequestBuilder setTimeout(TimeValue timeout) {
-         request.timeout(timeout);
-         return this;
-     }
- 
-     /**
-      * Sets shards preference of request.
-      */
-     public final RemoteStoreMetadataRequestBuilder setShards(String... shards) {
-         request.shards(shards);
-         return this;
-     }
- 
-     /**
-      * Sets local shards preference of request.
-      */
-     public final RemoteStoreMetadataRequestBuilder setLocal(boolean local) {
-         request.local(local);
-         return this;
-     }
- }
+import org.opensearch.action.support.broadcast.BroadcastOperationRequestBuilder;
+import org.opensearch.common.annotation.PublicApi;
+import org.opensearch.common.unit.TimeValue;
+import org.opensearch.transport.client.OpenSearchClient;
+
+/**
+ * Builder for RemoteStoreMetadataRequest
+ *
+ * @opensearch.api
+ */
+@PublicApi(since = "3.0.0")
+public class RemoteStoreMetadataRequestBuilder extends BroadcastOperationRequestBuilder<
+    RemoteStoreMetadataRequest,
+    RemoteStoreMetadataResponse,
+    RemoteStoreMetadataRequestBuilder> {
+
+    public RemoteStoreMetadataRequestBuilder(OpenSearchClient client, RemoteStoreMetadataAction action) {
+        super(client, action, new RemoteStoreMetadataRequest());
+    }
+
+    /**
+     * Sets timeout of request.
+     */
+    public final RemoteStoreMetadataRequestBuilder setTimeout(TimeValue timeout) {
+        request.timeout(timeout);
+        return this;
+    }
+
+    /**
+     * Sets shards preference of request.
+     */
+    public final RemoteStoreMetadataRequestBuilder setShards(String... shards) {
+        request.shards(shards);
+        return this;
+    }
+
+    /**
+     * Sets local shards preference of request.
+     */
+    public final RemoteStoreMetadataRequestBuilder setLocal(boolean local) {
+        request.local(local);
+        return this;
+    }
+}

server/src/main/java/org/opensearch/action/admin/cluster/remotestore/metadata/RemoteStoreMetadataResponse.java

@@ -98,4 +98,4 @@ static final class Fields {
         static final String SHARDS = "shards";
         static final String INDICES = "indices";
     }
-}
+}

server/src/main/java/org/opensearch/action/admin/cluster/remotestore/metadata/TransportRemoteStoreMetadataAction.java

@@ -35,7 +35,13 @@
 import java.nio.file.DirectoryStream;
 import java.nio.file.Files;
 import java.nio.file.Path;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Arrays;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.stream.Collectors;
 
@@ -77,7 +83,7 @@ public TransportRemoteStoreMetadataAction(
     protected void doExecute(Task task, RemoteStoreMetadataRequest request, ActionListener<RemoteStoreMetadataResponse> listener) {
         try {
             ClusterState state = clusterService.state();
-            
+
             // Check blocks
             ClusterBlockException blockException = checkBlocks(state, request);
             if (blockException != null) {
@@ -88,14 +94,13 @@ protected void doExecute(Task task, RemoteStoreMetadataRequest request, ActionLi
             // Resolve concrete indices
             String[] concreteIndices = indexNameExpressionResolver.concreteIndexNames(state, request);
             if (concreteIndices.length == 0) {
-                listener.onResponse(new RemoteStoreMetadataResponse(
-                    new RemoteStoreMetadata[0], 0, 0, 0, Collections.emptyList()));
+                listener.onResponse(new RemoteStoreMetadataResponse(new RemoteStoreMetadata[0], 0, 0, 0, Collections.emptyList()));
                 return;
             }
 
             // Get relevant shards
             List<ShardRouting> selectedShards = getSelectedShards(state, request, concreteIndices);
-            
+
             // Process each shard
             List<RemoteStoreMetadata> responses = new ArrayList<>();
             AtomicInteger successfulShards = new AtomicInteger(0);
@@ -109,10 +114,9 @@ protected void doExecute(Task task, RemoteStoreMetadataRequest request, ActionLi
                     successfulShards.incrementAndGet();
                 } catch (Exception e) {
                     failedShards.incrementAndGet();
-                    shardFailures.add(new DefaultShardOperationFailedException(
-                        shardRouting.shardId().getIndexName(),
-                        shardRouting.shardId().getId(),
-                        e));
+                    shardFailures.add(
+                        new DefaultShardOperationFailedException(shardRouting.shardId().getIndexName(), shardRouting.shardId().getId(), e)
+                    );
                 }
             }
 
@@ -123,7 +127,7 @@ protected void doExecute(Task task, RemoteStoreMetadataRequest request, ActionLi
                 failedShards.get(),
                 shardFailures
             );
-            
+
             listener.onResponse(response);
 
         } catch (Exception e) {
@@ -141,22 +145,23 @@ private ClusterBlockException checkBlocks(ClusterState state, RemoteStoreMetadat
         return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_READ, concreteIndices);
     }
 
-    private List<ShardRouting> getSelectedShards(
-        ClusterState clusterState,
-        RemoteStoreMetadataRequest request,
-        String[] concreteIndices
-    ) {
+    private List<ShardRouting> getSelectedShards(ClusterState clusterState, RemoteStoreMetadataRequest request, String[] concreteIndices) {
         return clusterState.routingTable()
             .allShards(concreteIndices)
             .getShardRoutings()
             .stream()
-            .filter(shardRouting -> request.shards().length == 0 ||
-                Arrays.asList(request.shards()).contains(Integer.toString(shardRouting.shardId().id())))
-            .filter(shardRouting -> !request.local() ||
-                Objects.equals(shardRouting.currentNodeId(), clusterState.getNodes().getLocalNodeId()))
-            .filter(shardRouting -> Boolean.parseBoolean(
-                clusterState.getMetadata().index(shardRouting.index())
-                    .getSettings().get(IndexMetadata.SETTING_REMOTE_STORE_ENABLED)))
+            .filter(
+                shardRouting -> request.shards().length == 0
+                    || Arrays.asList(request.shards()).contains(Integer.toString(shardRouting.shardId().id()))
+            )
+            .filter(
+                shardRouting -> !request.local() || Objects.equals(shardRouting.currentNodeId(), clusterState.getNodes().getLocalNodeId())
+            )
+            .filter(
+                shardRouting -> Boolean.parseBoolean(
+                    clusterState.getMetadata().index(shardRouting.index()).getSettings().get(IndexMetadata.SETTING_REMOTE_STORE_ENABLED)
+                )
+            )
             .collect(Collectors.toList());
     }
 
@@ -168,9 +173,7 @@ private RemoteStoreMetadata getShardMetadata(ShardRouting shardRouting) throws I
             throw new ShardNotFoundException(indexShard.shardId());
         }
 
-        String repoLocation = clusterService.localNode()
-            .getAttributes()
-            .get("remote_store.repository.my-repository.settings.location");
+        String repoLocation = clusterService.localNode().getAttributes().get("remote_store.repository.my-repository.settings.location");
 
         String indexUUID = shardRouting.index().getUUID();
         int shardId = shardRouting.shardId().id();
@@ -191,8 +194,10 @@ private Map<String, Object> readSegmentMetadata(String metadataPath) throws IOEx
 
         try (DirectoryStream<Path> stream = Files.newDirectoryStream(path, "metadata__*")) {
             for (Path metadataFile : stream) {
-                try (InputStream in = Files.newInputStream(metadataFile);
-                     IndexInput idxIn = new ByteArrayIndexInput(metadataFile.getFileName().toString(), in.readAllBytes())) {
+                try (
+                    InputStream in = Files.newInputStream(metadataFile);
+                    IndexInput idxIn = new ByteArrayIndexInput(metadataFile.getFileName().toString(), in.readAllBytes())
+                ) {
 
                     RemoteSegmentMetadata segMetadata = metadataStreamWrapper.readStream(idxIn);
                     Map<String, Object> fileMetadata = new HashMap<>();
@@ -212,15 +217,25 @@ private Map<String, Object> readSegmentMetadata(String metadataPath) throws IOEx
 
                     if (segMetadata.getReplicationCheckpoint() != null) {
                         var cp = segMetadata.getReplicationCheckpoint();
-                        fileMetadata.put("replication_checkpoint", Map.of(
-                            "shard_id", cp.getShardId().toString(),
-                            "primary_term", cp.getPrimaryTerm(),
-                            "generation", cp.getSegmentsGen(),
-                            "version", cp.getSegmentInfosVersion(),
-                            "length", cp.getLength(),
-                            "codec", cp.getCodec(),
-                            "created_timestamp", cp.getCreatedTimeStamp()
-                        ));
+                        fileMetadata.put(
+                            "replication_checkpoint",
+                            Map.of(
+                                "shard_id",
+                                cp.getShardId().toString(),
+                                "primary_term",
+                                cp.getPrimaryTerm(),
+                                "generation",
+                                cp.getSegmentsGen(),
+                                "version",
+                                cp.getSegmentInfosVersion(),
+                                "length",
+                                cp.getLength(),
+                                "codec",
+                                cp.getCodec(),
+                                "created_timestamp",
+                                cp.getCreatedTimeStamp()
+                            )
+                        );
                     }
 
                     fileMetadata.put("generation", segMetadata.getGeneration());
@@ -239,8 +254,10 @@ private Map<String, Object> readTranslogMetadata(String metadataPath) throws IOE
 
         try (DirectoryStream<Path> stream = Files.newDirectoryStream(path, "metadata__*")) {
             for (Path metadataFile : stream) {
-                try (InputStream inputStream = Files.newInputStream(metadataFile);
-                     BytesStreamInput input = new BytesStreamInput(inputStream.readAllBytes())) {
+                try (
+                    InputStream inputStream = Files.newInputStream(metadataFile);
+                    BytesStreamInput input = new BytesStreamInput(inputStream.readAllBytes())
+                ) {
 
                     Map<String, Object> fileMetadata = new HashMap<>();
                     String[] parts = metadataFile.getFileName().toString().split(TranslogTransferMetadata.METADATA_SEPARATOR);
@@ -256,16 +273,23 @@ private Map<String, Object> readTranslogMetadata(String metadataPath) throws IOE
                     long generation = input.readLong();
                     long minTranslogGen = input.readLong();
                     Map<String, String> genToTermMap = input.readMap(StreamInput::readString, StreamInput::readString);
-                    fileMetadata.put("content", Map.of(
-                        "primary_term", primaryTerm,
-                        "generation", generation,
-                        "min_translog_generation", minTranslogGen,
-                        "generation_to_term_mapping", genToTermMap
-                    ));
+                    fileMetadata.put(
+                        "content",
+                        Map.of(
+                            "primary_term",
+                            primaryTerm,
+                            "generation",
+                            generation,
+                            "min_translog_generation",
+                            minTranslogGen,
+                            "generation_to_term_mapping",
+                            genToTermMap
+                        )
+                    );
                     metadata.put(metadataFile.getFileName().toString(), fileMetadata);
                 }
             }
         }
         return metadata;
     }
-}
+}