Repository: atlas Updated Branches: refs/heads/branch-0.8 b9c4c3e78 -> 7a64f612e
ATLAS-2815: Graph TXN fixes Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/7a64f612 Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/7a64f612 Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/7a64f612 Branch: refs/heads/branch-0.8 Commit: 7a64f612eb5e8c3d458e9fa2890698461bbcaa78 Parents: b9c4c3e Author: apoorvnaik <[email protected]> Authored: Wed Aug 8 13:53:42 2018 -0700 Committer: apoorvnaik <[email protected]> Committed: Wed Aug 8 14:04:39 2018 -0700 ---------------------------------------------------------------------- .../atlas/repository/store/graph/v1/AtlasEntityStoreV1.java | 4 ++++ .../atlas/repository/store/graph/v1/EntityGraphRetriever.java | 1 - 2 files changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/atlas/blob/7a64f612/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasEntityStoreV1.java ---------------------------------------------------------------------- diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasEntityStoreV1.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasEntityStoreV1.java index 1f48d1c..2bfef78 100644 --- a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasEntityStoreV1.java +++ b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasEntityStoreV1.java @@ -77,6 +77,7 @@ public class AtlasEntityStoreV1 implements AtlasEntityStore { } @Override + @GraphTransaction public AtlasEntityWithExtInfo getById(String guid) throws AtlasBaseException { return getById(guid, false); } @@ -124,7 +125,9 @@ public class AtlasEntityStoreV1 implements AtlasEntityStore { return ret; } + @Override + @GraphTransaction public AtlasEntitiesWithExtInfo getByIds(List<String> guids) throws AtlasBaseException { return getByIds(guids, false); } @@ -148,6 +151,7 @@ public class AtlasEntityStoreV1 implements AtlasEntityStore { } @Override + @GraphTransaction public AtlasEntityWithExtInfo getByUniqueAttributes(AtlasEntityType entityType, Map<String, Object> uniqAttributes) throws AtlasBaseException { return getByUniqueAttributes(entityType, uniqAttributes, false); http://git-wip-us.apache.org/repos/asf/atlas/blob/7a64f612/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/EntityGraphRetriever.java ---------------------------------------------------------------------- diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/EntityGraphRetriever.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/EntityGraphRetriever.java index f2241b5..a243fd7 100644 --- a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/EntityGraphRetriever.java +++ b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/EntityGraphRetriever.java @@ -18,7 +18,6 @@ package org.apache.atlas.repository.store.graph.v1; import org.apache.atlas.AtlasErrorCode; -import org.apache.atlas.annotation.GraphTransaction; import org.apache.atlas.exception.AtlasBaseException; import org.apache.atlas.model.instance.AtlasClassification; import org.apache.atlas.model.instance.AtlasEntity;
