From d8e31c11a56a2ee90e97aad3f2ded706445db2f6 Mon Sep 17 00:00:00 2001 From: Suresh Srinivas Date: Thu, 5 Aug 2021 02:08:26 -0700 Subject: [PATCH] Event logging, add pluggable interfaces and AuditLog, ElasticSearch implementations --- .../catalog/events/ElasticSearchEventHandler.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/ElasticSearchEventHandler.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/ElasticSearchEventHandler.java index 0c98d75f5c7..a03ffc9fd14 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/ElasticSearchEventHandler.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/events/ElasticSearchEventHandler.java @@ -61,16 +61,21 @@ public class ElasticSearchEventHandler implements EventHandler { Table instance = (Table) entity; Map jsonMap = new HashMap<>(); jsonMap.put("description", instance.getDescription()); - Set tags = new HashSet(); + Set tags = new HashSet<>(); + List columnDescriptions = new ArrayList<>(); instance.getTags().forEach(tag -> tags.add(tag.getTagFQN())); for(Column column: instance.getColumns()) { column.getTags().forEach(tag -> tags.add(tag.getTagFQN())); + columnDescriptions.add(column.getDescription()); } if (!tags.isEmpty()) { List tagsList = new ArrayList<>(); tagsList.addAll(tags); jsonMap.put("tags", tagsList); } + if (!columnDescriptions.isEmpty()) { + jsonMap.put("column_descriptions", columnDescriptions); + } UpdateRequest updateRequest = new UpdateRequest("table_search_index", instance.getId().toString()); updateRequest.doc(jsonMap); client.updateAsync(updateRequest, RequestOptions.DEFAULT, listener);