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..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 @@ -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 (Exception 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 (Exception 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