Commit 0dcd6890 by apoorvnaik

ATLAS-2551: Update AtlasRelatedObjectId to include relationship status

Change-Id: If1158a70b894e10d9b7205ba536aa6e8a928faa6
parent 0cde9f92
...@@ -48,22 +48,27 @@ public class AtlasRelatedObjectId extends AtlasObjectId implements Serializable ...@@ -48,22 +48,27 @@ public class AtlasRelatedObjectId extends AtlasObjectId implements Serializable
private String displayText = null; private String displayText = null;
private String relationshipGuid = null; private String relationshipGuid = null;
private AtlasRelationship.Status relationshipStatus = null;
private AtlasStruct relationshipAttributes; private AtlasStruct relationshipAttributes;
public AtlasRelatedObjectId() { } public AtlasRelatedObjectId() { }
public AtlasRelatedObjectId(String guid, String typeName, String relationshipGuid, AtlasStruct relationshipAttributes) { public AtlasRelatedObjectId(String guid, String typeName, String relationshipGuid,
AtlasRelationship.Status relationshipStatus, AtlasStruct relationshipAttributes) {
super(guid, typeName); super(guid, typeName);
setRelationshipGuid(relationshipGuid); setRelationshipGuid(relationshipGuid);
setRelationshipStatus(relationshipStatus);
setRelationshipAttributes(relationshipAttributes); setRelationshipAttributes(relationshipAttributes);
} }
public AtlasRelatedObjectId(String guid, String typeName, Map<String, Object> uniqueAttributes, String displayText, public AtlasRelatedObjectId(String guid, String typeName, Map<String, Object> uniqueAttributes, String displayText,
String relationshipGuid, AtlasStruct relationshipAttributes) { String relationshipGuid, AtlasRelationship.Status relationshipStatus,
AtlasStruct relationshipAttributes) {
super(guid, typeName, uniqueAttributes); super(guid, typeName, uniqueAttributes);
setRelationshipGuid(relationshipGuid); setRelationshipGuid(relationshipGuid);
setRelationshipStatus(relationshipStatus);
setDisplayText(displayText); setDisplayText(displayText);
setRelationshipAttributes(relationshipAttributes); setRelationshipAttributes(relationshipAttributes);
} }
...@@ -88,12 +93,13 @@ public class AtlasRelatedObjectId extends AtlasObjectId implements Serializable ...@@ -88,12 +93,13 @@ public class AtlasRelatedObjectId extends AtlasObjectId implements Serializable
AtlasRelatedObjectId that = (AtlasRelatedObjectId) o; AtlasRelatedObjectId that = (AtlasRelatedObjectId) o;
return Objects.equals(displayText, that.displayText) && return Objects.equals(displayText, that.displayText) &&
Objects.equals(relationshipGuid, that.relationshipGuid) && Objects.equals(relationshipGuid, that.relationshipGuid) &&
Objects.equals(relationshipStatus, that.relationshipStatus) &&
Objects.equals(relationshipAttributes, that.relationshipAttributes); Objects.equals(relationshipAttributes, that.relationshipAttributes);
} }
@Override @Override
public int hashCode() { public int hashCode() {
return Objects.hash(super.hashCode(), displayText, relationshipGuid, relationshipAttributes); return Objects.hash(super.hashCode(), displayText, relationshipGuid, relationshipStatus, relationshipAttributes);
} }
@Override @Override
...@@ -111,9 +117,18 @@ public class AtlasRelatedObjectId extends AtlasObjectId implements Serializable ...@@ -111,9 +117,18 @@ public class AtlasRelatedObjectId extends AtlasObjectId implements Serializable
super.toString(sb); super.toString(sb);
sb.append("displayText='").append(displayText).append('\''); sb.append("displayText='").append(displayText).append('\'');
sb.append(", relationshipGuid='").append(relationshipGuid).append('\''); sb.append(", relationshipGuid='").append(relationshipGuid).append('\'');
sb.append(", relationshipStatus='").append(relationshipStatus).append('\'');
sb.append(", relationshipAttributes=").append(relationshipAttributes); sb.append(", relationshipAttributes=").append(relationshipAttributes);
sb.append('}'); sb.append('}');
return sb; return sb;
} }
public AtlasRelationship.Status getRelationshipStatus() {
return relationshipStatus;
}
public void setRelationshipStatus(final AtlasRelationship.Status relationshipStatus) {
this.relationshipStatus = relationshipStatus;
}
} }
\ No newline at end of file
...@@ -848,7 +848,8 @@ public final class EntityGraphRetriever { ...@@ -848,7 +848,8 @@ public final class EntityGraphRetriever {
String entityGuid = getGuid(referenceVertex); String entityGuid = getGuid(referenceVertex);
AtlasRelationship relationship = mapEdgeToAtlasRelationship(edge); AtlasRelationship relationship = mapEdgeToAtlasRelationship(edge);
ret = new AtlasRelatedObjectId(entityGuid, entityTypeName, relationship.getGuid(), ret = new AtlasRelatedObjectId(entityGuid, entityTypeName,
relationship.getGuid(), relationship.getStatus(),
new AtlasStruct(relationship.getTypeName(), relationship.getAttributes())); new AtlasStruct(relationship.getTypeName(), relationship.getAttributes()));
Object displayText = getDisplayText(referenceVertex, entityTypeName); Object displayText = getDisplayText(referenceVertex, entityTypeName);
......
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