Skip to content

Commit f4f3ffb

Browse files
committed
Support TransportVersions for ViewMetadata serialization
1 parent 23aa5ea commit f4f3ffb

File tree

4 files changed

+8
-4
lines changed

4 files changed

+8
-4
lines changed
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
9177000
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
roles_security_stats,9176000
1+
esql_views,9177000

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/EsqlPlugin.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,7 @@
9494
import org.elasticsearch.xpack.esql.view.TransportGetViewAction;
9595
import org.elasticsearch.xpack.esql.view.TransportListViewsAction;
9696
import org.elasticsearch.xpack.esql.view.TransportPutViewAction;
97+
import org.elasticsearch.xpack.esql.view.ViewMetadata;
9798
import org.elasticsearch.xpack.esql.view.ViewService;
9899

99100
import java.lang.invoke.MethodHandles;
@@ -376,6 +377,7 @@ public List<NamedWriteableRegistry.Entry> getNamedWriteables() {
376377

377378
entries.add(ExpressionQueryBuilder.ENTRY);
378379
entries.add(PlanStreamWrapperQueryBuilder.ENTRY);
380+
entries.add(ViewMetadata.ENTRY);
379381

380382
entries.addAll(ExpressionWritables.getNamedWriteables());
381383
entries.addAll(PlanWritables.getNamedWriteables());

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/view/ViewMetadata.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,9 @@
77
package org.elasticsearch.xpack.esql.view;
88

99
import org.elasticsearch.TransportVersion;
10-
import org.elasticsearch.TransportVersions;
1110
import org.elasticsearch.cluster.AbstractNamedDiffable;
1211
import org.elasticsearch.cluster.metadata.Metadata;
12+
import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
1313
import org.elasticsearch.common.io.stream.StreamInput;
1414
import org.elasticsearch.common.io.stream.StreamOutput;
1515
import org.elasticsearch.common.xcontent.ChunkedToXContentHelper;
@@ -30,6 +30,8 @@
3030
*/
3131
public final class ViewMetadata extends AbstractNamedDiffable<Metadata.ClusterCustom> implements Metadata.ClusterCustom {
3232
public static final String TYPE = "esql_view";
33+
public static final NamedWriteableRegistry.Entry ENTRY = new NamedWriteableRegistry.Entry(ViewMetadata.class, TYPE, ViewMetadata::new);
34+
private static final TransportVersion ESQL_VIEWS = TransportVersion.fromName("esql_views");
3335

3436
static final ParseField VIEWS = new ParseField("views");
3537

@@ -65,8 +67,7 @@ public Map<String, View> views() {
6567

6668
@Override
6769
public TransportVersion getMinimalSupportedVersion() {
68-
// TODO set this to something sane, perhaps once the new TransportVersion mechanism is in place
69-
return TransportVersions.INDEX_SOURCE;
70+
return ESQL_VIEWS;
7071
}
7172

7273
@Override

0 commit comments

Comments
 (0)