Added a override function for finalizeSnapshot

Signed-off-by: nandan <[email protected]>
nandnkum · Sep 5, 2024 · bae9870 · bae9870
1 parent 5310ffc
commit bae9870
Showing 1 changed file with 12 additions and 4 deletions.
diff --git a/src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepository.kt b/src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepository.kt
@@ -74,6 +74,7 @@ import java.util.UUID
 import java.util.function.Consumer
 import java.util.function.Function
 import kotlin.collections.ArrayList
+import org.opensearch.common.Priority;
 
 const val REMOTE_REPOSITORY_PREFIX = "replication-remote-repo-"
 const val REMOTE_REPOSITORY_TYPE = "replication-remote-repository"
@@ -116,12 +117,19 @@ class RemoteClusterRepository(private val repositoryMetadata: RepositoryMetadata
     }
 
     override fun finalizeSnapshot(shardGenerations: ShardGenerations?, repositoryStateId: Long, clusterMetadata: Metadata?,
-                                  snapshotInfo: SnapshotInfo?, repositoryMetaVersion: Version?,
-                                  stateTransformer: Function<ClusterState, ClusterState>?,
-                                  listener: ActionListener<RepositoryData>?) {
-        throw UnsupportedOperationException("Operation not permitted")
+    snapshotInfo: SnapshotInfo?, repositoryMetaVersion: Version?,
+    stateTransformer: Function<ClusterState, ClusterState>?,
+    listener: ActionListener<RepositoryData>?) {
+    throw UnsupportedOperationException("Operation not permitted")
     }
 
+    override fun finalizeSnapshot(shardGenerations: ShardGenerations?, repositoryStateId: Long, clusterMetadata: Metadata?,
+    snapshotInfo: SnapshotInfo?, repositoryMetaVersion: Version?,
+    stateTransformer: Function<ClusterState, ClusterState>?, repositoryUpdatePriority: Priority,
+    listener: ActionListener<RepositoryData>?) {
+    throw UnsupportedOperationException("Operation not permitted")
+    }
+
     override fun deleteSnapshots(snapshotIds: MutableCollection<SnapshotId>?, repositoryStateId: Long,
                                  repositoryMetaVersion: Version?, listener: ActionListener<RepositoryData>?) {
         throw UnsupportedOperationException("Operation not permitted")