Skip to content

Commit 37ccc8e

Browse files
committed
Fixed PrimaryTerm/SeqNo datatypes in UpdateQuery
1 parent 55d470f commit 37ccc8e

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

src/main/java/org/springframework/data/elasticsearch/core/query/UpdateQuery.java

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -42,8 +42,8 @@ public class UpdateQuery {
4242
@Nullable private final Boolean fetchSource;
4343
@Nullable private final List<String> fetchSourceIncludes;
4444
@Nullable private final List<String> fetchSourceExcludes;
45-
@Nullable private final Integer ifSeqNo;
46-
@Nullable private final Integer ifPrimaryTerm;
45+
@Nullable private final Long ifSeqNo;
46+
@Nullable private final Long ifPrimaryTerm;
4747
@Nullable private final RefreshPolicy refreshPolicy;
4848
@Nullable private final Integer retryOnConflict;
4949
@Nullable private final String timeout;
@@ -71,8 +71,8 @@ public static Builder builder(Query query) {
7171
private UpdateQuery(String id, @Nullable String script, @Nullable Map<String, Object> params,
7272
@Nullable Document document, @Nullable Document upsert, @Nullable String lang, @Nullable String routing,
7373
@Nullable Boolean scriptedUpsert, @Nullable Boolean docAsUpsert, @Nullable Boolean fetchSource,
74-
@Nullable List<String> fetchSourceIncludes, @Nullable List<String> fetchSourceExcludes, @Nullable Integer ifSeqNo,
75-
@Nullable Integer ifPrimaryTerm, @Nullable RefreshPolicy refreshPolicy, @Nullable Integer retryOnConflict,
74+
@Nullable List<String> fetchSourceIncludes, @Nullable List<String> fetchSourceExcludes, @Nullable Long ifSeqNo,
75+
@Nullable Long ifPrimaryTerm, @Nullable RefreshPolicy refreshPolicy, @Nullable Integer retryOnConflict,
7676
@Nullable String timeout, @Nullable String waitForActiveShards, @Nullable Query query,
7777
@Nullable Boolean abortOnVersionConflict, @Nullable Integer batchSize, @Nullable Integer maxDocs,
7878
@Nullable Integer maxRetries, @Nullable String pipeline, @Nullable Float requestsPerSecond,
@@ -172,12 +172,12 @@ public List<String> getFetchSourceExcludes() {
172172
}
173173

174174
@Nullable
175-
public Integer getIfSeqNo() {
175+
public Long getIfSeqNo() {
176176
return ifSeqNo;
177177
}
178178

179179
@Nullable
180-
public Integer getIfPrimaryTerm() {
180+
public Long getIfPrimaryTerm() {
181181
return ifPrimaryTerm;
182182
}
183183

@@ -278,8 +278,8 @@ public static final class Builder {
278278
@Nullable private Boolean scriptedUpsert;
279279
@Nullable private Boolean docAsUpsert;
280280
@Nullable private Boolean fetchSource;
281-
@Nullable private Integer ifSeqNo;
282-
@Nullable private Integer ifPrimaryTerm;
281+
@Nullable private Long ifSeqNo;
282+
@Nullable private Long ifPrimaryTerm;
283283
@Nullable private RefreshPolicy refreshPolicy;
284284
@Nullable private Integer retryOnConflict;
285285
@Nullable private String timeout;
@@ -351,12 +351,12 @@ public Builder withFetchSource(Boolean fetchSource) {
351351
return this;
352352
}
353353

354-
public Builder withIfSeqNo(Integer ifSeqNo) {
354+
public Builder withIfSeqNo(Long ifSeqNo) {
355355
this.ifSeqNo = ifSeqNo;
356356
return this;
357357
}
358358

359-
public Builder withIfPrimaryTerm(Integer ifPrimaryTerm) {
359+
public Builder withIfPrimaryTerm(Long ifPrimaryTerm) {
360360
this.ifPrimaryTerm = ifPrimaryTerm;
361361
return this;
362362
}

0 commit comments

Comments
 (0)