Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@
import co.elastic.clients.json.JsonpUtils;
import co.elastic.clients.json.ObjectBuilderDeserializer;
import co.elastic.clients.json.ObjectDeserializer;
import co.elastic.clients.util.ApiTypeHelper;
import co.elastic.clients.util.ObjectBuilder;
import co.elastic.clients.util.WithJsonObjectBuilderBase;
import jakarta.json.stream.JsonGenerator;
Expand Down Expand Up @@ -60,6 +59,7 @@
*/
@JsonpDeserializable
public class KuromojiAnalyzer implements AnalyzerVariant, JsonpSerializable {
@Nullable
private final KuromojiTokenizationMode mode;

@Nullable
Expand All @@ -69,7 +69,7 @@ public class KuromojiAnalyzer implements AnalyzerVariant, JsonpSerializable {

private KuromojiAnalyzer(Builder builder) {

this.mode = ApiTypeHelper.requireNonNull(builder.mode, this, "mode");
this.mode = builder.mode;
this.userDictionary = builder.userDictionary;

}
Expand All @@ -87,8 +87,9 @@ public Analyzer.Kind _analyzerKind() {
}

/**
* Required - API name: {@code mode}
* API name: {@code mode}
*/
@Nullable
public final KuromojiTokenizationMode mode() {
return this.mode;
}
Expand All @@ -114,8 +115,10 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {

generator.write("type", "kuromoji");

generator.writeKey("mode");
this.mode.serialize(generator, mapper);
if (this.mode != null) {
generator.writeKey("mode");
this.mode.serialize(generator, mapper);
}
if (this.userDictionary != null) {
generator.writeKey("user_dictionary");
generator.write(this.userDictionary);
Expand All @@ -136,15 +139,16 @@ public String toString() {
*/

public static class Builder extends WithJsonObjectBuilderBase<Builder> implements ObjectBuilder<KuromojiAnalyzer> {
@Nullable
private KuromojiTokenizationMode mode;

@Nullable
private String userDictionary;

/**
* Required - API name: {@code mode}
* API name: {@code mode}
*/
public final Builder mode(KuromojiTokenizationMode value) {
public final Builder mode(@Nullable KuromojiTokenizationMode value) {
this.mode = value;
return this;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3082,10 +3082,10 @@
'transform._types.PivotGroupByContainer': 'transform/_types/Transform.ts#L70-L78',
'transform._types.RetentionPolicy': 'transform/_types/Transform.ts#L88-L96',
'transform._types.RetentionPolicyContainer': 'transform/_types/Transform.ts#L80-L86',
'transform._types.Settings': 'transform/_types/Transform.ts#L98-L144',
'transform._types.Source': 'transform/_types/Transform.ts#L146-L165',
'transform._types.SyncContainer': 'transform/_types/Transform.ts#L169-L175',
'transform._types.TimeSync': 'transform/_types/Transform.ts#L177-L189',
'transform._types.Settings': 'transform/_types/Transform.ts#L98-L154',
'transform._types.Source': 'transform/_types/Transform.ts#L156-L175',
'transform._types.SyncContainer': 'transform/_types/Transform.ts#L179-L185',
'transform._types.TimeSync': 'transform/_types/Transform.ts#L187-L199',
'transform.delete_transform.Request': 'transform/delete_transform/DeleteTransformRequest.ts#L24-L64',
'transform.delete_transform.Response': 'transform/delete_transform/DeleteTransformResponse.ts#L22-L25',
'transform.get_transform.Request': 'transform/get_transform/GetTransformRequest.ts#L24-L84',
Expand Down Expand Up @@ -3322,10 +3322,10 @@
if (hash.length > 1) {
hash = hash.substring(1);
}
window.location = "https://github.com/elastic/elasticsearch-specification/tree/32e19181074f337369c123c1b7e9518f71b8bb6b/specification/" + (paths[hash] || "");
window.location = "https://github.com/elastic/elasticsearch-specification/tree/d4d8c79c221bc01acf5f802bc5c41632dcf6cde9/specification/" + (paths[hash] || "");
</script>
</head>
<body>
Please see the <a href="https://github.com/elastic/elasticsearch-specification/tree/32e19181074f337369c123c1b7e9518f71b8bb6b/specification/">Elasticsearch API specification</a>.
Please see the <a href="https://github.com/elastic/elasticsearch-specification/tree/d4d8c79c221bc01acf5f802bc5c41632dcf6cde9/specification/">Elasticsearch API specification</a>.
</body>
</html>
Original file line number Diff line number Diff line change
Expand Up @@ -76,6 +76,9 @@ public class Settings implements JsonpSerializable {
@Nullable
private final Integer maxPageSearchSize;

@Nullable
private final Boolean usePointInTime;

@Nullable
private final Boolean unattended;

Expand All @@ -88,6 +91,7 @@ private Settings(Builder builder) {
this.deduceMappings = builder.deduceMappings;
this.docsPerSecond = builder.docsPerSecond;
this.maxPageSearchSize = builder.maxPageSearchSize;
this.usePointInTime = builder.usePointInTime;
this.unattended = builder.unattended;

}
Expand Down Expand Up @@ -159,6 +163,22 @@ public final Integer maxPageSearchSize() {
return this.maxPageSearchSize;
}

/**
* Specifies whether the transform checkpoint will use the Point In Time API
* while searching over the source index. In general, Point In Time is an
* optimization that will reduce pressure on the source index by reducing the
* amount of refreshes and merges, but it can be expensive if a large number of
* Point In Times are opened and closed for a given index. The benefits and
* impact depend on the data being searched, the ingest rate into the source
* index, and the amount of other consumers searching the same source index.
* <p>
* API name: {@code use_point_in_time}
*/
@Nullable
public final Boolean usePointInTime() {
return this.usePointInTime;
}

/**
* If <code>true</code>, the transform runs in unattended mode. In unattended
* mode, the transform retries indefinitely in case of an error which means the
Expand Down Expand Up @@ -207,6 +227,11 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
generator.writeKey("max_page_search_size");
generator.write(this.maxPageSearchSize);

}
if (this.usePointInTime != null) {
generator.writeKey("use_point_in_time");
generator.write(this.usePointInTime);

}
if (this.unattended != null) {
generator.writeKey("unattended");
Expand Down Expand Up @@ -243,6 +268,9 @@ public static class Builder extends WithJsonObjectBuilderBase<Builder> implement
@Nullable
private Integer maxPageSearchSize;

@Nullable
private Boolean usePointInTime;

@Nullable
private Boolean unattended;

Expand Down Expand Up @@ -309,6 +337,22 @@ public final Builder maxPageSearchSize(@Nullable Integer value) {
return this;
}

/**
* Specifies whether the transform checkpoint will use the Point In Time API
* while searching over the source index. In general, Point In Time is an
* optimization that will reduce pressure on the source index by reducing the
* amount of refreshes and merges, but it can be expensive if a large number of
* Point In Times are opened and closed for a given index. The benefits and
* impact depend on the data being searched, the ingest rate into the source
* index, and the amount of other consumers searching the same source index.
* <p>
* API name: {@code use_point_in_time}
*/
public final Builder usePointInTime(@Nullable Boolean value) {
this.usePointInTime = value;
return this;
}

/**
* If <code>true</code>, the transform runs in unattended mode. In unattended
* mode, the transform retries indefinitely in case of an error which means the
Expand Down Expand Up @@ -355,6 +399,7 @@ protected static void setupSettingsDeserializer(ObjectDeserializer<Settings.Buil
op.add(Builder::deduceMappings, JsonpDeserializer.booleanDeserializer(), "deduce_mappings");
op.add(Builder::docsPerSecond, JsonpDeserializer.floatDeserializer(), "docs_per_second");
op.add(Builder::maxPageSearchSize, JsonpDeserializer.integerDeserializer(), "max_page_search_size");
op.add(Builder::usePointInTime, JsonpDeserializer.booleanDeserializer(), "use_point_in_time");
op.add(Builder::unattended, JsonpDeserializer.booleanDeserializer(), "unattended");

}
Expand Down