Skip to content

Commit 31a42ce

Browse files
committed
Add reactive support for GetFieldMapping request - Fix PR
1 parent ad52127 commit 31a42ce

File tree

3 files changed

+4
-5
lines changed

3 files changed

+4
-5
lines changed

src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -678,7 +678,7 @@ public Mono<GetMappingsResponse> getMapping(HttpHeaders headers, GetMappingsRequ
678678
}
679679

680680
@Override
681-
public Mono<GetFieldMappingsResponse> getFieldMapping(final HttpHeaders headers, final GetFieldMappingsRequest getFieldMappingsRequest) {
681+
public Mono<GetFieldMappingsResponse> getFieldMapping(HttpHeaders headers, GetFieldMappingsRequest getFieldMappingsRequest) {
682682
return sendRequest(getFieldMappingsRequest, requestCreator.getFieldMapping(), GetFieldMappingsResponse.class, headers).next();
683683
}
684684

src/main/java/org/springframework/data/elasticsearch/client/util/RequestConverters.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -907,7 +907,6 @@ public static Request getFieldMapping(GetFieldMappingsRequest getFieldMappingsRe
907907
RequestConverters.Params parameters = new Params(request);
908908
parameters.withIndicesOptions(getFieldMappingsRequest.indicesOptions());
909909
parameters.withIncludeDefaults(getFieldMappingsRequest.includeDefaults());
910-
parameters.withLocal(getFieldMappingsRequest.local());
911910
parameters.withIncludeTypeName(false);
912911
return request;
913912
}

src/test/java/org/springframework/data/elasticsearch/client/reactive/ReactiveElasticsearchClientIntegrationTests.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -724,7 +724,7 @@ public void suggestReturnsSuggestionResults() {
724724
.verifyComplete();
725725
}
726726

727-
@Test // Issue #1640
727+
@Test // #1640
728728
void getFieldMapping() {
729729

730730
operations.indexOps(IndexCoordinates.of(INDEX_I)).create().block();
@@ -750,7 +750,7 @@ void getFieldMapping() {
750750
.verifyComplete();
751751
}
752752

753-
@Test // Issue #1640
753+
@Test // #1640
754754
void getFieldMappingNonExistingField() {
755755

756756
operations.indexOps(IndexCoordinates.of(INDEX_I)).create().block();
@@ -771,7 +771,7 @@ void getFieldMappingNonExistingField() {
771771
.verifyComplete();
772772
}
773773

774-
@Test // Issue #1640
774+
@Test // #1640
775775
void getFieldMappingNonExistingIndex() {
776776

777777
client.indices().getFieldMapping(request -> request.indices(INDEX_I).fields("message1"))

0 commit comments

Comments
 (0)