From 40a13e74f4adde22ca9634cfe70df321213da597 Mon Sep 17 00:00:00 2001 From: "andrea.terzani" Date: Sat, 29 Mar 2025 08:19:52 +0100 Subject: [PATCH] Modifica il tempo di retry per i documenti incorporati e aggiorna l'indice del documento nei metadati --- .../java/com/olympus/apollo/services/KSIngestor.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/olympus/apollo/services/KSIngestor.java b/src/main/java/com/olympus/apollo/services/KSIngestor.java index 0db711a..12cb9a1 100644 --- a/src/main/java/com/olympus/apollo/services/KSIngestor.java +++ b/src/main/java/com/olympus/apollo/services/KSIngestor.java @@ -48,7 +48,7 @@ public class KSIngestor { @Value("${ksingestor.embedded.doc.batch.size:20}") private int embDocsBatchSize; - @Value("${ksingestor.embedded.doc.retry.time:20000}") + @Value("${ksingestor.embedded.doc.retry.time:10000}") private int embDocRetryTime; @@ -163,10 +163,13 @@ public class KSIngestor { HashMap metadata = ingestionInfo.getMetadata(); metadata.put("KsDocumentId",ksDocument.getId()); + docs.forEach(doc -> { + int docIndex = 0; - docs.forEach(doc -> { List splitDocs = splitter.split(doc); for (Document splitDoc : splitDocs) { + metadata.put("KsDocumentIndex",String.valueOf(docIndex)); + docIndex++; splitDoc.getMetadata().putAll(metadata); } @@ -238,7 +241,7 @@ public class KSIngestor { for (Document splitDoc : splitDocs) { - meta2.put("KsDocumentUIndex",docIndex); + meta2.put("KsDocumentIndex",docIndex); splitDoc.getMetadata().putAll(meta2); docIndex++; }