[atlas] 02/07: ATLAS-3029: Audit APIs for classification updates.

[nixon]

This is an automated email from the ASF dual-hosted git repository.

nixon pushed a commit to branch branch-1.0
in repository https://gitbox.apache.org/repos/asf/atlas.git

commit 752587a9d94214402ef4765917a4e93358777e6e
Author: Ashutosh Mestry <ames...@hortonworks.com>
AuthorDate: Mon Jan 21 21:32:42 2019 -0800

    ATLAS-3029: Audit APIs for classification updates.
---
 .../store/graph/v2/ClassificationAssociator.java           | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/ClassificationAssociator.java
 
b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/ClassificationAssociator.java
index 11d008f..057598c 100644
--- 
a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/ClassificationAssociator.java
+++ 
b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/ClassificationAssociator.java
@@ -171,7 +171,7 @@ public class ClassificationAssociator {
             operationListMap.put(op, results);
         }
 
-        private void addClassifications(String entityToBeChangedGuid, String 
typeName, String qualifiedName, List<AtlasClassification> list) {
+        private void addClassifications(String entityGuid, String typeName, 
String qualifiedName, List<AtlasClassification> list) {
             if (CollectionUtils.isEmpty(list)) {
                 return;
             }
@@ -179,16 +179,16 @@ public class ClassificationAssociator {
             String status = STATUS_DONE;
             String classificationNames = getClassificationNames(list);
             try {
-                entitiesStore.addClassifications(entityToBeChangedGuid, list);
+                entitiesStore.addClassifications(entityGuid, list);
             } catch (AtlasBaseException e) {
                 status = STATUS_PARTIAL;
                 LOG.warn("{}:{}:{} -> {}: {}.", PROCESS_UPDATE, typeName, 
qualifiedName, classificationNames, status);
             }
 
-            summarize(PROCESS_ADD, entityToBeChangedGuid, typeName, 
qualifiedName, classificationNames, status);
+            summarize(PROCESS_ADD, entityGuid, typeName, qualifiedName, 
classificationNames, status);
         }
 
-        private void updateClassifications(String entityToBeChangedGuid, 
String typeName, String qualifiedName, List<AtlasClassification> list) {
+        private void updateClassifications(String entityGuid, String typeName, 
String qualifiedName, List<AtlasClassification> list) {
             if (CollectionUtils.isEmpty(list)) {
                 return;
             }
@@ -197,16 +197,16 @@ public class ClassificationAssociator {
             String classificationNames = getClassificationNames(list);
 
             try {
-                entitiesStore.updateClassifications(entityToBeChangedGuid, 
list);
+                entitiesStore.updateClassifications(entityGuid, list);
             } catch (AtlasBaseException e) {
                 status = STATUS_PARTIAL;
                 LOG.warn("{}:{}:{} -> {}: {}.", PROCESS_UPDATE, typeName, 
qualifiedName, classificationNames, status);
             }
 
-            summarize(PROCESS_UPDATE, entityToBeChangedGuid, typeName, 
qualifiedName, classificationNames, status);
+            summarize(PROCESS_UPDATE, entityGuid, typeName, qualifiedName, 
classificationNames, status);
         }
 
-        private void deleteClassifications(String typeName, String entityGuid, 
String qualifiedName, List<AtlasClassification> list) {
+        private void deleteClassifications(String entityGuid, String typeName, 
String qualifiedName, List<AtlasClassification> list) {
             if (CollectionUtils.isEmpty(list)) {
                 return;
             }