Skip to content

Migrate sample operator transport version #134020

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 1 commit into from
Closed

Migrate sample operator transport version #134020

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 0 additions & 2 deletions server/src/main/java/org/elasticsearch/TransportVersions.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -334,7 +334,6 @@ static TransportVersion def(int id) {
public static final TransportVersion ESQL_PROFILE_INCLUDE_PLAN = def(9_111_0_00);
public static final TransportVersion MAPPINGS_IN_DATA_STREAMS = def(9_112_0_00);
public static final TransportVersion ESQL_FIXED_INDEX_LIKE_9_1 = def(9_112_0_02);
public static final TransportVersion ESQL_SAMPLE_OPERATOR_STATUS_9_1 = def(9_112_0_03);
public static final TransportVersion INITIAL_ELASTICSEARCH_9_1_1 = def(9_112_0_04);
public static final TransportVersion INITIAL_ELASTICSEARCH_9_1_2 = def(9_112_0_05);
public static final TransportVersion INITIAL_ELASTICSEARCH_9_1_3 = def(9_112_0_06);
Expand All @@ -352,7 +351,6 @@ static TransportVersion def(int id) {
public static final TransportVersion PROJECT_STATE_REGISTRY_ENTRY = def(9_124_0_00);
public static final TransportVersion ML_INFERENCE_LLAMA_ADDED = def(9_125_0_00);
public static final TransportVersion SHARD_WRITE_LOAD_IN_CLUSTER_INFO = def(9_126_0_00);
public static final TransportVersion ESQL_SAMPLE_OPERATOR_STATUS = def(9_127_0_00);
public static final TransportVersion PROJECT_RESERVED_STATE_MOVE_TO_REGISTRY = def(9_147_0_00);
public static final TransportVersion STREAMS_ENDPOINT_PARAM_RESTRICTIONS = def(9_148_0_00);

Expand Down
1 change: 1 addition & 0 deletions server/src/main/resources/transport/definitions/referable/esql_sample_operator_status.csv
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
9127000,9112003
2 changes: 1 addition & 1 deletion server/src/main/resources/transport/upper_bounds/9.1.csv
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
esql_split_on_big_values,9112001
esql_sample_operator_status,9112003
6 changes: 3 additions & 3 deletions .../plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/SampleOperator.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
package org.elasticsearch.compute.operator;

import org.elasticsearch.TransportVersion;
import org.elasticsearch.TransportVersions;
import org.elasticsearch.common.Randomness;
import org.elasticsearch.common.Strings;
import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
Expand Down Expand Up @@ -177,6 +176,8 @@ public record Status(long collectNanos, long emitNanos, int pagesProcessed, long
Status::new
);

private static final TransportVersion ESQL_SAMPLE_OPERATOR_STATUS = TransportVersion.fromName("esql_sample_operator_status");

Status(StreamInput streamInput) throws IOException {
this(
streamInput.readVLong(),
Expand Down Expand Up @@ -248,8 +249,7 @@ public TransportVersion getMinimalSupportedVersion() {

@Override
public boolean supportsVersion(TransportVersion version) {
return version.onOrAfter(TransportVersions.ESQL_SAMPLE_OPERATOR_STATUS)
|| version.isPatchFrom(TransportVersions.ESQL_SAMPLE_OPERATOR_STATUS_9_1);
return version.supports(ESQL_SAMPLE_OPERATOR_STATUS);
}
}
}