Interface LineageGraph
-
- All Known Implementing Classes:
LineageGraphStorageService
public interface LineageGraph
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
deleteClassification(java.util.Set<GraphContext> classificationContext)
Deletes an entity's classification in the Graphvoid
deleteEntity(java.lang.String guid, java.lang.Object version)
/** Deletes a vertex in the graphvoid
deleteRelationship(java.lang.String guid)
Deletes a relationship in the graphjava.util.Optional<java.lang.Long>
getAssetLineageUpdateTime()
Gets last asset lineage update time from the graphjava.lang.Boolean
isEntityInGraph(java.lang.String guid)
Returns whether an entity exists in the graph or notvoid
saveAssetLineageUpdateTime(java.lang.Long timestamp)
Save last asset lineage update time in the graphvoid
storeToGraph(java.util.Set<GraphContext> graphContext)
Stores a lineage event into the lineage graph databasevoid
updateClassification(java.util.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 Detail
-
storeToGraph
void storeToGraph(java.util.Set<GraphContext> graphContext)
Stores a lineage event into the lineage graph database- Parameters:
graphContext
- graph Collection
-
updateNeighbours
void updateNeighbours(LineageSyncUpdateContext syncUpdateContext)
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
void updateEntity(LineageEntity lineageEntity)
Updates a vertex in the Graph- Parameters:
lineageEntity
- entity to be updated
-
upsertRelationship
void upsertRelationship(LineageRelationship lineageRelationship)
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
void updateRelationship(LineageRelationship lineageRelationship)
Updates a vertex in the Graph- Parameters:
lineageRelationship
- relationship to be updated
-
updateClassification
void updateClassification(java.util.Set<GraphContext> classificationContext)
Updates an entity's classification in the Graph- Parameters:
classificationContext
- classification context
-
deleteClassification
void deleteClassification(java.util.Set<GraphContext> classificationContext)
Deletes an entity's classification in the Graph- Parameters:
classificationContext
- classification context
-
deleteRelationship
void deleteRelationship(java.lang.String guid)
Deletes a relationship in the graph- Parameters:
guid
- unique identifier of the entity to be deleted
-
deleteEntity
void deleteEntity(java.lang.String guid, java.lang.Object version)
/** Deletes a vertex in the graph- Parameters:
guid
- unique identifier of the entity to be deletedversion
- version of the entity to be deleted
-
saveAssetLineageUpdateTime
void saveAssetLineageUpdateTime(java.lang.Long timestamp)
Save last asset lineage update time in the graph- Parameters:
timestamp
- the standard epoch time in milliseconds
-
getAssetLineageUpdateTime
java.util.Optional<java.lang.Long> getAssetLineageUpdateTime()
Gets last asset lineage update time from the graph- Returns:
- last update time represented as epoch time milliseconds
-
isEntityInGraph
java.lang.Boolean isEntityInGraph(java.lang.String guid)
Returns whether an entity exists in the graph or not- Parameters:
guid
- the lineage entity guid- Returns:
- the boolean
-
-