naming

Author: lkts

server/src/main/java/org/elasticsearch/cluster/routing/RecoverySource.java

@@ -32,7 +32,7 @@
  * - {@link PeerRecoverySource} recovery from a primary on another node
  * - {@link SnapshotRecoverySource} recovery from a snapshot
  * - {@link LocalShardsRecoverySource} recovery from other shards of another index on the same node
- * - {@link SplitTargetRecoverySource} recovery of a shard that is created as a result of a resharding split
+ * - {@link ReshardSplitTargetRecoverySource} recovery of a shard that is created as a result of a resharding split
  */
 public abstract class RecoverySource implements Writeable, ToXContentObject {
 
@@ -61,7 +61,7 @@ public static RecoverySource readFrom(StreamInput in) throws IOException {
             case PEER -> PeerRecoverySource.INSTANCE;
             case SNAPSHOT -> new SnapshotRecoverySource(in);
             case LOCAL_SHARDS -> LocalShardsRecoverySource.INSTANCE;
-            case RESHARD_SPLIT_TARGET -> new SplitTargetRecoverySource(in);
+            case RESHARD_SPLIT_TARGET -> new ReshardSplitTargetRecoverySource(in);
         };
     }
 
@@ -330,14 +330,14 @@ public boolean expectEmptyRetentionLeases() {
      * Recovery of a shard that is created as a result of a resharding split.
      * Not to be confused with _split API.
      */
-    public static class SplitTargetRecoverySource extends RecoverySource {
+    public static class ReshardSplitTargetRecoverySource extends RecoverySource {
         private final ShardId sourceShardId;
 
-        public SplitTargetRecoverySource(ShardId sourceShardId) {
+        public ReshardSplitTargetRecoverySource(ShardId sourceShardId) {
             this.sourceShardId = sourceShardId;
         }
 
-        SplitTargetRecoverySource(StreamInput in) throws IOException {
+        ReshardSplitTargetRecoverySource(StreamInput in) throws IOException {
             sourceShardId = new ShardId(in);
         }
 

server/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java

@@ -703,7 +703,7 @@ private void createShard(ShardRouting shardRouting, ClusterState state) {
                     return;
                 }
             } else if (shardRouting.recoverySource().getType() == Type.RESHARD_SPLIT_TARGET) {
-                ShardId sourceShardId = ((RecoverySource.SplitTargetRecoverySource) shardRouting.recoverySource()).getSourceShardId();
+                ShardId sourceShardId = ((RecoverySource.ReshardSplitTargetRecoverySource) shardRouting.recoverySource()).getSourceShardId();
                 sourceNode = findSourceNodeForSplitTargetRecovery(state.routingTable(project.id()), state.nodes(), sourceShardId);
                 if (sourceNode == null) {
                     logger.trace("ignoring initializing reshard target shard {} - no source node can be found.", shardId);

test/framework/src/main/java/org/elasticsearch/cluster/routing/TestShardRouting.java

@@ -276,7 +276,7 @@ public static RecoverySource buildRecoverySource() {
                 IndexVersion.current(),
                 new IndexId("some_index", randomUUID())
             ),
-            new RecoverySource.SplitTargetRecoverySource(new ShardId("some_index", randomUUID(), randomIntBetween(0, 1000)))
+            new RecoverySource.ReshardSplitTargetRecoverySource(new ShardId("some_index", randomUUID(), randomIntBetween(0, 1000)))
         );
     }
 }