Applied spotless correction

Author: Aditi Goyal

server/src/main/java/org/opensearch/index/shard/IndexShard.java

@@ -4085,7 +4085,8 @@ private EngineConfig newEngineConfig(LongSupplier globalCheckpointSupplier) thro
                 this,
                 this.checkpointPublisher,
                 remoteStoreStatsTrackerFactory.getRemoteSegmentTransferTracker(shardId()),
-                remoteStoreSettings);
+                remoteStoreSettings
+            );
 
             internalRefreshListener.add(
                 new RemoteStoreRefreshListener(

server/src/main/java/org/opensearch/index/shard/RemoteStoreRefreshListener.java

@@ -9,49 +9,30 @@
 package org.opensearch.index.shard;
 
 import org.apache.logging.log4j.Logger;
-import org.apache.logging.log4j.message.ParameterizedMessage;
 import org.apache.lucene.codecs.CodecUtil;
-import org.apache.lucene.index.CorruptIndexException;
 import org.apache.lucene.index.SegmentInfos;
 import org.apache.lucene.store.Directory;
 import org.apache.lucene.store.FilterDirectory;
 import org.apache.lucene.store.IOContext;
 import org.apache.lucene.store.IndexInput;
-import org.opensearch.action.LatchedActionListener;
 import org.opensearch.action.bulk.BackoffPolicy;
-import org.opensearch.action.support.GroupedActionListener;
 import org.opensearch.cluster.routing.RecoverySource;
 import org.opensearch.common.concurrent.GatedCloseable;
 import org.opensearch.common.logging.Loggers;
 import org.opensearch.common.unit.TimeValue;
-import org.opensearch.common.util.UploadListener;
-import org.opensearch.core.action.ActionListener;
-import org.opensearch.index.engine.EngineException;
-import org.opensearch.index.engine.InternalEngine;
 import org.opensearch.index.remote.RemoteSegmentTransferTracker;
-import org.opensearch.index.seqno.SequenceNumbers;
-import org.opensearch.index.store.CompositeDirectory;
 import org.opensearch.index.store.RemoteSegmentStoreDirectory;
 import org.opensearch.index.store.remote.metadata.RemoteSegmentMetadata;
-import org.opensearch.index.translog.Translog;
 import org.opensearch.indices.RemoteStoreSettings;
-import org.opensearch.indices.replication.checkpoint.ReplicationCheckpoint;
 import org.opensearch.indices.replication.checkpoint.SegmentReplicationCheckpointPublisher;
 import org.opensearch.threadpool.ThreadPool;
 
 import java.io.IOException;
 import java.util.Collection;
 import java.util.HashMap;
 import java.util.Iterator;
-import java.util.Locale;
 import java.util.Map;
 import java.util.Set;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.stream.Collectors;
-
-import static org.opensearch.index.seqno.SequenceNumbers.LOCAL_CHECKPOINT_KEY;
 
 /**
  * RefreshListener implementation to upload newly created segment files to the remote store
@@ -120,8 +101,7 @@ public RemoteStoreRefreshListener(
         }
         // initializing primary term with the primary term of latest metadata in remote store.
         // if no metadata is present, this value will be initialized with -1.
-        this.primaryTerm = remoteSegmentMetadata != null ? remoteSegmentMetadata.getPrimaryTerm() :
-            INVALID_PRIMARY_TERM;
+        this.primaryTerm = remoteSegmentMetadata != null ? remoteSegmentMetadata.getPrimaryTerm() : INVALID_PRIMARY_TERM;
         this.segmentTracker = segmentTracker;
         resetBackOffDelayIterator();
         this.checkpointPublisher = checkpointPublisher;
@@ -233,7 +213,7 @@ protected String getRetryThreadPoolName() {
         return ThreadPool.Names.REMOTE_REFRESH_RETRY;
     }
 
-    //todo: create a common class
+    // todo: create a common class
     private boolean isRefreshAfterCommit() throws IOException {
         String lastCommittedLocalSegmentFileName = SegmentInfos.getLastCommitSegmentsFileName(storeDirectory);
         return (lastCommittedLocalSegmentFileName != null
@@ -253,7 +233,7 @@ private boolean isRefreshAfterCommitSafe() {
         return false;
     }
 
-    //todo
+    // todo
     boolean isLowPriorityUpload() {
         return isLocalOrSnapshotRecoveryOrSeeding();
     }
@@ -264,7 +244,7 @@ boolean isLowPriorityUpload() {
      * @param file that needs to be uploaded.
      * @return true if the upload has to be skipped for the file.
      */
-    //todo: create a common class
+    // todo: create a common class
     private boolean skipUpload(String file) {
         try {
             // Exclude files that are already uploaded and the exclude files to come up with the list of files to be uploaded.
@@ -295,7 +275,7 @@ private String getChecksumOfLocalFile(String file) throws IOException {
      *
      * @return updated map of local segment files and filesize
      */
-    //todo: create a common class
+    // todo: create a common class
     private Map<String, Long> updateLocalSizeMapAndTracker(Collection<String> segmentFiles) {
         return segmentTracker.updateLatestLocalFileNameLengthMap(segmentFiles, storeDirectory::fileLength);
     }
@@ -305,7 +285,7 @@ private Map<String, Long> updateLocalSizeMapAndTracker(Collection<String> segmen
      * returned value of this method for scheduling retries in syncSegments method.
      * @return true iff the shard is a started with primary mode true or it is local or snapshot recovery.
      */
-    //todo: create a common class
+    // todo: create a common class
     private boolean isReadyForUpload() {
         boolean isReady = indexShard.isStartedPrimary() || isLocalOrSnapshotRecoveryOrSeeding();
 
@@ -329,7 +309,7 @@ private boolean isReadyForUpload() {
         return isReady;
     }
 
-    //todo: create a common class
+    // todo: create a common class
     boolean isLocalOrSnapshotRecoveryOrSeeding() {
         // In this case when the primary mode is false, we need to upload segments to Remote Store
         // This is required in case of remote migration seeding/snapshots/shrink/ split/clone where we need to durable persist

server/src/main/java/org/opensearch/index/shard/RemoteUploaderService.java

@@ -30,8 +30,6 @@
 import org.opensearch.index.engine.InternalEngine;
 import org.opensearch.index.remote.RemoteSegmentTransferTracker;
 import org.opensearch.index.seqno.SequenceNumbers;
-import static org.opensearch.index.seqno.SequenceNumbers.LOCAL_CHECKPOINT_KEY;
-import static org.opensearch.index.shard.RemoteStoreRefreshListener.EXCLUDE_FILES;
 import org.opensearch.index.store.CompositeDirectory;
 import org.opensearch.index.store.RemoteSegmentStoreDirectory;
 import org.opensearch.index.store.remote.metadata.RemoteSegmentMetadata;
@@ -51,6 +49,8 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.stream.Collectors;
 
+import static org.opensearch.index.seqno.SequenceNumbers.LOCAL_CHECKPOINT_KEY;
+import static org.opensearch.index.shard.RemoteStoreRefreshListener.EXCLUDE_FILES;
 
 public class RemoteUploaderService {
 
@@ -411,8 +411,8 @@ boolean isLocalOrSnapshotRecoveryOrSeeding() {
         return (indexShard.state() == IndexShardState.RECOVERING && indexShard.shardRouting.primary())
             && indexShard.recoveryState() != null
             && (indexShard.recoveryState().getRecoverySource().getType() == RecoverySource.Type.LOCAL_SHARDS
-            || indexShard.recoveryState().getRecoverySource().getType() == RecoverySource.Type.SNAPSHOT
-            || indexShard.shouldSeedRemoteStore());
+                || indexShard.recoveryState().getRecoverySource().getType() == RecoverySource.Type.SNAPSHOT
+                || indexShard.shouldSeedRemoteStore());
     }
 
     private String getChecksumOfLocalFile(String file) throws IOException {