Skip to content

Commit be4f845

Browse files
authored
Remove deprecated Metadata.Builder#putProjectCustom (#130862)
Replaces the deprecated method with appropriate substitute.
1 parent 2b715f5 commit be4f845

File tree

2 files changed

+15
-16
lines changed

2 files changed

+15
-16
lines changed

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

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1230,6 +1230,7 @@ public static Metadata readFrom(StreamInput in) throws IOException {
12301230
}
12311231

12321232
private static void readBwcCustoms(StreamInput in, Builder builder) throws IOException {
1233+
final ProjectMetadata.Builder projectBuilder = builder.getProject(ProjectId.DEFAULT);
12331234
final Set<String> clusterScopedNames = in.namedWriteableRegistry().getReaders(ClusterCustom.class).keySet();
12341235
final Set<String> projectScopedNames = in.namedWriteableRegistry().getReaders(ProjectCustom.class).keySet();
12351236
final int count = in.readVInt();
@@ -1245,9 +1246,9 @@ private static void readBwcCustoms(StreamInput in, Builder builder) throws IOExc
12451246
if (custom instanceof PersistentTasksCustomMetadata persistentTasksCustomMetadata) {
12461247
final var tuple = persistentTasksCustomMetadata.split();
12471248
builder.putCustom(tuple.v1().getWriteableName(), tuple.v1());
1248-
builder.putProjectCustom(tuple.v2().getWriteableName(), tuple.v2());
1249+
projectBuilder.putCustom(tuple.v2().getWriteableName(), tuple.v2());
12491250
} else {
1250-
builder.putProjectCustom(custom.getWriteableName(), custom);
1251+
projectBuilder.putCustom(custom.getWriteableName(), custom);
12511252
}
12521253
} else {
12531254
throw new IllegalArgumentException("Unknown custom name [" + name + "]");
@@ -1552,7 +1553,8 @@ public Builder putCustom(String type, ClusterCustom custom) {
15521553

15531554
@Deprecated(forRemoval = true)
15541555
public Builder putCustom(String type, ProjectCustom custom) {
1555-
return putProjectCustom(type, custom);
1556+
getSingleProject().putCustom(type, Objects.requireNonNull(custom, type));
1557+
return this;
15561558
}
15571559

15581560
public ClusterCustom getCustom(String type) {
@@ -1575,12 +1577,6 @@ public Builder customs(Map<String, ClusterCustom> clusterCustoms) {
15751577
return this;
15761578
}
15771579

1578-
@Deprecated(forRemoval = true)
1579-
public Builder putProjectCustom(String type, ProjectCustom custom) {
1580-
getSingleProject().putCustom(type, Objects.requireNonNull(custom, type));
1581-
return this;
1582-
}
1583-
15841580
@Deprecated(forRemoval = true)
15851581
public Builder projectCustoms(Map<String, ProjectCustom> projectCustoms) {
15861582
projectCustoms.forEach((key, value) -> Objects.requireNonNull(value, key));

server/src/test/java/org/elasticsearch/cluster/metadata/MetadataPersistentTasksTests.java

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -306,13 +306,16 @@ private Tuple<Metadata, Metadata> randomMetadataAndUpdate() {
306306
ClusterPersistentTasksCustomMetadata::new
307307
)
308308
)
309-
.putProjectCustom(
310-
PersistentTasksCustomMetadata.TYPE,
311-
mutatePersistentTasks(
312-
PersistentTasksCustomMetadata.get(before.getProject(Metadata.DEFAULT_PROJECT_ID)),
313-
MetadataPersistentTasksTests::oneProjectPersistentTask,
314-
PersistentTasksCustomMetadata::new
315-
)
309+
.put(
310+
ProjectMetadata.builder(before.getProject(Metadata.DEFAULT_PROJECT_ID))
311+
.putCustom(
312+
PersistentTasksCustomMetadata.TYPE,
313+
mutatePersistentTasks(
314+
PersistentTasksCustomMetadata.get(before.getProject(Metadata.DEFAULT_PROJECT_ID)),
315+
MetadataPersistentTasksTests::oneProjectPersistentTask,
316+
PersistentTasksCustomMetadata::new
317+
)
318+
)
316319
)
317320
.build();
318321
return new Tuple<>(before, after);

0 commit comments

Comments
 (0)