Skip to content

Commit 8edfa05

Browse files
authored
Make MigrateToDataStreamClusterStateUpdateRequest a record (#113277)
No need to extend `ClusterStateUpdateRequest` here.
1 parent 8fe7d74 commit 8edfa05

File tree

1 file changed

+6
-10
lines changed

1 file changed

+6
-10
lines changed

server/src/main/java/org/elasticsearch/cluster/metadata/MetadataMigrateToDataStreamService.java

Lines changed: 6 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818
import org.elasticsearch.cluster.AckedClusterStateUpdateTask;
1919
import org.elasticsearch.cluster.ClusterState;
2020
import org.elasticsearch.cluster.ClusterStateUpdateTask;
21-
import org.elasticsearch.cluster.ack.ClusterStateUpdateRequest;
2221
import org.elasticsearch.cluster.metadata.MetadataCreateDataStreamService.CreateDataStreamClusterStateUpdateRequest;
2322
import org.elasticsearch.cluster.routing.allocation.allocator.AllocationActionListener;
2423
import org.elasticsearch.cluster.service.ClusterService;
@@ -40,6 +39,7 @@
4039
import java.io.IOException;
4140
import java.util.ArrayList;
4241
import java.util.List;
42+
import java.util.Objects;
4343
import java.util.concurrent.atomic.AtomicReference;
4444
import java.util.function.Function;
4545

@@ -283,15 +283,11 @@ static void validateBackingIndices(ClusterState currentState, String dataStreamN
283283
}
284284
}
285285

286-
@SuppressWarnings("rawtypes")
287-
public static final class MigrateToDataStreamClusterStateUpdateRequest extends ClusterStateUpdateRequest {
288-
289-
private final String aliasName;
290-
291-
public MigrateToDataStreamClusterStateUpdateRequest(String aliasName, TimeValue masterNodeTimeout, TimeValue timeout) {
292-
this.aliasName = aliasName;
293-
masterNodeTimeout(masterNodeTimeout);
294-
ackTimeout(timeout);
286+
public record MigrateToDataStreamClusterStateUpdateRequest(String aliasName, TimeValue masterNodeTimeout, TimeValue ackTimeout) {
287+
public MigrateToDataStreamClusterStateUpdateRequest {
288+
Objects.requireNonNull(aliasName);
289+
Objects.requireNonNull(masterNodeTimeout);
290+
Objects.requireNonNull(ackTimeout);
295291
}
296292
}
297293

0 commit comments

Comments
 (0)