github-mirrors/elasticsearch
1
0
Fork 0
mirror of https://github.com/elastic/elasticsearch.git synced 2025-06-28 01:22:26 -04:00
Code Issues Projects Releases Packages Wiki Activity

TransportVersion for backporting ES|QL sample (#129831)

Browse source
This commit is contained in:
Jan Kuipers 2025-06-23 15:28:14 +02:00 • committed by GitHub
parent e031b3e8d3
commit a3dac7434b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 9 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

1
server/src/main/java/org/elasticsearch/TransportVersions.java
View file

@ -201,6 +201,7 @@ public class TransportVersions {
public static final TransportVersion ML_INFERENCE_CUSTOM_SERVICE_EMBEDDING_BATCH_SIZE_8_19 = def(8_841_0_53); public static final TransportVersion ML_INFERENCE_CUSTOM_SERVICE_EMBEDDING_BATCH_SIZE_8_19 = def(8_841_0_53);
public static final TransportVersion STREAMS_LOGS_SUPPORT_8_19 = def(8_841_0_54); public static final TransportVersion STREAMS_LOGS_SUPPORT_8_19 = def(8_841_0_54);
public static final TransportVersion ML_INFERENCE_CUSTOM_SERVICE_INPUT_TYPE_8_19 = def(8_841_0_55); public static final TransportVersion ML_INFERENCE_CUSTOM_SERVICE_INPUT_TYPE_8_19 = def(8_841_0_55);
public static final TransportVersion RANDOM_SAMPLER_QUERY_BUILDER_8_19 = def(8_841_0_56);
public static final TransportVersion V_9_0_0 = def(9_000_0_09); public static final TransportVersion V_9_0_0 = def(9_000_0_09);
public static final TransportVersion INITIAL_ELASTICSEARCH_9_0_1 = def(9_000_0_10); public static final TransportVersion INITIAL_ELASTICSEARCH_9_0_1 = def(9_000_0_10);

12
server/src/main/java/org/elasticsearch/search/aggregations/bucket/sampler/random/RandomSamplingQueryBuilder.java
View file

@ -139,11 +139,15 @@ public class RandomSamplingQueryBuilder extends AbstractQueryBuilder<RandomSampl
return NAME; return NAME;
} }
/** @Override
* The minimal version of the recipient this object can be sent to public boolean supportsVersion(TransportVersion version) {
*/ return version.onOrAfter(TransportVersions.RANDOM_SAMPLER_QUERY_BUILDER)
|| version.isPatchFrom(TransportVersions.RANDOM_SAMPLER_QUERY_BUILDER_8_19);
}
@Override @Override
public TransportVersion getMinimalSupportedVersion() { public TransportVersion getMinimalSupportedVersion() {
return TransportVersions.RANDOM_SAMPLER_QUERY_BUILDER; assert false : "must not be called when overriding supportsVersion";
throw new UnsupportedOperationException("must not be called when overriding supportsVersion");
} }
} }