You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by am...@apache.org on 2019/01/22 06:31:27 UTC
[atlas] 01/02: ATLAS-3029: Audit APIs for classification updates.
This is an automated email from the ASF dual-hosted git repository.
amestry pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git
commit fa7d167537dfcdc48401e810519615723a4c664e
Author: Ashutosh Mestry <am...@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;
}