yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-07-24 17:59:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add Assets field to domain (#16871)

Browse Source
This commit is contained in:
Mohit Yadav 2024-07-01 22:26:56 +05:30 committed by GitHub
parent bf4a3f8baa
commit 079d93b9e5
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/DomainRepository.java
View File

@ -16,7 +16,9 @@ package org.openmetadata.service.jdbi3;
import static org.openmetadata.common.utils.CommonUtil.listOrEmpty;
import static org.openmetadata.schema.type.Include.ALL;
import static org.openmetadata.service.Entity.DOMAIN;
import static org.openmetadata.service.Entity.FIELD_ASSETS;
import java.util.List;
import lombok.extern.slf4j.Slf4j;
import org.jdbi.v3.sqlobject.transaction.Transaction;
import org.openmetadata.schema.EntityInterface;
@ -48,6 +50,7 @@ public class DomainRepository extends EntityRepository<Domain> {
@Override
public void setFields(Domain entity, Fields fields) {
entity.withAssets(fields.contains(FIELD_ASSETS) ? getAssets(entity) : null);
entity.withParent(getParent(entity));
}
@ -91,6 +94,10 @@ public class DomainRepository extends EntityRepository<Domain> {
}
}
private List<EntityReference> getAssets(Domain entity) {
return findTo(entity.getId(), DOMAIN, Relationship.HAS, null);
}
public BulkOperationResult bulkAddAssets(String domainName, BulkAssets request) {
Domain domain = getByName(null, domainName, getFields("id"));
return bulkAssetsOperation(domain.getId(), DOMAIN, Relationship.HAS, request, true);

4
openmetadata-spec/src/main/resources/json/schema/entity/domains/domain.json
View File

@ -78,6 +78,10 @@
"$ref": "../../type/entityReferenceList.json",
"default" : null
},
"assets": {
"description": "Data assets collection that is part of this domain.",
"$ref" : "../../type/entityReferenceList.json"
},
"changeDescription": {
"description": "Change that lead to this version of the entity.",
"$ref": "../../type/entityHistory.json#/definitions/changeDescription"