Skip to content

Commit 971a58c

Browse files
committed
format - Signed-off-by: Theo van Kraay <theo.van@microsoft.com>
Signed-off-by: Theo van Kraay <theo.van@microsoft.com>
1 parent 0104827 commit 971a58c

File tree

2 files changed

+9
-11
lines changed

2 files changed

+9
-11
lines changed

vector-stores/spring-ai-azure-cosmos-db-store/src/main/java/org/springframework/ai/vectorstore/cosmosdb/CosmosDBVectorStore.java

+8-7
Original file line numberDiff line numberDiff line change
@@ -353,32 +353,33 @@ public List<Document> doSimilaritySearch(SearchRequest request) {
353353

354354
CosmosPagedFlux<JsonNode> pagedFlux = this.container.queryItems(sqlQuerySpec, options, JsonNode.class);
355355

356-
357356
logger.info("Executing similarity search query: {}", query);
358357
try {
359358
// Collect documents from the paged flux
360359
List<JsonNode> documents = pagedFlux.byPage()
361360
.flatMap(page -> Flux.fromIterable(page.getResults()))
362361
.collectList()
363362
.block();
364-
363+
365364
// Collect metadata fields from the documents
366365
Map<String, Object> docFields = new HashMap<>();
367366
for (var doc : documents) {
368367
JsonNode metadata = doc.get("metadata");
369368
metadata.fieldNames().forEachRemaining(field -> {
370369
JsonNode value = metadata.get(field);
371-
Object parsedValue = value.isTextual() ? value.asText() :
372-
value.isNumber() ? value.numberValue() :
373-
value.isBoolean() ? value.booleanValue() :
374-
value.toString();
370+
Object parsedValue = value.isTextual() ? value.asText() : value.isNumber() ? value.numberValue()
371+
: value.isBoolean() ? value.booleanValue() : value.toString();
375372
docFields.put(field, parsedValue);
376373
});
377374
}
378375

379376
// Convert JsonNode to Document
380377
List<Document> docs = documents.stream()
381-
.map(doc -> Document.builder().id(doc.get("id").asText()).text(doc.get("content").asText()).metadata(docFields).build())
378+
.map(doc -> Document.builder()
379+
.id(doc.get("id").asText())
380+
.text(doc.get("content").asText())
381+
.metadata(docFields)
382+
.build())
382383
.collect(Collectors.toList());
383384

384385
return docs != null ? docs : List.of();

vector-stores/spring-ai-azure-cosmos-db-store/src/test/java/org/springframework/ai/vectorstore/cosmosdb/CosmosDBVectorStoreIT.java

+1-4
Original file line numberDiff line numberDiff line change
@@ -144,8 +144,7 @@ void testSimilaritySearchWithFilter() {
144144
for (Document doc : results) {
145145
assertThat(doc.getMetadata().get("country")).isIn("UK", "NL");
146146
assertThat(doc.getMetadata().get("year")).isIn(2021, 2022);
147-
assertThat(doc.getMetadata().get("city")).isIn("London", "Amsterdam")
148-
.isNotEqualTo("Sofia");
147+
assertThat(doc.getMetadata().get("city")).isIn("London", "Amsterdam").isNotEqualTo("Sofia");
149148
}
150149

151150
List<Document> results2 = this.vectorStore.similaritySearch(SearchRequest.builder()
@@ -158,8 +157,6 @@ void testSimilaritySearchWithFilter() {
158157
assertThat(results2).hasSize(1);
159158
assertThat(results2).extracting(Document::getId).containsExactlyInAnyOrder("1");
160159

161-
162-
163160
List<Document> results3 = this.vectorStore.similaritySearch(SearchRequest.builder()
164161
.query("The World")
165162
.topK(10)

0 commit comments

Comments
 (0)