From f34e8c0f503247de2595a6af9901b8dbc5aa1663 Mon Sep 17 00:00:00 2001 From: Amit Kumar Yadav <36166686+amit-kumaryadav@users.noreply.github.com> Date: Mon, 16 Aug 2021 19:20:33 +0530 Subject: [PATCH 1/2] Update CompositeSearchIndexer.java --- .../service/util/CompositeSearchIndexer.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/platform-jobs/samza/composite-search-indexer/src/main/java/org/ekstep/jobs/samza/service/util/CompositeSearchIndexer.java b/platform-jobs/samza/composite-search-indexer/src/main/java/org/ekstep/jobs/samza/service/util/CompositeSearchIndexer.java index 9b245c4a55..9186a6c3c0 100644 --- a/platform-jobs/samza/composite-search-indexer/src/main/java/org/ekstep/jobs/samza/service/util/CompositeSearchIndexer.java +++ b/platform-jobs/samza/composite-search-indexer/src/main/java/org/ekstep/jobs/samza/service/util/CompositeSearchIndexer.java @@ -216,12 +216,24 @@ private void upsertDocument(String uniqueId, Map message, Map indexDocument = getIndexDocument(message, relationMap, false, indexableProps); String jsonIndexDocument = mapper.writeValueAsString(indexDocument); + try { + System.out.println("New Content Request::"); + System.out.println(jsonIndexDocument); + } catch (JsonProcessingException e) { + e.printStackTrace(); + } upsertDocument(uniqueId, jsonIndexDocument); break; } case CompositeSearchConstants.OPERATION_UPDATE: { Map indexDocument = getIndexDocument(message, relationMap, true, indexableProps); String jsonIndexDocument = mapper.writeValueAsString(indexDocument); + try { + System.out.println("Update Content Request::"); + System.out.println(jsonIndexDocument); + } catch (JsonProcessingException e) { + e.printStackTrace(); + } upsertDocument(uniqueId, jsonIndexDocument); break; } @@ -252,6 +264,9 @@ private List getIndexableProperties(Map definition) { } private void addMetadataToDocument(Map.Entry propertyMap, String propertyName, Map indexDocument) throws Exception { + System.out.println("Nested : field values and Property Name"); + System.out.println(nestedFields); + System.out.println(propertyName); // new value of the property Object propertyNewValue = ((Map) propertyMap.getValue()).get("nv"); // New value from transaction data is null, then remove the property from document From 63cd6e6b3ef50674830716b3625f272851b53099 Mon Sep 17 00:00:00 2001 From: Amit Kumar Yadav <36166686+amit-kumaryadav@users.noreply.github.com> Date: Tue, 17 Aug 2021 12:05:18 +0530 Subject: [PATCH 2/2] Update CompositeSearchIndexer.java --- .../jobs/samza/service/util/CompositeSearchIndexer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/platform-jobs/samza/composite-search-indexer/src/main/java/org/ekstep/jobs/samza/service/util/CompositeSearchIndexer.java b/platform-jobs/samza/composite-search-indexer/src/main/java/org/ekstep/jobs/samza/service/util/CompositeSearchIndexer.java index 9186a6c3c0..ece29d2795 100644 --- a/platform-jobs/samza/composite-search-indexer/src/main/java/org/ekstep/jobs/samza/service/util/CompositeSearchIndexer.java +++ b/platform-jobs/samza/composite-search-indexer/src/main/java/org/ekstep/jobs/samza/service/util/CompositeSearchIndexer.java @@ -219,7 +219,7 @@ private void upsertDocument(String uniqueId, Map message, Map message, Map