diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/ElasticsearchAsyncClient.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/ElasticsearchAsyncClient.java
index 2d5fe918ef..a6bbc122f8 100644
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/ElasticsearchAsyncClient.java
+++ b/java-client/src/main/java/co/elastic/clients/elasticsearch/ElasticsearchAsyncClient.java
@@ -383,10 +383,11 @@ public ElasticsearchXpackAsyncClient xpack() {
// ----- Endpoint: bulk
/**
- * Bulk index or delete documents. Perform multiple index,
- * create, delete, and update actions in
- * a single request. This reduces overhead and can greatly increase indexing
- * speed.
+ * Bulk index or delete documents.
+ *
+ * Perform multiple index, create,
+ * delete, and update actions in a single request.
+ * This reduces overhead and can greatly increase indexing speed.
*
* If the Elasticsearch security features are enabled, you must have the
* following index privileges for the target data stream, index, or index alias:
@@ -483,6 +484,8 @@ public ElasticsearchXpackAsyncClient xpack() {
* Search::Elasticsearch::Client::5_0::Scroll
*
elasticsearch.helpers.*client.helpers.*co.elastic.clients.elasticsearch._helpers.bulk.BulkIngesterBulkAllObservableElasticsearch::Helpers::BulkHelperindex,
- * create, delete, and update actions in
- * a single request. This reduces overhead and can greatly increase indexing
- * speed.
+ * Bulk index or delete documents.
+ *
+ * Perform multiple index, create,
+ * delete, and update actions in a single request.
+ * This reduces overhead and can greatly increase indexing speed.
*
* If the Elasticsearch security features are enabled, you must have the
* following index privileges for the target data stream, index, or index alias:
@@ -662,6 +666,8 @@ public CompletableFuture
+ * Perform multiple
* If the Elasticsearch security features are enabled, you must have the
* following index privileges for the target data stream, index, or index alias:
@@ -841,6 +848,8 @@ public final CompletableFuture
+ * Clear the search context and results for a scrolling search.
*
* @see Documentation
@@ -936,8 +946,9 @@ public CompletableFuture
+ * Clear the search context and results for a scrolling search.
*
* @param fn
* a function that initializes a builder to create the
@@ -953,8 +964,9 @@ public final CompletableFuture
+ * Clear the search context and results for a scrolling search.
*
* @see Documentation
@@ -969,12 +981,14 @@ public CompletableFuture
+ * A point in time must be opened explicitly before being used in search
+ * requests. The
+ * A point in time must be opened explicitly before being used in search
+ * requests. The
+ * Get the number of documents matching a query.
*
* The query can be provided either by using a simple query string as a
* parameter, or by defining Query DSL within the request body. The query is
@@ -1039,7 +1057,9 @@ public CompletableFuture
+ * Get the number of documents matching a query.
*
* The query can be provided either by using a simple query string as a
* parameter, or by defining Query DSL within the request body. The query is
@@ -1067,7 +1087,9 @@ public final CompletableFuture
+ * Get the number of documents matching a query.
*
* The query can be provided either by using a simple query string as a
* parameter, or by defining Query DSL within the request body. The query is
@@ -1839,8 +1861,9 @@ public final CompletableFuture
+ * Deletes a stored script or search template.
*
* @see Documentation
@@ -1855,8 +1878,9 @@ public CompletableFuture
+ * Deletes a stored script or search template.
*
* @param fn
* a function that initializes a builder to create the
@@ -2002,9 +2026,10 @@ public final CompletableFuture
+ * Get information about why a specific document matches, or doesn't match, a
+ * query. It computes a score explanation for a query and a specific document.
*
* @see Documentation
@@ -2022,9 +2047,10 @@ public
+ * Get information about why a specific document matches, or doesn't match, a
+ * query. It computes a score explanation for a query and a specific document.
*
* @param fn
* a function that initializes a builder to create the
@@ -2061,9 +2087,10 @@ public final CompletableFuture
+ * Get information about why a specific document matches, or doesn't match, a
+ * query. It computes a score explanation for a query and a specific document.
*
* @see Documentation
@@ -2081,9 +2108,10 @@ public
+ * Get information about why a specific document matches, or doesn't match, a
+ * query. It computes a score explanation for a query and a specific document.
*
* @param fn
* a function that initializes a builder to create the
@@ -2541,8 +2569,9 @@ public final
+ * Retrieves a stored script or search template.
*
* @see Documentation
@@ -2557,8 +2586,9 @@ public CompletableFuture
+ * Retrieves a stored script or search template.
*
* @param fn
* a function that initializes a builder to create the
@@ -2761,9 +2791,10 @@ public final
+ * Get a report with the health status of an Elasticsearch cluster. The report
+ * contains a list of indicators that compose Elasticsearch functionality.
*
* Each indicator has a health status of: green, unknown, yellow or red. The
* indicator will provide an explanation and metadata describing the reason for
@@ -2803,9 +2834,10 @@ public CompletableFuture
+ * Get a report with the health status of an Elasticsearch cluster. The report
+ * contains a list of indicators that compose Elasticsearch functionality.
*
* Each indicator has a health status of: green, unknown, yellow or red. The
* indicator will provide an explanation and metadata describing the reason for
@@ -2846,9 +2878,10 @@ public final CompletableFuture
+ * Get a report with the health status of an Elasticsearch cluster. The report
+ * contains a list of indicators that compose Elasticsearch functionality.
*
* Each indicator has a health status of: green, unknown, yellow or red. The
* indicator will provide an explanation and metadata describing the reason for
@@ -3069,15 +3102,21 @@ public CompletableFuture
+ * In this example, the operation will succeed since the supplied version of 2
+ * is higher than the current document version of 1. If the document was already
+ * updated and its version was set to 2 or higher, the indexing command will
+ * fail and result in a conflict (409 HTTP status code).
+ *
+ * A nice side effect is that there is no need to maintain strict ordering of
+ * async indexing operations run as a result of changes to a source database, as
+ * long as version numbers from the source database are used. Even the simple
+ * case of updating the Elasticsearch index using data from a database is
+ * simplified if external versioning is used, as only the latest version will be
+ * used if the index operations arrive out of order.
+ *
* @see Documentation
* on elastic.co
@@ -3272,15 +3311,21 @@ public
+ * In this example, the operation will succeed since the supplied version of 2
+ * is higher than the current document version of 1. If the document was already
+ * updated and its version was set to 2 or higher, the indexing command will
+ * fail and result in a conflict (409 HTTP status code).
+ *
+ * A nice side effect is that there is no need to maintain strict ordering of
+ * async indexing operations run as a result of changes to a source database, as
+ * long as version numbers from the source database are used. Even the simple
+ * case of updating the Elasticsearch index using data from a database is
+ * simplified if external versioning is used, as only the latest version will be
+ * used if the index operations arrive out of order.
+ *
* @param fn
* a function that initializes a builder to create the
* {@link IndexRequest}
@@ -3297,9 +3342,11 @@ public final
+ * Get basic build, version, and cluster information. ::: In Serverless, this
+ * API is retained for backward compatibility only. Some response fields, such
+ * as the version number, should be ignored.
*
* @see Documentation
@@ -4048,7 +4095,9 @@ public final CompletableFuture
+ * Get information about whether the cluster is running.
*
* @see Documentation
@@ -4061,8 +4110,9 @@ public CompletableFuture
+ * Creates or updates a stored script or search template.
*
* @see Documentation
@@ -4077,8 +4127,9 @@ public CompletableFuture
+ * Creates or updates a stored script or search template.
*
* @param fn
* a function that initializes a builder to create the
@@ -4165,9 +4216,13 @@ public final CompletableFuture
- * If reindexing from a remote cluster, you must explicitly allow the remote
- * host in the
* The
- * If reindexing from a remote cluster, you must explicitly allow the remote
- * host in the
* The
* If the Elasticsearch security features are enabled, you must have the
* following index privileges for the target data stream, index, or alias:
@@ -6301,10 +6361,11 @@ public CompletableFuture
+ * Updates documents that match the specified query. If no query is specified,
+ * performs an update on every document in the data stream or index without
+ * modifying the source, which is useful for picking up mapping changes.
*
* If the Elasticsearch security features are enabled, you must have the
* following index privileges for the target data stream, index, or alias:
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/ElasticsearchClient.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/ElasticsearchClient.java
index fa0bc36ac5..ee5860cd36 100644
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/ElasticsearchClient.java
+++ b/java-client/src/main/java/co/elastic/clients/elasticsearch/ElasticsearchClient.java
@@ -383,10 +383,11 @@ public ElasticsearchXpackClient xpack() {
// ----- Endpoint: bulk
/**
- * Bulk index or delete documents. Perform multiple
+ * Perform multiple
* If the Elasticsearch security features are enabled, you must have the
* following index privileges for the target data stream, index, or index alias:
@@ -483,6 +484,8 @@ public ElasticsearchXpackClient xpack() {
*
+ * Perform multiple
* If the Elasticsearch security features are enabled, you must have the
* following index privileges for the target data stream, index, or index alias:
@@ -662,6 +666,8 @@ public BulkResponse bulk(BulkRequest request) throws IOException, ElasticsearchE
*
+ * Perform multiple
* If the Elasticsearch security features are enabled, you must have the
* following index privileges for the target data stream, index, or index alias:
@@ -842,6 +849,8 @@ public final BulkResponse bulk(Function
+ * Clear the search context and results for a scrolling search.
*
* @see Documentation
@@ -937,8 +947,9 @@ public ClearScrollResponse clearScroll(ClearScrollRequest request) throws IOExce
}
/**
- * Clear a scrolling search. Clear the search context and results for a
- * scrolling search.
+ * Clear a scrolling search.
+ *
+ * Clear the search context and results for a scrolling search.
*
* @param fn
* a function that initializes a builder to create the
@@ -955,8 +966,9 @@ public final ClearScrollResponse clearScroll(
}
/**
- * Clear a scrolling search. Clear the search context and results for a
- * scrolling search.
+ * Clear a scrolling search.
+ *
+ * Clear the search context and results for a scrolling search.
*
* @see Documentation
@@ -971,12 +983,14 @@ public ClearScrollResponse clearScroll() throws IOException, ElasticsearchExcept
// ----- Endpoint: close_point_in_time
/**
- * Close a point in time. A point in time must be opened explicitly before being
- * used in search requests. The
+ * A point in time must be opened explicitly before being used in search
+ * requests. The
+ * A point in time must be opened explicitly before being used in search
+ * requests. The
+ * Get the number of documents matching a query.
*
* The query can be provided either by using a simple query string as a
* parameter, or by defining Query DSL within the request body. The query is
@@ -1043,7 +1061,9 @@ public CountResponse count(CountRequest request) throws IOException, Elasticsear
}
/**
- * Count search results. Get the number of documents matching a query.
+ * Count search results.
+ *
+ * Get the number of documents matching a query.
*
* The query can be provided either by using a simple query string as a
* parameter, or by defining Query DSL within the request body. The query is
@@ -1071,7 +1091,9 @@ public final CountResponse count(Function
* The query can be provided either by using a simple query string as a
* parameter, or by defining Query DSL within the request body. The query is
@@ -1848,8 +1870,9 @@ public final DeleteByQueryRethrottleResponse deleteByQueryRethrottle(
// ----- Endpoint: delete_script
/**
- * Delete a script or search template. Deletes a stored script or search
- * template.
+ * Delete a script or search template.
+ *
+ * Deletes a stored script or search template.
*
* @see Documentation
@@ -1864,8 +1887,9 @@ public DeleteScriptResponse deleteScript(DeleteScriptRequest request) throws IOE
}
/**
- * Delete a script or search template. Deletes a stored script or search
- * template.
+ * Delete a script or search template.
+ *
+ * Deletes a stored script or search template.
*
* @param fn
* a function that initializes a builder to create the
@@ -2013,9 +2037,10 @@ public final BooleanResponse existsSource(
// ----- Endpoint: explain
/**
- * Explain a document match result. Get information about why a specific
- * document matches, or doesn't match, a query. It computes a score explanation
- * for a query and a specific document.
+ * Explain a document match result.
+ *
+ * Get information about why a specific document matches, or doesn't match, a
+ * query. It computes a score explanation for a query and a specific document.
*
* @see Documentation
@@ -2033,9 +2058,10 @@ public
+ * Get information about why a specific document matches, or doesn't match, a
+ * query. It computes a score explanation for a query and a specific document.
*
* @param fn
* a function that initializes a builder to create the
@@ -2073,9 +2099,10 @@ public final ExplainResponse
+ * Get information about why a specific document matches, or doesn't match, a
+ * query. It computes a score explanation for a query and a specific document.
*
* @param fn
* a function that initializes a builder to create the
@@ -2556,8 +2584,9 @@ public final
+ * Retrieves a stored script or search template.
*
* @param fn
* a function that initializes a builder to create the
@@ -2779,9 +2809,10 @@ public final
+ * Get a report with the health status of an Elasticsearch cluster. The report
+ * contains a list of indicators that compose Elasticsearch functionality.
*
* Each indicator has a health status of: green, unknown, yellow or red. The
* indicator will provide an explanation and metadata describing the reason for
@@ -2821,9 +2852,10 @@ public HealthReportResponse healthReport(HealthReportRequest request) throws IOE
}
/**
- * Get the cluster health. Get a report with the health status of an
- * Elasticsearch cluster. The report contains a list of indicators that compose
- * Elasticsearch functionality.
+ * Get the cluster health.
+ *
+ * Get a report with the health status of an Elasticsearch cluster. The report
+ * contains a list of indicators that compose Elasticsearch functionality.
*
* Each indicator has a health status of: green, unknown, yellow or red. The
* indicator will provide an explanation and metadata describing the reason for
@@ -2865,9 +2897,10 @@ public final HealthReportResponse healthReport(
}
/**
- * Get the cluster health. Get a report with the health status of an
- * Elasticsearch cluster. The report contains a list of indicators that compose
- * Elasticsearch functionality.
+ * Get the cluster health.
+ *
+ * Get a report with the health status of an Elasticsearch cluster. The report
+ * contains a list of indicators that compose Elasticsearch functionality.
*
* Each indicator has a health status of: green, unknown, yellow or red. The
* indicator will provide an explanation and metadata describing the reason for
@@ -3088,15 +3121,21 @@ public HealthReportResponse healthReport() throws IOException, ElasticsearchExce
* "id": "elkbee"
* }
* }
- *
- * In this example, the operation will succeed since the supplied version of 2 is higher than the current document version of 1.
- * If the document was already updated and its version was set to 2 or higher, the indexing command will fail and result in a conflict (409 HTTP status code).
- *
- * A nice side effect is that there is no need to maintain strict ordering of async indexing operations run as a result of changes to a source database, as long as version numbers from the source database are used.
- * Even the simple case of updating the Elasticsearch index using data from a database is simplified if external versioning is used, as only the latest version will be used if the index operations arrive out of order.
*
*
- *
+ *
+ * In this example, the operation will succeed since the supplied version of 2
+ * is higher than the current document version of 1. If the document was already
+ * updated and its version was set to 2 or higher, the indexing command will
+ * fail and result in a conflict (409 HTTP status code).
+ *
+ * A nice side effect is that there is no need to maintain strict ordering of
+ * async indexing operations run as a result of changes to a source database, as
+ * long as version numbers from the source database are used. Even the simple
+ * case of updating the Elasticsearch index using data from a database is
+ * simplified if external versioning is used, as only the latest version will be
+ * used if the index operations arrive out of order.
+ *
* @see Documentation
* on elastic.co
@@ -3291,15 +3330,21 @@ public
+ * In this example, the operation will succeed since the supplied version of 2
+ * is higher than the current document version of 1. If the document was already
+ * updated and its version was set to 2 or higher, the indexing command will
+ * fail and result in a conflict (409 HTTP status code).
+ *
+ * A nice side effect is that there is no need to maintain strict ordering of
+ * async indexing operations run as a result of changes to a source database, as
+ * long as version numbers from the source database are used. Even the simple
+ * case of updating the Elasticsearch index using data from a database is
+ * simplified if external versioning is used, as only the latest version will be
+ * used if the index operations arrive out of order.
+ *
* @param fn
* a function that initializes a builder to create the
* {@link IndexRequest}
@@ -3317,9 +3362,11 @@ public final
+ * Get basic build, version, and cluster information. ::: In Serverless, this
+ * API is retained for backward compatibility only. Some response fields, such
+ * as the version number, should be ignored.
*
* @see Documentation
@@ -4077,7 +4124,9 @@ public final OpenPointInTimeResponse openPointInTime(
// ----- Endpoint: ping
/**
- * Ping the cluster. Get information about whether the cluster is running.
+ * Ping the cluster.
+ *
+ * Get information about whether the cluster is running.
*
* @see Documentation
@@ -4090,8 +4139,9 @@ public BooleanResponse ping() throws IOException, ElasticsearchException {
// ----- Endpoint: put_script
/**
- * Create or update a script or search template. Creates or updates a stored
- * script or search template.
+ * Create or update a script or search template.
+ *
+ * Creates or updates a stored script or search template.
*
* @see Documentation
@@ -4106,8 +4156,9 @@ public PutScriptResponse putScript(PutScriptRequest request) throws IOException,
}
/**
- * Create or update a script or search template. Creates or updates a stored
- * script or search template.
+ * Create or update a script or search template.
+ *
+ * Creates or updates a stored script or search template.
*
* @param fn
* a function that initializes a builder to create the
@@ -4194,9 +4245,13 @@ public final RankEvalResponse rankEval(Function
- * If reindexing from a remote cluster, you must explicitly allow the remote
- * host in the
* The
- * If reindexing from a remote cluster, you must explicitly allow the remote
- * host in the
* The
+ * Updates documents that match the specified query. If no query is specified,
+ * performs an update on every document in the data stream or index without
+ * modifying the source, which is useful for picking up mapping changes.
*
* If the Elasticsearch security features are enabled, you must have the
* following index privileges for the target data stream, index, or alias:
@@ -6351,10 +6411,11 @@ public UpdateByQueryResponse updateByQuery(UpdateByQueryRequest request)
}
/**
- * Update documents. Updates documents that match the specified query. If no
- * query is specified, performs an update on every document in the data stream
- * or index without modifying the source, which is useful for picking up mapping
- * changes.
+ * Update documents.
+ *
+ * Updates documents that match the specified query. If no query is specified,
+ * performs an update on every document in the data stream or index without
+ * modifying the source, which is useful for picking up mapping changes.
*
* If the Elasticsearch security features are enabled, you must have the
* following index privileges for the target data stream, index, or alias:
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/_types/CommonStatsFlag.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/_types/CommonStatsFlag.java
new file mode 100644
index 0000000000..776f9a188c
--- /dev/null
+++ b/java-client/src/main/java/co/elastic/clients/elasticsearch/_types/CommonStatsFlag.java
@@ -0,0 +1,106 @@
+/*
+ * Licensed to Elasticsearch B.V. under one or more contributor
+ * license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright
+ * ownership. Elasticsearch B.V. licenses this file to you under
+ * the Apache License, Version 2.0 (the "License"); you may
+ * not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package co.elastic.clients.elasticsearch._types;
+
+import co.elastic.clients.json.JsonEnum;
+import co.elastic.clients.json.JsonpDeserializable;
+import co.elastic.clients.json.JsonpDeserializer;
+
+//----------------------------------------------------------------
+// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
+//----------------------------------------------------------------
+//
+// This code is generated from the Elasticsearch API specification
+// at https://github.com/elastic/elasticsearch-specification
+//
+// Manual updates to this file will be lost when the code is
+// re-generated.
+//
+// If you find a property that is missing or wrongly typed, please
+// open an issue or a PR on the API specification repository.
+//
+//----------------------------------------------------------------
+
+/**
+ *
+ * @see API
+ * specification
+ */
+@JsonpDeserializable
+public enum CommonStatsFlag implements JsonEnum {
+ All("_all"),
+
+ Store("store"),
+
+ Indexing("indexing"),
+
+ Get("get"),
+
+ Search("search"),
+
+ Merge("merge"),
+
+ Flush("flush"),
+
+ Refresh("refresh"),
+
+ QueryCache("query_cache"),
+
+ Fielddata("fielddata"),
+
+ Docs("docs"),
+
+ Warmer("warmer"),
+
+ Completion("completion"),
+
+ Segments("segments"),
+
+ Translog("translog"),
+
+ RequestCache("request_cache"),
+
+ Recovery("recovery"),
+
+ Bulk("bulk"),
+
+ ShardStats("shard_stats"),
+
+ Mappings("mappings"),
+
+ DenseVector("dense_vector"),
+
+ SparseVector("sparse_vector"),
+
+ ;
+
+ private final String jsonValue;
+
+ CommonStatsFlag(String jsonValue) {
+ this.jsonValue = jsonValue;
+ }
+
+ public String jsonValue() {
+ return this.jsonValue;
+ }
+
+ public static final JsonEnum.Deserializer
+ * API name: {@code type}
+ */
+ public final DiversifyRetrieverTypes type() {
+ return this.type;
+ }
+
+ /**
+ * Required - The document field on which to diversify results on.
+ *
+ * API name: {@code field}
+ */
+ public final String field() {
+ return this.field;
+ }
+
+ /**
+ * Required - The nested retriever whose results will be diversified.
+ *
+ * API name: {@code retriever}
+ */
+ public final Retriever retriever() {
+ return this.retriever;
+ }
+
+ /**
+ * The number of top documents to return after diversification.
+ *
+ * API name: {@code size}
+ */
+ @Nullable
+ public final Integer size() {
+ return this.size;
+ }
+
+ /**
+ * The number of top documents from the nested retriever to consider for
+ * diversification.
+ *
+ * API name: {@code rank_window_size}
+ */
+ @Nullable
+ public final Integer rankWindowSize() {
+ return this.rankWindowSize;
+ }
+
+ /**
+ * The query vector used for diversification.
+ *
+ * API name: {@code query_vector}
+ */
+ public final List
+ * API name: {@code query_vector_builder}
+ */
+ @Nullable
+ public final QueryVectorBuilder queryVectorBuilder() {
+ return this.queryVectorBuilder;
+ }
+
+ /**
+ * Controls the trade-off between relevance and diversity for MMR. A value of
+ * 0.0 focuses solely on diversity, while a value of 1.0 focuses solely on
+ * relevance. Required for MMR
+ *
+ * API name: {@code lambda}
+ */
+ @Nullable
+ public final Float lambda() {
+ return this.lambda;
+ }
+
+ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
+
+ super.serializeInternal(generator, mapper);
+ generator.writeKey("type");
+ this.type.serialize(generator, mapper);
+ generator.writeKey("field");
+ generator.write(this.field);
+
+ generator.writeKey("retriever");
+ this.retriever.serialize(generator, mapper);
+
+ if (this.size != null) {
+ generator.writeKey("size");
+ generator.write(this.size);
+
+ }
+ if (this.rankWindowSize != null) {
+ generator.writeKey("rank_window_size");
+ generator.write(this.rankWindowSize);
+
+ }
+ if (ApiTypeHelper.isDefined(this.queryVector)) {
+ generator.writeKey("query_vector");
+ generator.writeStartArray();
+ for (Float item0 : this.queryVector) {
+ generator.write(item0);
+
+ }
+ generator.writeEnd();
+
+ }
+ if (this.queryVectorBuilder != null) {
+ generator.writeKey("query_vector_builder");
+ this.queryVectorBuilder.serialize(generator, mapper);
+
+ }
+ if (this.lambda != null) {
+ generator.writeKey("lambda");
+ generator.write(this.lambda);
+
+ }
+
+ }
+
+ // ---------------------------------------------------------------------------------------------
+
+ /**
+ * Builder for {@link DiversifyRetriever}.
+ */
+
+ public static class Builder extends RetrieverBase.AbstractBuilder
+ * API name: {@code type}
+ */
+ public final Builder type(DiversifyRetrieverTypes value) {
+ this.type = value;
+ return this;
+ }
+
+ /**
+ * Required - The document field on which to diversify results on.
+ *
+ * API name: {@code field}
+ */
+ public final Builder field(String value) {
+ this.field = value;
+ return this;
+ }
+
+ /**
+ * Required - The nested retriever whose results will be diversified.
+ *
+ * API name: {@code retriever}
+ */
+ public final Builder retriever(Retriever value) {
+ this.retriever = value;
+ return this;
+ }
+
+ /**
+ * Required - The nested retriever whose results will be diversified.
+ *
+ * API name: {@code retriever}
+ */
+ public final Builder retriever(Function
+ * API name: {@code retriever}
+ */
+ public final Builder retriever(RetrieverVariant value) {
+ this.retriever = value._toRetriever();
+ return this;
+ }
+
+ /**
+ * The number of top documents to return after diversification.
+ *
+ * API name: {@code size}
+ */
+ public final Builder size(@Nullable Integer value) {
+ this.size = value;
+ return this;
+ }
+
+ /**
+ * The number of top documents from the nested retriever to consider for
+ * diversification.
+ *
+ * API name: {@code rank_window_size}
+ */
+ public final Builder rankWindowSize(@Nullable Integer value) {
+ this.rankWindowSize = value;
+ return this;
+ }
+
+ /**
+ * The query vector used for diversification.
+ *
+ * API name: {@code query_vector}
+ *
+ * Adds all elements of
+ * API name: {@code query_vector}
+ *
+ * Adds one or more values to
+ * API name: {@code query_vector_builder}
+ */
+ public final Builder queryVectorBuilder(@Nullable QueryVectorBuilder value) {
+ this.queryVectorBuilder = value;
+ return this;
+ }
+
+ /**
+ * a dense vector query vector builder to use instead of a static query_vector
+ *
+ * API name: {@code query_vector_builder}
+ */
+ public final Builder queryVectorBuilder(
+ Function
+ * API name: {@code query_vector_builder}
+ */
+ public final Builder queryVectorBuilder(QueryVectorBuilderVariant value) {
+ this.queryVectorBuilder = value._toQueryVectorBuilder();
+ return this;
+ }
+
+ /**
+ * Controls the trade-off between relevance and diversity for MMR. A value of
+ * 0.0 focuses solely on diversity, while a value of 1.0 focuses solely on
+ * relevance. Required for MMR
+ *
+ * API name: {@code lambda}
+ */
+ public final Builder lambda(@Nullable Float value) {
+ this.lambda = value;
+ return this;
+ }
+
+ @Override
+ protected Builder self() {
+ return this;
+ }
+
+ /**
+ * Builds a {@link DiversifyRetriever}.
+ *
+ * @throws NullPointerException
+ * if some of the required fields are null.
+ */
+ public DiversifyRetriever build() {
+ _checkSingleUse();
+
+ return new DiversifyRetriever(this);
+ }
+ }
+
+ // ---------------------------------------------------------------------------------------------
+
+ /**
+ * Json deserializer for {@link DiversifyRetriever}
+ */
+ public static final JsonpDeserializer
+ * Adds all elements of
+ * Adds one or more values to
+ * API name: {@code visit_percentage}
+ */
+ @Nullable
+ public final Float visitPercentage() {
+ return this.visitPercentage;
+ }
+
/**
* The final number of nearest neighbors to return as top hits
*
@@ -214,6 +229,11 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
generator.writeKey("num_candidates");
generator.write(this.numCandidates);
+ }
+ if (this.visitPercentage != null) {
+ generator.writeKey("visit_percentage");
+ generator.write(this.visitPercentage);
+
}
if (this.k != null) {
generator.writeKey("k");
@@ -261,6 +281,9 @@ public static class Builder extends QueryBase.AbstractBuilder
+ * API name: {@code visit_percentage}
+ */
+ public final Builder visitPercentage(@Nullable Float value) {
+ this.visitPercentage = value;
+ return this;
+ }
+
/**
* The final number of nearest neighbors to return as top hits
*
@@ -472,6 +506,7 @@ protected static void setupKnnQueryDeserializer(ObjectDeserializer
@@ -198,6 +213,11 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
generator.writeKey("num_candidates");
generator.write(this.numCandidates);
+ if (this.visitPercentage != null) {
+ generator.writeKey("visit_percentage");
+ generator.write(this.visitPercentage);
+
+ }
if (this.similarity != null) {
generator.writeKey("similarity");
generator.write(this.similarity);
@@ -230,6 +250,9 @@ public static class Builder extends RetrieverBase.AbstractBuilder
+ * API name: {@code visit_percentage}
+ */
+ public final Builder visitPercentage(@Nullable Float value) {
+ this.visitPercentage = value;
+ return this;
+ }
+
/**
* The minimum similarity required for a document to be considered a match.
*
@@ -387,6 +421,7 @@ protected static void setupKnnRetrieverDeserializer(ObjectDeserializer
@@ -249,6 +264,11 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
generator.writeKey("num_candidates");
generator.write(this.numCandidates);
+ }
+ if (this.visitPercentage != null) {
+ generator.writeKey("visit_percentage");
+ generator.write(this.visitPercentage);
+
}
if (this.boost != null) {
generator.writeKey("boost");
@@ -309,6 +329,9 @@ public static class Builder extends WithJsonObjectBuilderBase
+ * API name: {@code visit_percentage}
+ */
+ public final Builder visitPercentage(@Nullable Float value) {
+ this.visitPercentage = value;
+ return this;
+ }
+
/**
* Boost value to apply to kNN scores
*
@@ -553,6 +587,7 @@ protected static void setupKnnSearchDeserializer(ObjectDeserializer
* API name: {@code retrievers}
*/
- public final List
* API name: {@code retrievers}
*
* Adds all elements of
* API name: {@code retrievers}
*
* Adds one or more values to
- * API name: {@code retrievers}
- *
- * Adds one or more values to
* API name: {@code retrievers}
*
* Adds a value to
+ * API name: {@code retriever}
+ */
+ public final Retriever retriever() {
+ return this.retriever;
+ }
+
+ /**
+ * Weight multiplier for this retriever's contribution to the RRF score. Higher
+ * values increase influence. Defaults to 1.0 if not specified. Must be
+ * non-negative.
+ *
+ * API name: {@code weight}
+ */
+ @Nullable
+ public final Float weight() {
+ return this.weight;
+ }
+
+ /**
+ * Serialize this object to JSON.
+ */
+ public void serialize(JsonGenerator generator, JsonpMapper mapper) {
+ generator.writeStartObject();
+ serializeInternal(generator, mapper);
+ generator.writeEnd();
+ }
+
+ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
+
+ generator.writeKey("retriever");
+ this.retriever.serialize(generator, mapper);
+
+ if (this.weight != null) {
+ generator.writeKey("weight");
+ generator.write(this.weight);
+
+ }
+
+ }
+
+ @Override
+ public String toString() {
+ return JsonpUtils.toString(this);
+ }
+
+ // ---------------------------------------------------------------------------------------------
+
+ /**
+ * Builder for {@link RRFRetrieverComponent}.
+ */
+
+ public static class Builder extends WithJsonObjectBuilderBase
+ * API name: {@code retriever}
+ */
+ public final Builder retriever(Retriever value) {
+ this.retriever = value;
+ return this;
+ }
+
+ /**
+ * Required - The nested retriever configuration.
+ *
+ * API name: {@code retriever}
+ */
+ public final Builder retriever(Function
+ * API name: {@code retriever}
+ */
+ public final Builder retriever(RetrieverVariant value) {
+ this.retriever = value._toRetriever();
+ return this;
+ }
+
+ /**
+ * Weight multiplier for this retriever's contribution to the RRF score. Higher
+ * values increase influence. Defaults to 1.0 if not specified. Must be
+ * non-negative.
+ *
+ * API name: {@code weight}
+ */
+ public final Builder weight(@Nullable Float value) {
+ this.weight = value;
+ return this;
+ }
+
+ @Override
+ protected Builder self() {
+ return this;
+ }
+
+ /**
+ * Builds a {@link RRFRetrieverComponent}.
+ *
+ * @throws NullPointerException
+ * if some of the required fields are null.
+ */
+ public RRFRetrieverComponent build() {
+ _checkSingleUse();
+
+ return new RRFRetrieverComponent(this);
+ }
+ }
+
+ // ---------------------------------------------------------------------------------------------
+
+ /**
+ * Json deserializer for {@link RRFRetrieverComponent}
+ */
+ public static final JsonpDeserializer
+ * API name: {@code slice_id}
+ */
+ @Nullable
+ public final Integer sliceId() {
+ return this.sliceId;
+ }
+
/**
* Required - The number of scroll responses pulled back by the reindex.
*
@@ -126,11 +145,12 @@ public final long batches() {
}
/**
- * Required - The number of documents that were successfully created.
+ * The number of documents that were successfully created.
*
* API name: {@code created}
*/
- public final long created() {
+ @Nullable
+ public final Long created() {
return this.created;
}
@@ -223,13 +243,13 @@ public final long total() {
}
/**
- * Required - The number of documents that were successfully updated, for
- * example, a document with same ID already existed prior to reindex updating
- * it.
+ * The number of documents that were successfully updated, for example, a
+ * document with same ID already existed prior to reindex updating it.
*
* API name: {@code updated}
*/
- public final long updated() {
+ @Nullable
+ public final Long updated() {
return this.updated;
}
@@ -242,6 +262,16 @@ public final long versionConflicts() {
return this.versionConflicts;
}
+ /**
+ * The reason for cancellation if the slice was canceled
+ *
+ * API name: {@code cancelled}
+ */
+ @Nullable
+ public final String cancelled() {
+ return this.cancelled;
+ }
+
/**
* Serialize this object to JSON.
*/
@@ -253,12 +283,19 @@ public void serialize(JsonGenerator generator, JsonpMapper mapper) {
protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
+ if (this.sliceId != null) {
+ generator.writeKey("slice_id");
+ generator.write(this.sliceId);
+
+ }
generator.writeKey("batches");
generator.write(this.batches);
- generator.writeKey("created");
- generator.write(this.created);
+ if (this.created != null) {
+ generator.writeKey("created");
+ generator.write(this.created);
+ }
generator.writeKey("deleted");
generator.write(this.deleted);
@@ -290,12 +327,20 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
generator.writeKey("total");
generator.write(this.total);
- generator.writeKey("updated");
- generator.write(this.updated);
+ if (this.updated != null) {
+ generator.writeKey("updated");
+ generator.write(this.updated);
+ }
generator.writeKey("version_conflicts");
generator.write(this.versionConflicts);
+ if (this.cancelled != null) {
+ generator.writeKey("cancelled");
+ generator.write(this.cancelled);
+
+ }
+
}
@Override
@@ -310,8 +355,12 @@ public String toString() {
*/
public static class Builder extends WithJsonObjectBuilderBase
+ * API name: {@code slice_id}
+ */
+ public final Builder sliceId(@Nullable Integer value) {
+ this.sliceId = value;
+ return this;
+ }
+
/**
* Required - The number of scroll responses pulled back by the reindex.
*
@@ -349,11 +412,11 @@ public final Builder batches(long value) {
}
/**
- * Required - The number of documents that were successfully created.
+ * The number of documents that were successfully created.
*
* API name: {@code created}
*/
- public final Builder created(long value) {
+ public final Builder created(@Nullable Long value) {
this.created = value;
return this;
}
@@ -479,13 +542,12 @@ public final Builder total(long value) {
}
/**
- * Required - The number of documents that were successfully updated, for
- * example, a document with same ID already existed prior to reindex updating
- * it.
+ * The number of documents that were successfully updated, for example, a
+ * document with same ID already existed prior to reindex updating it.
*
* API name: {@code updated}
*/
- public final Builder updated(long value) {
+ public final Builder updated(@Nullable Long value) {
this.updated = value;
return this;
}
@@ -500,6 +562,16 @@ public final Builder versionConflicts(long value) {
return this;
}
+ /**
+ * The reason for cancellation if the slice was canceled
+ *
+ * API name: {@code cancelled}
+ */
+ public final Builder cancelled(@Nullable String value) {
+ this.cancelled = value;
+ return this;
+ }
+
@Override
protected Builder self() {
return this;
@@ -528,6 +600,7 @@ public ReindexStatus build() {
protected static void setupReindexStatusDeserializer(ObjectDeserializer
* API name: {@code sort}
*/
+ @Nullable
public final GeoLineSort sort() {
return this.sort;
}
@@ -166,9 +168,11 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
generator.writeKey("point");
this.point.serialize(generator, mapper);
- generator.writeKey("sort");
- this.sort.serialize(generator, mapper);
+ if (this.sort != null) {
+ generator.writeKey("sort");
+ this.sort.serialize(generator, mapper);
+ }
if (this.includeSort != null) {
generator.writeKey("include_sort");
generator.write(this.includeSort);
@@ -202,6 +206,7 @@ public static class Builder extends WithJsonObjectBuilderBase
* API name: {@code sort}
*/
- public final Builder sort(GeoLineSort value) {
+ public final Builder sort(@Nullable GeoLineSort value) {
this.sort = value;
return this;
}
/**
- * Required - The name of the numeric field to use as the sort key for ordering
- * the points. When the
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/_types/aggregations/GeoTileGridAggregation.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/_types/aggregations/GeoTileGridAggregation.java
index 7928c64452..ad42320a8e 100644
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/_types/aggregations/GeoTileGridAggregation.java
+++ b/java-client/src/main/java/co/elastic/clients/elasticsearch/_types/aggregations/GeoTileGridAggregation.java
@@ -32,7 +32,6 @@
import co.elastic.clients.util.ObjectBuilder;
import jakarta.json.stream.JsonGenerator;
import java.lang.Integer;
-import java.lang.Number;
import java.lang.String;
import java.util.Objects;
import java.util.function.Function;
@@ -71,7 +70,7 @@ public class GeoTileGridAggregation extends BucketAggregationBase
private final String field;
@Nullable
- private final Number precision;
+ private final Integer precision;
@Nullable
private final Integer shardSize;
@@ -133,7 +132,7 @@ public final String field() {
* API name: {@code precision}
*/
@Nullable
- public final Number precision() {
+ public final Integer precision() {
return this.precision;
}
@@ -187,7 +186,7 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
}
if (this.precision != null) {
generator.writeKey("precision");
- generator.write(this.precision.doubleValue());
+ generator.write(this.precision);
}
if (this.shardSize != null) {
@@ -226,7 +225,7 @@ public static class Builder extends BucketAggregationBase.AbstractBuilder
- * Only applicable to
* API name: {@code on_disk_rescore}
*/
@@ -345,7 +346,8 @@ public final Builder rescoreVector(
/**
*
- * Only applicable to
* API name: {@code on_disk_rescore}
*/
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/_types/mapping/ExponentialHistogramProperty.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/_types/mapping/ExponentialHistogramProperty.java
new file mode 100644
index 0000000000..bce4e42e4f
--- /dev/null
+++ b/java-client/src/main/java/co/elastic/clients/elasticsearch/_types/mapping/ExponentialHistogramProperty.java
@@ -0,0 +1,155 @@
+/*
+ * Licensed to Elasticsearch B.V. under one or more contributor
+ * license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright
+ * ownership. Elasticsearch B.V. licenses this file to you under
+ * the Apache License, Version 2.0 (the "License"); you may
+ * not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package co.elastic.clients.elasticsearch._types.mapping;
+
+import co.elastic.clients.json.JsonpDeserializable;
+import co.elastic.clients.json.JsonpDeserializer;
+import co.elastic.clients.json.JsonpMapper;
+import co.elastic.clients.json.ObjectBuilderDeserializer;
+import co.elastic.clients.json.ObjectDeserializer;
+import co.elastic.clients.util.ObjectBuilder;
+import jakarta.json.stream.JsonGenerator;
+import java.util.Objects;
+import java.util.function.Function;
+import javax.annotation.Nullable;
+
+//----------------------------------------------------------------
+// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
+//----------------------------------------------------------------
+//
+// This code is generated from the Elasticsearch API specification
+// at https://github.com/elastic/elasticsearch-specification
+//
+// Manual updates to this file will be lost when the code is
+// re-generated.
+//
+// If you find a property that is missing or wrongly typed, please
+// open an issue or a PR on the API specification repository.
+//
+//----------------------------------------------------------------
+
+// typedef: _types.mapping.ExponentialHistogramProperty
+
+/**
+ *
+ * @see API
+ * specification
+ */
+@JsonpDeserializable
+public class ExponentialHistogramProperty extends PropertyBase implements PropertyVariant {
+ @Nullable
+ private final TimeSeriesMetricType timeSeriesMetric;
+
+ // ---------------------------------------------------------------------------------------------
+
+ private ExponentialHistogramProperty(Builder builder) {
+ super(builder);
+
+ this.timeSeriesMetric = builder.timeSeriesMetric;
+
+ }
+
+ public static ExponentialHistogramProperty of(FunctionSearch::Elasticsearch::Client::5_0::Scroll
* elasticsearch.helpers.*client.helpers.*co.elastic.clients.elasticsearch._helpers.bulk.BulkIngesterBulkAllObservableElasticsearch::Helpers::BulkHelpercreate, delete, and update actions in
- * a single request. This reduces overhead and can greatly increase indexing
- * speed.
+ * Bulk index or delete documents.
+ * index, create,
+ * delete, and update actions in a single request.
+ * This reduces overhead and can greatly increase indexing speed.
* elasticsearch.helpers.*client.helpers.*co.elastic.clients.elasticsearch._helpers.bulk.BulkIngesterBulkAllObservableElasticsearch::Helpers::BulkHelperkeep_alive parameter tells
- * Elasticsearch how long it should persist. A point in time is automatically
- * closed when the keep_alive period has elapsed. However, keeping
- * points in time has a cost; close them as soon as they are no longer required
- * for search requests.
+ * Close a point in time.
+ * keep_alive parameter tells Elasticsearch how long
+ * it should persist. A point in time is automatically closed when the
+ * keep_alive period has elapsed. However, keeping points in time
+ * has a cost; close them as soon as they are no longer required for search
+ * requests.
*
* @see Documentation
@@ -989,12 +1003,14 @@ public CompletableFuturekeep_alive parameter tells
- * Elasticsearch how long it should persist. A point in time is automatically
- * closed when the keep_alive period has elapsed. However, keeping
- * points in time has a cost; close them as soon as they are no longer required
- * for search requests.
+ * Close a point in time.
+ * keep_alive parameter tells Elasticsearch how long
+ * it should persist. A point in time is automatically closed when the
+ * keep_alive period has elapsed. However, keeping points in time
+ * has a cost; close them as soon as they are no longer required for search
+ * requests.
*
* @param fn
* a function that initializes a builder to create the
@@ -1012,7 +1028,9 @@ public final CompletableFuturereindex.remote.whitelist setting. Automatic data
- * stream creation requires a matching index template with data stream enabled.
+ * If reindexing from a remote cluster into a cluster using Elastic Stack, you
+ * must explicitly allow the remote host using the
+ * reindex.remote.whitelist node setting on the destination
+ * cluster. If reindexing from a remote cluster into an Elastic Cloud Serverless
+ * project, only remote hosts from Elastic Cloud Hosted are allowed. Automatic
+ * data stream creation requires a matching index template with data stream
+ * enabled.
* dest element can be configured like the index API to control
* optimistic concurrency control. Omitting version_type or setting
@@ -4257,9 +4312,13 @@ public CompletableFuturereindex.remote.whitelist setting. Automatic data
- * stream creation requires a matching index template with data stream enabled.
+ * If reindexing from a remote cluster into a cluster using Elastic Stack, you
+ * must explicitly allow the remote host using the
+ * reindex.remote.whitelist node setting on the destination
+ * cluster. If reindexing from a remote cluster into an Elastic Cloud Serverless
+ * project, only remote hosts from Elastic Cloud Hosted are allowed. Automatic
+ * data stream creation requires a matching index template with data stream
+ * enabled.
* dest element can be configured like the index API to control
* optimistic concurrency control. Omitting version_type or setting
@@ -6140,10 +6199,11 @@ public final index,
- * create, delete, and update actions in
- * a single request. This reduces overhead and can greatly increase indexing
- * speed.
+ * Bulk index or delete documents.
+ * index, create,
+ * delete, and update actions in a single request.
+ * This reduces overhead and can greatly increase indexing speed.
* Search::Elasticsearch::Client::5_0::Scroll
* elasticsearch.helpers.*client.helpers.*co.elastic.clients.elasticsearch._helpers.bulk.BulkIngesterBulkAllObservableElasticsearch::Helpers::BulkHelperindex,
- * create, delete, and update actions in
- * a single request. This reduces overhead and can greatly increase indexing
- * speed.
+ * Bulk index or delete documents.
+ * index, create,
+ * delete, and update actions in a single request.
+ * This reduces overhead and can greatly increase indexing speed.
* Search::Elasticsearch::Client::5_0::Scroll
* elasticsearch.helpers.*client.helpers.*co.elastic.clients.elasticsearch._helpers.bulk.BulkIngesterBulkAllObservableElasticsearch::Helpers::BulkHelpercreate, delete, and update actions in
- * a single request. This reduces overhead and can greatly increase indexing
- * speed.
+ * Bulk index or delete documents.
+ * index, create,
+ * delete, and update actions in a single request.
+ * This reduces overhead and can greatly increase indexing speed.
* elasticsearch.helpers.*client.helpers.*co.elastic.clients.elasticsearch._helpers.bulk.BulkIngesterBulkAllObservableElasticsearch::Helpers::BulkHelperkeep_alive parameter tells
- * Elasticsearch how long it should persist. A point in time is automatically
- * closed when the keep_alive period has elapsed. However, keeping
- * points in time has a cost; close them as soon as they are no longer required
- * for search requests.
+ * Close a point in time.
+ * keep_alive parameter tells Elasticsearch how long
+ * it should persist. A point in time is automatically closed when the
+ * keep_alive period has elapsed. However, keeping points in time
+ * has a cost; close them as soon as they are no longer required for search
+ * requests.
*
* @see Documentation
@@ -992,12 +1006,14 @@ public ClosePointInTimeResponse closePointInTime(ClosePointInTimeRequest request
}
/**
- * Close a point in time. A point in time must be opened explicitly before being
- * used in search requests. The keep_alive parameter tells
- * Elasticsearch how long it should persist. A point in time is automatically
- * closed when the keep_alive period has elapsed. However, keeping
- * points in time has a cost; close them as soon as they are no longer required
- * for search requests.
+ * Close a point in time.
+ * keep_alive parameter tells Elasticsearch how long
+ * it should persist. A point in time is automatically closed when the
+ * keep_alive period has elapsed. However, keeping points in time
+ * has a cost; close them as soon as they are no longer required for search
+ * requests.
*
* @param fn
* a function that initializes a builder to create the
@@ -1016,7 +1032,9 @@ public final ClosePointInTimeResponse closePointInTime(
// ----- Endpoint: count
/**
- * Count search results. Get the number of documents matching a query.
+ * Count search results.
+ * reindex.remote.whitelist setting. Automatic data
- * stream creation requires a matching index template with data stream enabled.
+ * If reindexing from a remote cluster into a cluster using Elastic Stack, you
+ * must explicitly allow the remote host using the
+ * reindex.remote.whitelist node setting on the destination
+ * cluster. If reindexing from a remote cluster into an Elastic Cloud Serverless
+ * project, only remote hosts from Elastic Cloud Hosted are allowed. Automatic
+ * data stream creation requires a matching index template with data stream
+ * enabled.
* dest element can be configured like the index API to control
* optimistic concurrency control. Omitting version_type or setting
@@ -4286,9 +4341,13 @@ public ReindexResponse reindex(ReindexRequest request) throws IOException, Elast
* alias.
*
* reindex.remote.whitelist setting. Automatic data
- * stream creation requires a matching index template with data stream enabled.
+ * If reindexing from a remote cluster into a cluster using Elastic Stack, you
+ * must explicitly allow the remote host using the
+ * reindex.remote.whitelist node setting on the destination
+ * cluster. If reindexing from a remote cluster into an Elastic Cloud Serverless
+ * project, only remote hosts from Elastic Cloud Hosted are allowed. Automatic
+ * data stream creation requires a matching index template with data stream
+ * enabled.
* dest element can be configured like the index API to control
* optimistic concurrency control. Omitting version_type or setting
@@ -6189,10 +6248,11 @@ public final list to queryVector.
+ */
+ public final Builder queryVector(ListqueryVector.
+ */
+ public final Builder queryVector(Float value, Float... values) {
+ this.queryVector = _listAdd(this.queryVector, value, values);
+ return this;
+ }
+
+ /**
+ * a dense vector query vector builder to use instead of a static query_vector
+ * list to routing.
+ */
+ public final Builderrouting.
*/
- public final Builderlist to retrievers.
*/
- public final Builder retrievers(Listretrievers.
*/
- public final Builder retrievers(Retriever value, Retriever... values) {
+ public final Builder retrievers(RRFRetrieverEntry value, RRFRetrieverEntry... values) {
this.retrievers = _listAdd(this.retrievers, value, values);
return this;
}
/**
* Required - A list of child retrievers to specify which sets of returned top
- * documents will have the RRF formula applied to them.
- * retrievers.
- */
- public final Builder retrievers(RetrieverVariant value, RetrieverVariant... values) {
- this.retrievers = _listAdd(this.retrievers, value._toRetriever());
- for (RetrieverVariant v : values) {
- _listAdd(this.retrievers, v._toRetriever());
- }
- return this;
- }
-
- /**
- * Required - A list of child retrievers to specify which sets of returned top
- * documents will have the RRF formula applied to them.
+ * documents will have the RRF formula applied to them. Each retriever can
+ * optionally include a weight parameter.
* retrievers using a builder lambda.
*/
- public final Builder retrievers(Functiongeo_line aggregation is nested inside a
+ * The name of the numeric field to use as the sort key for ordering the points.
+ * When the geo_line aggregation is nested inside a
* time_series aggregation, this field defaults to
* @timestamp, and any other value will result in error.
* geo_line aggregation is nested inside a
* time_series aggregation, this field defaults to
* @timestamp, and any other value will result in error.
* geo_line aggregation is nested inside a
+ * The name of the numeric field to use as the sort key for ordering the points.
+ * When the geo_line aggregation is nested inside a
* time_series aggregation, this field defaults to
* @timestamp, and any other value will result in error.
* true if vector rescoring should be done on-disk
* bbq_hnsw
+ * Only applicable to bbq_disk, bbq_hnsw,
+ * int4_hnsw, int8_hnsw
* true if vector rescoring should be done on-disk
* bbq_hnsw
+ * Only applicable to bbq_disk, bbq_hnsw,
+ * int4_hnsw, int8_hnsw
*