Skip to content

Commit c869daf

Browse files
committed
[codegen] Update to latest API specification
1 parent ca0c0b0 commit c869daf

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

42 files changed

+3030
-3629
lines changed

java-client/src/main/java/co/elastic/clients/elasticsearch/_types/EmptyTransform.java

Lines changed: 0 additions & 65 deletions
This file was deleted.

java-client/src/main/java/co/elastic/clients/elasticsearch/_types/SortOptions.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -288,10 +288,9 @@ public SortOptions build() {
288288
}
289289

290290
public static final JsonpDeserializer<SortOptions> _DESERIALIZER = JsonpDeserializer.lazy(() -> JsonpDeserializer
291-
.of(EnumSet.of(JsonParser.Event.START_OBJECT, JsonParser.Event.VALUE_STRING), (parser, mapper) -> {
291+
.of(EnumSet.of(JsonParser.Event.START_OBJECT, JsonParser.Event.VALUE_STRING), (parser, mapper, event) -> {
292292
SortOptions.Builder b = new SortOptions.Builder();
293293

294-
JsonParser.Event event = parser.next();
295294
if (event == JsonParser.Event.VALUE_STRING) {
296295
switch (parser.getString()) {
297296
case "_score" :

java-client/src/main/java/co/elastic/clients/elasticsearch/_types/Transform.java

Lines changed: 16 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737
import co.elastic.clients.util.TaggedUnionUtils;
3838
import jakarta.json.stream.JsonGenerator;
3939
import java.lang.Object;
40+
import java.util.List;
4041
import java.util.Objects;
4142
import java.util.function.Function;
4243
import javax.annotation.Nullable;
@@ -126,7 +127,7 @@ public boolean isChain() {
126127
* @throws IllegalStateException
127128
* if the current variant is not of the {@code chain} kind.
128129
*/
129-
public ChainTransform chain() {
130+
public List<Transform> chain() {
130131
return TaggedUnionUtils.get(this, Kind.Chain);
131132
}
132133

@@ -173,6 +174,18 @@ public void serialize(JsonGenerator generator, JsonpMapper mapper) {
173174
generator.writeKey(_kind.jsonValue());
174175
if (_value instanceof JsonpSerializable) {
175176
((JsonpSerializable) _value).serialize(generator, mapper);
177+
} else {
178+
switch (_kind) {
179+
case Chain :
180+
generator.writeStartArray();
181+
for (Transform item0 : ((List<Transform>) this._value)) {
182+
item0.serialize(generator, mapper);
183+
184+
}
185+
generator.writeEnd();
186+
187+
break;
188+
}
176189
}
177190

178191
generator.writeEnd();
@@ -183,16 +196,12 @@ public static class Builder extends ObjectBuilderBase implements ObjectBuilder<T
183196
private Kind _kind;
184197
private Object _value;
185198

186-
public ObjectBuilder<Transform> chain(ChainTransform v) {
199+
public ObjectBuilder<Transform> chain(List<Transform> v) {
187200
this._kind = Kind.Chain;
188201
this._value = v;
189202
return this;
190203
}
191204

192-
public ObjectBuilder<Transform> chain(Function<ChainTransform.Builder, ObjectBuilder<ChainTransform>> fn) {
193-
return this.chain(fn.apply(new ChainTransform.Builder()).build());
194-
}
195-
196205
public ObjectBuilder<Transform> script(ScriptTransform v) {
197206
this._kind = Kind.Script;
198207
this._value = v;
@@ -222,7 +231,7 @@ public Transform build() {
222231

223232
protected static void setupTransformDeserializer(ObjectDeserializer<Builder> op) {
224233

225-
op.add(Builder::chain, ChainTransform._DESERIALIZER, "chain");
234+
op.add(Builder::chain, JsonpDeserializer.arrayDeserializer(Transform._DESERIALIZER), "chain");
226235
op.add(Builder::script, ScriptTransform._DESERIALIZER, "script");
227236
op.add(Builder::search, SearchTransform._DESERIALIZER, "search");
228237

java-client/src/main/java/co/elastic/clients/elasticsearch/_types/TransformBuilders.java

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -25,19 +25,15 @@
2525

2626
/**
2727
* Builders for {@link Transform} variants.
28+
* <p>
29+
* Variants <code>chain</code> are not available here as they don't have a
30+
* dedicated class. Use {@link Transform}'s builder for these.
31+
*
2832
*/
2933
public class TransformBuilders {
3034
private TransformBuilders() {
3135
}
3236

33-
/**
34-
* Creates a builder for the {@link ChainTransform chain} {@code Transform}
35-
* variant.
36-
*/
37-
public static ChainTransform.Builder chain() {
38-
return new ChainTransform.Builder();
39-
}
40-
4137
/**
4238
* Creates a builder for the {@link ScriptTransform script} {@code Transform}
4339
* variant.

java-client/src/main/java/co/elastic/clients/elasticsearch/_types/aggregations/ChildrenAggregateBucket.java

Lines changed: 0 additions & 97 deletions
This file was deleted.

java-client/src/main/java/co/elastic/clients/elasticsearch/_types/aggregations/RangeBucket.java

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,9 @@ public class RangeBucket extends MultiBucketBase {
5858
@Nullable
5959
private final String toAsString;
6060

61+
@Nullable
62+
private final String key;
63+
6164
// ---------------------------------------------------------------------------------------------
6265

6366
private RangeBucket(Builder builder) {
@@ -67,6 +70,7 @@ private RangeBucket(Builder builder) {
6770
this.to = builder.to;
6871
this.fromAsString = builder.fromAsString;
6972
this.toAsString = builder.toAsString;
73+
this.key = builder.key;
7074

7175
}
7276

@@ -106,6 +110,16 @@ public final String toAsString() {
106110
return this.toAsString;
107111
}
108112

113+
/**
114+
* The bucket key. Present if the aggregation is <em>not</em> keyed
115+
* <p>
116+
* API name: {@code key}
117+
*/
118+
@Nullable
119+
public final String key() {
120+
return this.key;
121+
}
122+
109123
protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
110124

111125
super.serializeInternal(generator, mapper);
@@ -129,6 +143,11 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
129143
generator.write(this.toAsString);
130144

131145
}
146+
if (this.key != null) {
147+
generator.writeKey("key");
148+
generator.write(this.key);
149+
150+
}
132151

133152
}
134153

@@ -151,6 +170,9 @@ public static class Builder extends MultiBucketBase.AbstractBuilder<Builder> imp
151170
@Nullable
152171
private String toAsString;
153172

173+
@Nullable
174+
private String key;
175+
154176
/**
155177
* API name: {@code from}
156178
*/
@@ -183,6 +205,16 @@ public final Builder toAsString(@Nullable String value) {
183205
return this;
184206
}
185207

208+
/**
209+
* The bucket key. Present if the aggregation is <em>not</em> keyed
210+
* <p>
211+
* API name: {@code key}
212+
*/
213+
public final Builder key(@Nullable String value) {
214+
this.key = value;
215+
return this;
216+
}
217+
186218
@Override
187219
protected Builder self() {
188220
return this;
@@ -215,6 +247,7 @@ protected static void setupRangeBucketDeserializer(ObjectDeserializer<RangeBucke
215247
op.add(Builder::to, JsonpDeserializer.doubleDeserializer(), "to");
216248
op.add(Builder::fromAsString, JsonpDeserializer.stringDeserializer(), "from_as_string");
217249
op.add(Builder::toAsString, JsonpDeserializer.stringDeserializer(), "to_as_string");
250+
op.add(Builder::key, JsonpDeserializer.stringDeserializer(), "key");
218251

219252
}
220253

java-client/src/main/java/co/elastic/clients/elasticsearch/_types/query_dsl/SpanGapQuery.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -104,8 +104,7 @@ public SpanGapQuery build() {
104104
* Json deserializer for {@link SpanGapQuery}
105105
*/
106106
public static final JsonpDeserializer<SpanGapQuery> _DESERIALIZER = JsonpDeserializer
107-
.of(EnumSet.of(JsonParser.Event.START_OBJECT), (parser, mapper) -> {
108-
JsonpUtils.expectNextEvent(parser, JsonParser.Event.START_OBJECT);
107+
.of(EnumSet.of(JsonParser.Event.START_OBJECT), (parser, mapper, event) -> {
109108
String name = JsonpUtils.expectKeyName(parser, parser.next());
110109

111110
JsonpUtils.expectNextEvent(parser, JsonParser.Event.VALUE_NUMBER);

java-client/src/main/java/co/elastic/clients/elasticsearch/async_search/AsyncSearch.java

Lines changed: 3 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -297,20 +297,7 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
297297

298298
if (ApiTypeHelper.isDefined(this.suggest)) {
299299
generator.writeKey("suggest");
300-
generator.writeStartObject();
301-
for (Map.Entry<String, List<Suggestion<TDocument>>> item0 : this.suggest.entrySet()) {
302-
generator.writeKey(item0.getKey());
303-
generator.writeStartArray();
304-
if (item0.getValue() != null) {
305-
for (Suggestion<TDocument> item1 : item0.getValue()) {
306-
item1.serialize(generator, mapper);
307-
308-
}
309-
}
310-
generator.writeEnd();
311-
312-
}
313-
generator.writeEnd();
300+
ExternallyTaggedUnion.serializeTypedKeysArray(this.suggest, generator, mapper);
314301

315302
}
316303
if (this.terminatedEarly != null) {
@@ -608,9 +595,8 @@ protected static <TDocument> void setupAsyncSearchDeserializer(
608595
op.add(Builder::pitId, JsonpDeserializer.stringDeserializer(), "pit_id");
609596
op.add(Builder::scrollId, JsonpDeserializer.stringDeserializer(), "_scroll_id");
610597
op.add(Builder::shards, ShardStatistics._DESERIALIZER, "_shards");
611-
op.add(Builder::suggest, JsonpDeserializer.stringMapDeserializer(
612-
JsonpDeserializer.arrayDeserializer(Suggestion.createSuggestionDeserializer(tDocumentDeserializer))),
613-
"suggest");
598+
op.add(Builder::suggest, ExternallyTaggedUnion.<Suggestion<TDocument>>arrayMapDeserializer(
599+
Suggestion.createSuggestionDeserializer(tDocumentDeserializer)), "suggest");
614600
op.add(Builder::terminatedEarly, JsonpDeserializer.booleanDeserializer(), "terminated_early");
615601
op.add(Builder::timedOut, JsonpDeserializer.booleanDeserializer(), "timed_out");
616602
op.add(Builder::took, JsonpDeserializer.longDeserializer(), "took");

0 commit comments

Comments
 (0)