Skip to content

Commit ebc0792

Browse files
zane-neopeterzhuamazonrithin-pullela-aws
authored
Fix test failure after lucene upgrade to 10 (opensearch-project#3426)
* Fix test failure after lucene upgrade to 10 Signed-off-by: zane-neo <zaniu@amazon.com> * Fix test failure after lucene upgrade to 10 Signed-off-by: zane-neo <zaniu@amazon.com> * Fix test failure after lucene version upgraded to 10 Signed-off-by: zane-neo <zaniu@amazon.com> * Change version to opensearch version alpha1 Signed-off-by: zane-neo <zaniu@amazon.com> * Update build.gradle to use alpha1 version correctly Signed-off-by: Peter Zhu <zhujiaxi@amazon.com> * Fix test failure after lucene upgrade to 10 Signed-off-by: zane-neo <zaniu@amazon.com> * Fix test failure after lucene upgrade to 10 Signed-off-by: zane-neo <zaniu@amazon.com> * Fix test failure after lucene version upgraded to 10 Signed-off-by: zane-neo <zaniu@amazon.com> * Change version to opensearch version alpha1 Signed-off-by: zane-neo <zaniu@amazon.com> * Fix compilation failure due to opensearch core change Signed-off-by: zane-neo <zaniu@amazon.com> * fix conflicts Signed-off-by: zane-neo <zaniu@amazon.com> * fix conflicts Signed-off-by: zane-neo <zaniu@amazon.com> * format code Signed-off-by: zane-neo <zaniu@amazon.com> * Update more version Signed-off-by: Peter Zhu <zhujiaxi@amazon.com> * Fix compilation error Signed-off-by: zane-neo <zaniu@amazon.com> * Added test to cover getNumberOfDocumentsInIndex with 4 arguments Signed-off-by: rithin-pullela-aws <rithinp@amazon.com> --------- Signed-off-by: zane-neo <zaniu@amazon.com> Signed-off-by: Peter Zhu <zhujiaxi@amazon.com> Signed-off-by: rithin-pullela-aws <rithinp@amazon.com> Co-authored-by: Peter Zhu <zhujiaxi@amazon.com> Co-authored-by: rithin-pullela-aws <rithinp@amazon.com>
1 parent d224d7a commit ebc0792

File tree

341 files changed

+434
-403
lines changed

Some content is hidden

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

341 files changed

+434
-403
lines changed

‎build.gradle

+3-3
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,8 @@ buildscript {
1111
ext {
1212
opensearch_group = "org.opensearch"
1313
isSnapshot = "true" == System.getProperty("build.snapshot", "true")
14-
opensearch_version = System.getProperty("opensearch.version", "3.0.0-SNAPSHOT")
15-
buildVersionQualifier = System.getProperty("build.version_qualifier", "")
14+
opensearch_version = System.getProperty("opensearch.version", "3.0.0-alpha1-SNAPSHOT")
15+
buildVersionQualifier = System.getProperty("build.version_qualifier", "alpha1")
1616
asm_version = "9.7"
1717

1818
// 2.0.0-rc1-SNAPSHOT -> 2.0.0.0-rc1-SNAPSHOT
@@ -79,7 +79,7 @@ allprojects {
7979
}
8080

8181
plugins.withId('jacoco') {
82-
jacoco.toolVersion = '0.8.10'
82+
jacoco.toolVersion = '0.8.12'
8383
}
8484

8585
project.getExtensions().getExtraProperties().set("versions", VersionProperties.getVersions());

‎client/src/main/java/org/opensearch/ml/client/MachineLearningNodeClient.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
import org.opensearch.action.delete.DeleteResponse;
2222
import org.opensearch.action.search.SearchRequest;
2323
import org.opensearch.action.search.SearchResponse;
24-
import org.opensearch.client.Client;
2524
import org.opensearch.core.action.ActionListener;
2625
import org.opensearch.core.action.ActionResponse;
2726
import org.opensearch.ml.common.FunctionName;
@@ -89,6 +88,7 @@
8988
import org.opensearch.ml.common.transport.undeploy.MLUndeployModelsAction;
9089
import org.opensearch.ml.common.transport.undeploy.MLUndeployModelsRequest;
9190
import org.opensearch.ml.common.transport.undeploy.MLUndeployModelsResponse;
91+
import org.opensearch.transport.client.Client;
9292

9393
import lombok.AccessLevel;
9494
import lombok.RequiredArgsConstructor;

‎client/src/test/java/org/opensearch/ml/client/MachineLearningNodeClientTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,6 @@
4848
import org.opensearch.action.search.SearchRequest;
4949
import org.opensearch.action.search.SearchResponse;
5050
import org.opensearch.action.search.ShardSearchFailure;
51-
import org.opensearch.client.node.NodeClient;
5251
import org.opensearch.cluster.ClusterName;
5352
import org.opensearch.common.xcontent.XContentFactory;
5453
import org.opensearch.core.action.ActionListener;
@@ -147,6 +146,7 @@
147146
import org.opensearch.search.internal.InternalSearchResponse;
148147
import org.opensearch.search.profile.SearchProfileShardResults;
149148
import org.opensearch.search.suggest.Suggest;
149+
import org.opensearch.transport.client.node.NodeClient;
150150

151151
public class MachineLearningNodeClientTest {
152152

@@ -909,7 +909,7 @@ public void searchTask() {
909909

910910
verify(client).execute(eq(MLTaskSearchAction.INSTANCE), isA(SearchRequest.class), any());
911911
verify(searchTaskActionListener).onResponse(argumentCaptor.capture());
912-
assertEquals(1, argumentCaptor.getValue().getHits().getTotalHits().value);
912+
assertEquals(1, argumentCaptor.getValue().getHits().getTotalHits().value());
913913
Map<String, Object> source = argumentCaptor.getValue().getHits().getAt(0).getSourceAsMap();
914914
assertEquals(taskId, source.get(MLTask.TASK_ID_FIELD));
915915
assertEquals(modelId, source.get(MLTask.MODEL_ID_FIELD));

‎common/src/main/java/org/opensearch/ml/common/model/Guardrail.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,10 +8,10 @@
88
import java.io.IOException;
99
import java.util.Map;
1010

11-
import org.opensearch.client.Client;
1211
import org.opensearch.core.common.io.stream.StreamOutput;
1312
import org.opensearch.core.xcontent.NamedXContentRegistry;
1413
import org.opensearch.core.xcontent.ToXContentObject;
14+
import org.opensearch.transport.client.Client;
1515

1616
public abstract class Guardrail implements ToXContentObject {
1717

‎common/src/main/java/org/opensearch/ml/common/model/LocalRegexGuardrail.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@
2727
import org.opensearch.action.LatchedActionListener;
2828
import org.opensearch.action.search.SearchRequest;
2929
import org.opensearch.action.search.SearchResponse;
30-
import org.opensearch.client.Client;
3130
import org.opensearch.common.util.concurrent.ThreadContext;
3231
import org.opensearch.common.xcontent.LoggingDeprecationHandler;
3332
import org.opensearch.common.xcontent.XContentType;
@@ -38,6 +37,7 @@
3837
import org.opensearch.core.xcontent.XContentBuilder;
3938
import org.opensearch.core.xcontent.XContentParser;
4039
import org.opensearch.search.builder.SearchSourceBuilder;
40+
import org.opensearch.transport.client.Client;
4141

4242
import lombok.Builder;
4343
import lombok.EqualsAndHashCode;
@@ -235,7 +235,7 @@ public Boolean validateStopWordsSingleIndex(String input, String indexName, List
235235
context = client.threadPool().getThreadContext().stashContext();
236236
ThreadContext.StoredContext finalContext = context;
237237
client.search(searchRequest, ActionListener.runBefore(new LatchedActionListener(ActionListener.<SearchResponse>wrap(r -> {
238-
if (r == null || r.getHits() == null || r.getHits().getTotalHits() == null || r.getHits().getTotalHits().value == 0) {
238+
if (r == null || r.getHits() == null || r.getHits().getTotalHits() == null || r.getHits().getTotalHits().value() == 0) {
239239
hitStopWords.set(true);
240240
}
241241
}, e -> {
@@ -244,7 +244,7 @@ public Boolean validateStopWordsSingleIndex(String input, String indexName, List
244244
}), latch), () -> finalContext.restore()));
245245
} else {
246246
client.search(searchRequest, new LatchedActionListener(ActionListener.<SearchResponse>wrap(r -> {
247-
if (r == null || r.getHits() == null || r.getHits().getTotalHits() == null || r.getHits().getTotalHits().value == 0) {
247+
if (r == null || r.getHits() == null || r.getHits().getTotalHits() == null || r.getHits().getTotalHits().value() == 0) {
248248
hitStopWords.set(true);
249249
}
250250
}, e -> {

‎common/src/main/java/org/opensearch/ml/common/model/MLGuard.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,8 @@
77

88
import java.util.Map;
99

10-
import org.opensearch.client.Client;
1110
import org.opensearch.core.xcontent.NamedXContentRegistry;
11+
import org.opensearch.transport.client.Client;
1212

1313
import lombok.Getter;
1414
import lombok.extern.log4j.Log4j2;

‎common/src/main/java/org/opensearch/ml/common/model/ModelGuardrail.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222

2323
import org.opensearch.action.ActionRequest;
2424
import org.opensearch.action.LatchedActionListener;
25-
import org.opensearch.client.Client;
2625
import org.opensearch.core.action.ActionListener;
2726
import org.opensearch.core.action.ActionResponse;
2827
import org.opensearch.core.common.io.stream.StreamInput;
@@ -38,6 +37,7 @@
3837
import org.opensearch.ml.common.transport.MLTaskResponse;
3938
import org.opensearch.ml.common.transport.prediction.MLPredictionTaskAction;
4039
import org.opensearch.ml.common.transport.prediction.MLPredictionTaskRequest;
40+
import org.opensearch.transport.client.Client;
4141

4242
import lombok.Builder;
4343
import lombok.EqualsAndHashCode;

‎common/src/test/java/org/opensearch/ml/common/model/LocalRegexGuardrailTests.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
import org.mockito.MockitoAnnotations;
2424
import org.opensearch.action.search.SearchResponse;
2525
import org.opensearch.action.search.ShardSearchFailure;
26-
import org.opensearch.client.Client;
2726
import org.opensearch.common.action.ActionFuture;
2827
import org.opensearch.common.io.stream.BytesStreamOutput;
2928
import org.opensearch.common.settings.Settings;
@@ -45,6 +44,7 @@
4544
import org.opensearch.search.profile.SearchProfileShardResults;
4645
import org.opensearch.search.suggest.Suggest;
4746
import org.opensearch.threadpool.ThreadPool;
47+
import org.opensearch.transport.client.Client;
4848

4949
public class LocalRegexGuardrailTests {
5050
NamedXContentRegistry xContentRegistry;

‎common/src/test/java/org/opensearch/ml/common/model/MLGuardTests.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,12 @@
1616
import org.junit.Test;
1717
import org.mockito.Mock;
1818
import org.mockito.MockitoAnnotations;
19-
import org.opensearch.client.Client;
2019
import org.opensearch.common.settings.Settings;
2120
import org.opensearch.common.util.concurrent.ThreadContext;
2221
import org.opensearch.core.xcontent.NamedXContentRegistry;
2322
import org.opensearch.search.SearchModule;
2423
import org.opensearch.threadpool.ThreadPool;
24+
import org.opensearch.transport.client.Client;
2525

2626
public class MLGuardTests {
2727

‎common/src/test/java/org/opensearch/ml/common/model/ModelGuardrailTests.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313
import org.junit.Test;
1414
import org.mockito.Mock;
1515
import org.mockito.MockitoAnnotations;
16-
import org.opensearch.client.Client;
1716
import org.opensearch.common.io.stream.BytesStreamOutput;
1817
import org.opensearch.common.settings.Settings;
1918
import org.opensearch.common.xcontent.XContentType;
@@ -23,6 +22,7 @@
2322
import org.opensearch.core.xcontent.XContentParser;
2423
import org.opensearch.ml.common.TestHelper;
2524
import org.opensearch.search.SearchModule;
25+
import org.opensearch.transport.client.Client;
2626

2727
public class ModelGuardrailTests {
2828
NamedXContentRegistry xContentRegistry;

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/CreateConversationTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import org.opensearch.OpenSearchException;
2525
import org.opensearch.action.support.ActionFilters;
2626
import org.opensearch.action.support.HandledTransportAction;
27-
import org.opensearch.client.Client;
2827
import org.opensearch.cluster.service.ClusterService;
2928
import org.opensearch.common.inject.Inject;
3029
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -34,6 +33,7 @@
3433
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
3534
import org.opensearch.tasks.Task;
3635
import org.opensearch.transport.TransportService;
36+
import org.opensearch.transport.client.Client;
3737

3838
import lombok.extern.log4j.Log4j2;
3939

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/CreateInteractionTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@
2727
import org.opensearch.action.support.ActionFilters;
2828
import org.opensearch.action.support.HandledTransportAction;
2929
import org.opensearch.action.update.UpdateResponse;
30-
import org.opensearch.client.Client;
3130
import org.opensearch.cluster.service.ClusterService;
3231
import org.opensearch.common.inject.Inject;
3332
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -37,6 +36,7 @@
3736
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
3837
import org.opensearch.tasks.Task;
3938
import org.opensearch.transport.TransportService;
39+
import org.opensearch.transport.client.Client;
4040

4141
import lombok.extern.log4j.Log4j2;
4242

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/DeleteConversationTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import org.opensearch.OpenSearchException;
2323
import org.opensearch.action.support.ActionFilters;
2424
import org.opensearch.action.support.HandledTransportAction;
25-
import org.opensearch.client.Client;
2625
import org.opensearch.cluster.service.ClusterService;
2726
import org.opensearch.common.inject.Inject;
2827
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -32,6 +31,7 @@
3231
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
3332
import org.opensearch.tasks.Task;
3433
import org.opensearch.transport.TransportService;
34+
import org.opensearch.transport.client.Client;
3535

3636
import lombok.extern.log4j.Log4j2;
3737

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/GetConversationTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import org.opensearch.OpenSearchException;
2323
import org.opensearch.action.support.ActionFilters;
2424
import org.opensearch.action.support.HandledTransportAction;
25-
import org.opensearch.client.Client;
2625
import org.opensearch.cluster.service.ClusterService;
2726
import org.opensearch.common.inject.Inject;
2827
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -33,6 +32,7 @@
3332
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
3433
import org.opensearch.tasks.Task;
3534
import org.opensearch.transport.TransportService;
35+
import org.opensearch.transport.client.Client;
3636

3737
import lombok.extern.log4j.Log4j2;
3838

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/GetConversationsTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import org.opensearch.OpenSearchException;
2525
import org.opensearch.action.support.ActionFilters;
2626
import org.opensearch.action.support.HandledTransportAction;
27-
import org.opensearch.client.Client;
2827
import org.opensearch.cluster.service.ClusterService;
2928
import org.opensearch.common.inject.Inject;
3029
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -35,6 +34,7 @@
3534
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
3635
import org.opensearch.tasks.Task;
3736
import org.opensearch.transport.TransportService;
37+
import org.opensearch.transport.client.Client;
3838

3939
import lombok.extern.log4j.Log4j2;
4040

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/GetInteractionTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import org.opensearch.OpenSearchException;
2323
import org.opensearch.action.support.ActionFilters;
2424
import org.opensearch.action.support.HandledTransportAction;
25-
import org.opensearch.client.Client;
2625
import org.opensearch.cluster.service.ClusterService;
2726
import org.opensearch.common.inject.Inject;
2827
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -33,6 +32,7 @@
3332
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
3433
import org.opensearch.tasks.Task;
3534
import org.opensearch.transport.TransportService;
35+
import org.opensearch.transport.client.Client;
3636

3737
import lombok.extern.log4j.Log4j2;
3838

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/GetInteractionsTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import org.opensearch.OpenSearchException;
2525
import org.opensearch.action.support.ActionFilters;
2626
import org.opensearch.action.support.HandledTransportAction;
27-
import org.opensearch.client.Client;
2827
import org.opensearch.cluster.service.ClusterService;
2928
import org.opensearch.common.inject.Inject;
3029
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -35,6 +34,7 @@
3534
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
3635
import org.opensearch.tasks.Task;
3736
import org.opensearch.transport.TransportService;
37+
import org.opensearch.transport.client.Client;
3838

3939
import lombok.extern.log4j.Log4j2;
4040

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/GetTracesTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99

1010
import org.opensearch.action.support.ActionFilters;
1111
import org.opensearch.action.support.HandledTransportAction;
12-
import org.opensearch.client.Client;
1312
import org.opensearch.common.inject.Inject;
1413
import org.opensearch.common.util.concurrent.ThreadContext;
1514
import org.opensearch.core.action.ActionListener;
@@ -18,6 +17,7 @@
1817
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
1918
import org.opensearch.tasks.Task;
2019
import org.opensearch.transport.TransportService;
20+
import org.opensearch.transport.client.Client;
2121

2222
import lombok.extern.log4j.Log4j2;
2323

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/SearchConversationsTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
import org.opensearch.action.search.SearchResponse;
2424
import org.opensearch.action.support.ActionFilters;
2525
import org.opensearch.action.support.HandledTransportAction;
26-
import org.opensearch.client.Client;
2726
import org.opensearch.cluster.service.ClusterService;
2827
import org.opensearch.common.inject.Inject;
2928
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -34,6 +33,7 @@
3433
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
3534
import org.opensearch.tasks.Task;
3635
import org.opensearch.transport.TransportService;
36+
import org.opensearch.transport.client.Client;
3737

3838
import lombok.extern.log4j.Log4j2;
3939

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/SearchInteractionsTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
import org.opensearch.action.search.SearchResponse;
2424
import org.opensearch.action.support.ActionFilters;
2525
import org.opensearch.action.support.HandledTransportAction;
26-
import org.opensearch.client.Client;
2726
import org.opensearch.cluster.service.ClusterService;
2827
import org.opensearch.common.inject.Inject;
2928
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -33,6 +32,7 @@
3332
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
3433
import org.opensearch.tasks.Task;
3534
import org.opensearch.transport.TransportService;
35+
import org.opensearch.transport.client.Client;
3636

3737
import lombok.extern.log4j.Log4j2;
3838

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/UpdateConversationTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
import org.opensearch.action.support.ActionFilters;
1717
import org.opensearch.action.support.HandledTransportAction;
1818
import org.opensearch.action.update.UpdateResponse;
19-
import org.opensearch.client.Client;
2019
import org.opensearch.cluster.service.ClusterService;
2120
import org.opensearch.common.inject.Inject;
2221
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -26,6 +25,7 @@
2625
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
2726
import org.opensearch.tasks.Task;
2827
import org.opensearch.transport.TransportService;
28+
import org.opensearch.transport.client.Client;
2929

3030
import lombok.extern.log4j.Log4j2;
3131

‎memory/src/main/java/org/opensearch/ml/memory/action/conversation/UpdateInteractionTransportAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@
1515
import org.opensearch.action.support.ActionFilters;
1616
import org.opensearch.action.support.HandledTransportAction;
1717
import org.opensearch.action.update.UpdateResponse;
18-
import org.opensearch.client.Client;
1918
import org.opensearch.cluster.service.ClusterService;
2019
import org.opensearch.common.inject.Inject;
2120
import org.opensearch.common.util.concurrent.ThreadContext;
@@ -25,6 +24,7 @@
2524
import org.opensearch.ml.memory.index.OpenSearchConversationalMemoryHandler;
2625
import org.opensearch.tasks.Task;
2726
import org.opensearch.transport.TransportService;
27+
import org.opensearch.transport.client.Client;
2828

2929
import lombok.extern.log4j.Log4j2;
3030

‎memory/src/main/java/org/opensearch/ml/memory/index/ConversationMetaIndex.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,6 @@
4444
import org.opensearch.action.search.SearchResponse;
4545
import org.opensearch.action.update.UpdateRequest;
4646
import org.opensearch.action.update.UpdateResponse;
47-
import org.opensearch.client.Client;
48-
import org.opensearch.client.Requests;
4947
import org.opensearch.cluster.service.ClusterService;
5048
import org.opensearch.common.util.concurrent.ThreadContext;
5149
import org.opensearch.common.xcontent.XContentType;
@@ -63,6 +61,8 @@
6361
import org.opensearch.ml.common.conversation.ConversationalIndexConstants;
6462
import org.opensearch.search.SearchHit;
6563
import org.opensearch.search.sort.SortOrder;
64+
import org.opensearch.transport.client.Client;
65+
import org.opensearch.transport.client.Requests;
6666

6767
import lombok.AllArgsConstructor;
6868
import lombok.extern.log4j.Log4j2;

0 commit comments

Comments
 (0)