Interface LineageGraph
- All Known Implementing Classes:
LineageGraphStorageService
public interface LineageGraph
-
Method Summary
Modifier and TypeMethodDescriptionvoid
deleteClassification
(Set<GraphContext> classificationContext) Deletes an entity's classification in the Graphvoid
deleteEntity
(String guid, Object version) /** Deletes a vertex in the graphvoid
deleteRelationship
(String guid) Deletes a relationship in the graphGets last asset lineage update time from the graphisEntityInGraph
(String guid) Returns whether an entity exists in the graph or notvoid
saveAssetLineageUpdateTime
(Long timestamp) Save last asset lineage update time in the graphvoid
storeToGraph
(Set<GraphContext> graphContext) Stores a lineage event into the lineage graph databasevoid
updateClassification
(Set<GraphContext> classificationContext) Updates an entity's classification in the Graphvoid
updateEntity
(LineageEntity lineageEntity) Updates a vertex in the Graphvoid
updateNeighbours
(LineageSyncUpdateContext syncUpdateContext) Updates the neighbours of a node by removing all the relationships that no longer have a direct link to the entity.void
updateRelationship
(LineageRelationship lineageRelationship) Updates a vertex in the Graphvoid
upsertRelationship
(LineageRelationship lineageRelationship) Create or update the relationship between two edges In case the vertexes are not created, they are firstly created
-
Method Details
-
storeToGraph
Stores a lineage event into the lineage graph database- Parameters:
graphContext
- graph Collection
-
updateNeighbours
Updates the neighbours of a node by removing all the relationships that no longer have a direct link to the entity. SyncUpdateContext contains the context for syncing the relationships of a node after an update. -
updateEntity
Updates a vertex in the Graph- Parameters:
lineageEntity
- entity to be updated
-
upsertRelationship
Create or update the relationship between two edges In case the vertexes are not created, they are firstly created- Parameters:
lineageRelationship
- relationship to be updated or created
-
updateRelationship
Updates a vertex in the Graph- Parameters:
lineageRelationship
- relationship to be updated
-
updateClassification
Updates an entity's classification in the Graph- Parameters:
classificationContext
- classification context
-
deleteClassification
Deletes an entity's classification in the Graph- Parameters:
classificationContext
- classification context
-
deleteRelationship
Deletes a relationship in the graph- Parameters:
guid
- unique identifier of the entity to be deleted
-
deleteEntity
/** Deletes a vertex in the graph- Parameters:
guid
- unique identifier of the entity to be deletedversion
- version of the entity to be deleted
-
saveAssetLineageUpdateTime
Save last asset lineage update time in the graph- Parameters:
timestamp
- the standard epoch time in milliseconds
-
getAssetLineageUpdateTime
Gets last asset lineage update time from the graph- Returns:
- last update time represented as epoch time milliseconds
-
isEntityInGraph
Returns whether an entity exists in the graph or not- Parameters:
guid
- the lineage entity guid- Returns:
- the boolean
-