Skip to content

Commit a111412

Browse files
committed
wip
1 parent 2b09c01 commit a111412

File tree

1 file changed

+6
-25
lines changed
  • src/test/java/org/springframework/data/elasticsearch/client/elc

1 file changed

+6
-25
lines changed

src/test/java/org/springframework/data/elasticsearch/client/elc/DevTests.java

Lines changed: 6 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,6 @@
1919

2020
import co.elastic.clients.elasticsearch.ElasticsearchClient;
2121
import co.elastic.clients.elasticsearch._types.FieldValue;
22-
import co.elastic.clients.elasticsearch._types.Script;
23-
import co.elastic.clients.elasticsearch._types.mapping.RuntimeField;
24-
import co.elastic.clients.elasticsearch._types.mapping.RuntimeFieldType;
2522
import co.elastic.clients.elasticsearch._types.mapping.TypeMapping;
2623
import co.elastic.clients.elasticsearch.cluster.HealthRequest;
2724
import co.elastic.clients.elasticsearch.cluster.HealthResponse;
@@ -30,6 +27,8 @@
3027
import co.elastic.clients.elasticsearch.core.SearchRequest;
3128
import co.elastic.clients.elasticsearch.core.search.ResponseBody;
3229
import co.elastic.clients.elasticsearch.indices.ElasticsearchIndicesClient;
30+
import co.elastic.clients.elasticsearch.indices.GetIndicesSettingsRequest;
31+
import co.elastic.clients.elasticsearch.indices.GetIndicesSettingsResponse;
3332
import co.elastic.clients.elasticsearch.indices.IndexSettings;
3433
import co.elastic.clients.transport.ElasticsearchTransport;
3534
import co.elastic.clients.transport.TransportOptions;
@@ -85,30 +84,12 @@ public class DevTests {
8584
void someTest() throws IOException {
8685

8786
ElasticsearchClient client = imperativeElasticsearchClient;
87+
ElasticsearchIndicesClient indicesClient = client.indices();
8888

89-
String index = "testindex";
89+
indicesClient.create(b -> b.index("testindex"));
9090

91-
var p = new Product("p1", 42.0);
92-
93-
client.index(ir -> ir //
94-
.index(index)//
95-
.document(p));
96-
97-
client.indices().flush(f -> f.index(index));
98-
99-
RuntimeField runtimeField = RuntimeField.of(rf -> rf //
100-
.type(RuntimeFieldType.Double) //
101-
.script(Script.of(s -> s //
102-
.inline(i -> i. //
103-
source("emit(doc['price'].value * 1.19)") //
104-
) //
105-
)) //
106-
); //
107-
108-
client.search(sr -> sr //
109-
.index(index) //
110-
.runtimeMappings("priceWithTax", runtimeField), //
111-
Person.class); //
91+
GetIndicesSettingsResponse getIndicesSettingsResponse = indicesClient.getSettings(GetIndicesSettingsRequest
92+
.of(b -> b.index("testindex").includeDefaults(true)));
11293
}
11394

11495
static class ReactiveClient {

0 commit comments

Comments
 (0)