diff --git a/server/src/main/java/org/opensearch/snapshots/RemoteStoreRestoreService.java b/server/src/main/java/org/opensearch/snapshots/RemoteStoreRestoreService.java index de3c08eaf661a..088bf956064fa 100644 --- a/server/src/main/java/org/opensearch/snapshots/RemoteStoreRestoreService.java +++ b/server/src/main/java/org/opensearch/snapshots/RemoteStoreRestoreService.java @@ -13,10 +13,8 @@ import org.opensearch.Version; import org.opensearch.action.ActionListener; import org.opensearch.action.admin.cluster.remotestore.restore.RestoreRemoteStoreRequest; -import org.opensearch.cluster.ClusterChangedEvent; -import org.opensearch.cluster.ClusterState; -import org.opensearch.cluster.ClusterStateApplier; -import org.opensearch.cluster.ClusterStateUpdateTask; +import org.opensearch.action.admin.cluster.snapshots.restore.RestoreSnapshotRequest; +import org.opensearch.cluster.*; import org.opensearch.cluster.block.ClusterBlocks; import org.opensearch.cluster.metadata.IndexMetadata; import org.opensearch.cluster.metadata.Metadata; @@ -35,6 +33,7 @@ import org.opensearch.common.settings.Settings; import org.opensearch.common.unit.TimeValue; import org.opensearch.core.index.shard.ShardId; +import org.opensearch.index.shard.IndexShard; import org.opensearch.indices.ShardLimitValidator; import org.opensearch.indices.replication.common.ReplicationType; import org.opensearch.repositories.IndexId; @@ -57,6 +56,11 @@ import static org.opensearch.cluster.metadata.IndexMetadata.SETTING_REPLICATION_TYPE; import static org.opensearch.cluster.metadata.IndexMetadata.SETTING_REMOTE_STORE_ENABLED; +/** + * Service responsible for restoring indices from remote + * + * @opensearch.internal + */ public class RemoteStoreRestoreService implements ClusterStateApplier { private static final Logger logger = LogManager.getLogger(RemoteStoreRestoreService.class);