Commit 42d801f7 by apoorvnaik

ATLAS-2815 #2: Missing txn annotation and relationship attribute mapping

Change-Id: If22ef9eda4576b52661501245f862eacc607a3ed Signed-off-by: 's avatarapoorvnaik <apoorvnaik@apache.org>
parent e8a77780
...@@ -105,6 +105,7 @@ public class AtlasEntityStoreV2 implements AtlasEntityStore { ...@@ -105,6 +105,7 @@ public class AtlasEntityStoreV2 implements AtlasEntityStore {
} }
@Override @Override
@GraphTransaction
public AtlasEntityWithExtInfo getById(final String guid, final boolean isMinExtInfo) throws AtlasBaseException { public AtlasEntityWithExtInfo getById(final String guid, final boolean isMinExtInfo) throws AtlasBaseException {
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("==> getById({}, {})", guid, isMinExtInfo); LOG.debug("==> getById({}, {})", guid, isMinExtInfo);
...@@ -126,6 +127,7 @@ public class AtlasEntityStoreV2 implements AtlasEntityStore { ...@@ -126,6 +127,7 @@ public class AtlasEntityStoreV2 implements AtlasEntityStore {
} }
@Override @Override
@GraphTransaction
public AtlasEntityHeader getHeaderById(final String guid) throws AtlasBaseException { public AtlasEntityHeader getHeaderById(final String guid) throws AtlasBaseException {
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("==> getHeaderById({})", guid); LOG.debug("==> getHeaderById({})", guid);
...@@ -147,6 +149,7 @@ public class AtlasEntityStoreV2 implements AtlasEntityStore { ...@@ -147,6 +149,7 @@ public class AtlasEntityStoreV2 implements AtlasEntityStore {
} }
@Override @Override
@GraphTransaction
public AtlasEntitiesWithExtInfo getByIds(List<String> guids) throws AtlasBaseException { public AtlasEntitiesWithExtInfo getByIds(List<String> guids) throws AtlasBaseException {
return getByIds(guids, false); return getByIds(guids, false);
} }
...@@ -170,6 +173,7 @@ public class AtlasEntityStoreV2 implements AtlasEntityStore { ...@@ -170,6 +173,7 @@ public class AtlasEntityStoreV2 implements AtlasEntityStore {
} }
@Override @Override
@GraphTransaction
public AtlasEntityWithExtInfo getByUniqueAttributes(AtlasEntityType entityType, Map<String, Object> uniqAttributes) public AtlasEntityWithExtInfo getByUniqueAttributes(AtlasEntityType entityType, Map<String, Object> uniqAttributes)
throws AtlasBaseException { throws AtlasBaseException {
return getByUniqueAttributes(entityType, uniqAttributes, false); return getByUniqueAttributes(entityType, uniqAttributes, false);
......
...@@ -381,6 +381,8 @@ public final class EntityGraphRetriever { ...@@ -381,6 +381,8 @@ public final class EntityGraphRetriever {
mapAttributes(entityVertex, entity, entityExtInfo, isMinExtInfo); mapAttributes(entityVertex, entity, entityExtInfo, isMinExtInfo);
mapRelationshipAttributes(entityVertex, entity);
mapClassifications(entityVertex, entity); mapClassifications(entityVertex, entity);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment