mesh-283: unlink domain from asset to delete

PRATHAM2002-DS · PRATHAM2002-DS · commit 09adb515307a · 2024-11-20T17:53:39.000+05:30
diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/preprocessor/AssetPreProcessor.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/preprocessor/AssetPreProcessor.java
@@ -61,6 +61,9 @@ public void processAttributes(AtlasStruct entityStruct, EntityMutationContext co
             case UPDATE:
                 processUpdateAsset(entity, vertex);
                 break;
+            case DELETE:
+                processDelete(vertex);
+                break;
         }
     }
 
@@ -116,6 +119,14 @@ private void validateDomainAssetLinks(AtlasEntity entity) throws AtlasBaseExcept
         }
     }
 
+    @Override
+    public void processDelete(AtlasVertex vertex) throws AtlasBaseException {
+        //remove the domain link
+        if (vertex != null) {
+            vertex.removeProperty(DOMAIN_GUIDS);
+        }
+    }
+
     private void isAuthorized(AtlasVertex vertex) throws AtlasBaseException {
         AtlasEntityHeader sourceEntity = retrieverNoRelation.toAtlasEntityHeaderWithClassifications(vertex);
 

Original file line number	Diff line number	Diff line change
`@@ -61,6 +61,9 @@ public void processAttributes(AtlasStruct entityStruct, EntityMutationContext co`
`61`	`61`	`case UPDATE:`
`62`	`62`	`processUpdateAsset(entity, vertex);`
`63`	`63`	`break;`
	`64`	`+ case DELETE:`
	`65`	`+ processDelete(vertex);`
	`66`	`+ break;`
`64`	`67`	`}`
`65`	`68`	`}`
`66`	`69`
`@@ -116,6 +119,14 @@ private void validateDomainAssetLinks(AtlasEntity entity) throws AtlasBaseExcept`
`116`	`119`	`}`
`117`	`120`	`}`
`118`	`121`
	`122`	`+ @Override`
	`123`	`+ public void processDelete(AtlasVertex vertex) throws AtlasBaseException {`
	`124`	`+ //remove the domain link`
	`125`	`+ if (vertex != null) {`
	`126`	`+ vertex.removeProperty(DOMAIN_GUIDS);`
	`127`	`+ }`
	`128`	`+ }`
	`129`	`+`
`119`	`130`	`private void isAuthorized(AtlasVertex vertex) throws AtlasBaseException {`
`120`	`131`	`AtlasEntityHeader sourceEntity = retrieverNoRelation.toAtlasEntityHeaderWithClassifications(vertex);`
`121`	`132`