26
26
import co .elastic .clients .base .Transport ;
27
27
import co .elastic .clients .elasticsearch .ElasticsearchAsyncClient ;
28
28
import co .elastic .clients .elasticsearch .ElasticsearchClient ;
29
- import co .elastic .clients .elasticsearch ._core .BulkResponse ;
30
- import co .elastic .clients .elasticsearch ._core .IndexResponse ;
31
- import co .elastic .clients .elasticsearch ._core .SearchResponse ;
32
- import co .elastic .clients .elasticsearch ._core .bulk .ResponseItem ;
29
+ import co .elastic .clients .elasticsearch .core .BulkResponse ;
30
+ import co .elastic .clients .elasticsearch .core .GetResponse ;
31
+ import co .elastic .clients .elasticsearch .core .IndexResponse ;
32
+ import co .elastic .clients .elasticsearch .core .SearchResponse ;
33
+ import co .elastic .clients .elasticsearch .core .bulk .ResponseItem ;
33
34
import co .elastic .clients .elasticsearch .cat .NodesResponse ;
34
35
import co .elastic .clients .elasticsearch .indices .CreateIndexResponse ;
35
36
import co .elastic .clients .elasticsearch .indices .GetIndexResponse ;
@@ -253,7 +254,7 @@ public void testRefresh() throws IOException {
253
254
assertFalse (exists .value ());
254
255
255
256
try {
256
- co . elastic . clients . elasticsearch . _core . GetResponse <String > response = client .get (
257
+ GetResponse <String > response = client .get (
257
258
_0 -> _0 .index ("doesnotexist" ).id ("reallynot" ), String .class
258
259
);
259
260
} catch (ApiException apie ) {
@@ -264,7 +265,7 @@ public void testRefresh() throws IOException {
264
265
265
266
try {
266
267
ElasticsearchAsyncClient aClient = new ElasticsearchAsyncClient (transport );
267
- co . elastic . clients . elasticsearch . _core . GetResponse <String > response = aClient .get (
268
+ GetResponse <String > response = aClient .get (
268
269
_0 -> _0 .index ("doesnotexist" ).id ("reallynot" ), String .class
269
270
).get ();
270
271
} catch (ExecutionException ee ) {
0 commit comments