Spotless fixes

Signed-off-by: Sachin Kale <kalsac@amazon.com>
opensearch-project · Jul 20, 2023 · b2485fc · b2485fc
1 parent 93dbc51
commit b2485fc
Show file tree

Hide file tree

Showing 4 changed files with 19 additions and 4 deletions.
diff --git a/...va/org/opensearch/action/admin/cluster/remotestore/restore/RestoreRemoteStoreRequest.java b/...va/org/opensearch/action/admin/cluster/remotestore/restore/RestoreRemoteStoreRequest.java
@@ -190,7 +190,9 @@ public boolean equals(Object o) {
         if (this == o) return true;
         if (o == null || getClass() != o.getClass()) return false;
         RestoreRemoteStoreRequest that = (RestoreRemoteStoreRequest) o;
-        return waitForCompletion == that.waitForCompletion && restoreAllShards == that.restoreAllShards && Arrays.equals(indices, that.indices);
+        return waitForCompletion == that.waitForCompletion
+            && restoreAllShards == that.restoreAllShards
+            && Arrays.equals(indices, that.indices);
     }
 
     @Override

diff --git a/server/src/main/java/org/opensearch/cluster/routing/IndexRoutingTable.java b/server/src/main/java/org/opensearch/cluster/routing/IndexRoutingTable.java
@@ -450,7 +450,11 @@ public Builder initializeAsRestore(IndexMetadata indexMetadata, SnapshotRecovery
         /**
          * Initializes an existing index, to be restored from remote store
          */
-        public Builder initializeAsRemoteStoreRestore(IndexMetadata indexMetadata, RemoteStoreRecoverySource recoverySource, Map<ShardId, ShardRouting> activeShards) {
+        public Builder initializeAsRemoteStoreRestore(
+            IndexMetadata indexMetadata,
+            RemoteStoreRecoverySource recoverySource,
+            Map<ShardId, ShardRouting> activeShards
+        ) {
             final UnassignedInfo unassignedInfo = new UnassignedInfo(
                 UnassignedInfo.Reason.EXISTING_INDEX_RESTORED,
                 "restore_source[remote_store]"

diff --git a/server/src/main/java/org/opensearch/cluster/routing/RoutingTable.java b/server/src/main/java/org/opensearch/cluster/routing/RoutingTable.java
@@ -562,7 +562,11 @@ public Builder addAsFromOpenToClose(IndexMetadata indexMetadata) {
             return add(indexRoutingBuilder);
         }
 
-        public Builder addAsRemoteStoreRestore(IndexMetadata indexMetadata, RemoteStoreRecoverySource recoverySource, Map<ShardId, ShardRouting> activeShards) {
+        public Builder addAsRemoteStoreRestore(
+            IndexMetadata indexMetadata,
+            RemoteStoreRecoverySource recoverySource,
+            Map<ShardId, ShardRouting> activeShards
+        ) {
             IndexRoutingTable.Builder indexRoutingBuilder = new IndexRoutingTable.Builder(indexMetadata.getIndex())
                 .initializeAsRemoteStoreRestore(indexMetadata, recoverySource, activeShards);
             add(indexRoutingBuilder);

diff --git a/server/src/main/java/org/opensearch/snapshots/RestoreService.java b/server/src/main/java/org/opensearch/snapshots/RestoreService.java
@@ -260,7 +260,12 @@ public ClusterState execute(ClusterState currentState) {
                             updatedIndexMetadata.getCreationVersion(),
                             indexId
                         );
-                        Map<ShardId, ShardRouting> activeShards = currentState.routingTable().index(index).randomAllActiveShardsIt().getShardRoutings().stream().collect(Collectors.toMap(ShardRouting::shardId, Function.identity()));
+                        Map<ShardId, ShardRouting> activeShards = currentState.routingTable()
+                            .index(index)
+                            .randomAllActiveShardsIt()
+                            .getShardRoutings()
+                            .stream()
+                            .collect(Collectors.toMap(ShardRouting::shardId, Function.identity()));
                         rtBuilder.addAsRemoteStoreRestore(updatedIndexMetadata, recoverySource, activeShards);
                         blocks.updateBlocks(updatedIndexMetadata);
                         mdBuilder.put(updatedIndexMetadata, true);