refactor: rename updateIndexMapping in rest client

Signed-off-by: Sean Kao <[email protected]>
opensearch-project · Mar 23, 2024 · 05ebd93 · 05ebd93
1 parent 7b8bb94
commit 05ebd93
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/flint-core/src/main/java/org/opensearch/flint/core/IRestHighLevelClient.java b/flint-core/src/main/java/org/opensearch/flint/core/IRestHighLevelClient.java
@@ -45,7 +45,7 @@ public interface IRestHighLevelClient extends Closeable {
 
     CreateIndexResponse createIndex(CreateIndexRequest createIndexRequest, RequestOptions options) throws IOException;
 
-    void updateIndex(PutMappingRequest putMappingRequest, RequestOptions options) throws IOException;
+    void updateIndexMapping(PutMappingRequest putMappingRequest, RequestOptions options) throws IOException;
 
     void deleteIndex(DeleteIndexRequest deleteIndexRequest, RequestOptions options) throws IOException;
 

diff --git a/flint-core/src/main/java/org/opensearch/flint/core/RestHighLevelClientWrapper.java b/flint-core/src/main/java/org/opensearch/flint/core/RestHighLevelClientWrapper.java
@@ -65,7 +65,7 @@ public CreateIndexResponse createIndex(CreateIndexRequest createIndexRequest, Re
     }
 
     @Override
-    public void updateIndex(PutMappingRequest putMappingRequest, RequestOptions options) throws IOException {
+    public void updateIndexMapping(PutMappingRequest putMappingRequest, RequestOptions options) throws IOException {
         execute(OS_WRITE_OP_METRIC_PREFIX, () -> client.indices().putMapping(putMappingRequest, options));
     }
 

diff --git a/flint-core/src/main/scala/org/opensearch/flint/core/storage/FlintOpenSearchClient.java b/flint-core/src/main/scala/org/opensearch/flint/core/storage/FlintOpenSearchClient.java
@@ -199,7 +199,7 @@ public void updateIndex(String indexName, FlintMetadata metadata) {
     try (IRestHighLevelClient client = createClient()) {
       PutMappingRequest request = new PutMappingRequest(osIndexName);
       request.source(metadata.getContent(), XContentType.JSON);
-      client.updateIndex(request, RequestOptions.DEFAULT);
+      client.updateIndexMapping(request, RequestOptions.DEFAULT);
     } catch (Exception e) {
       throw new IllegalStateException("Failed to update Flint index " + osIndexName, e);
     }