yujunjun/openspg
1
0
Fork 0
mirror of https://github.com/OpenSPG/openspg.git synced 2025-11-30 01:00:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(reasoner): query edge add property (#211)

Browse Source
This commit is contained in:
Donghai 2024-04-22 19:13:45 +08:00 committed by GitHub
parent ff948d5403
commit 56fe76b49a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
reasoner/warehouse/cloudext-warehouse/src/main/java/com/antgroup/openspg/reasoner/warehouse/cloudext/CloudExtGraphState.java
View File

@ -22,6 +22,7 @@ import com.antgroup.openspg.cloudext.interfaces.graphstore.model.lpg.record.Edge
import com.antgroup.openspg.cloudext.interfaces.graphstore.model.lpg.record.VertexRecord;
import com.antgroup.openspg.cloudext.interfaces.graphstore.model.lpg.record.struct.GraphLPGRecordStruct;
import com.antgroup.openspg.cloudext.interfaces.graphstore.model.lpg.schema.EdgeTypeName;
import com.antgroup.openspg.reasoner.common.constants.Constants;
import com.antgroup.openspg.reasoner.common.graph.edge.Direction;
import com.antgroup.openspg.reasoner.common.graph.edge.IEdge;
import com.antgroup.openspg.reasoner.common.graph.edge.impl.Edge;
@ -175,11 +176,21 @@ public class CloudExtGraphState extends MemGraphState {
new Edge<>(
srcVertexId,
dstVertexId,
new EdgeProperty(edgeRecord.toPropertyMapWithId()),
0L,
toReasonerEdgeProperty(edgeRecord),
edgeRecord.getVersion(),
direction,
edgeRecord.getEdgeType().toString()));
}
return results;
}
private EdgeProperty toReasonerEdgeProperty(EdgeRecord edgeRecord) {
Map<String, Object> otherProperties = edgeRecord.toPropertyMap();
otherProperties.put(Constants.EDGE_FROM_ID_KEY, edgeRecord.getSrcId());
otherProperties.put(Constants.EDGE_TO_ID_KEY, edgeRecord.getDstId());
otherProperties.put(
Constants.EDGE_FROM_ID_TYPE_KEY, edgeRecord.getEdgeType().getStartVertexType());
otherProperties.put(Constants.EDGE_TO_ID_TYPE_KEY, edgeRecord.getEdgeType().getEndVertexType());
return new EdgeProperty(otherProperties);
}
}