Package org.odpi.openmetadata.openconnectors.governancedaemonconnectors.lineagewarehouseconnectors.janusconnector.graph

Class LineageGraphStorageService

java.lang.Object

org.odpi.openmetadata.openconnectors.governancedaemonconnectors.lineagewarehouseconnectors.janusconnector.graph.LineageGraphStorageService

All Implemented Interfaces:

LineageWarehouseGraphStorageService

public class LineageGraphStorageService
extends Object
implements LineageWarehouseGraphStorageService

Constructor Summary

Constructors

Constructor	Description
LineageGraphStorageService(GraphHelper graphHelper, AuditLog auditLog)

Method Summary

Modifier and Type	Method	Description
void	deleteClassification(Set<GraphContext> classificationContext)	Deletes a classification of a vertex
void	deleteEntity(String guid, Object version)	Deletes a vertex in the graph
void	deleteRelationship(String guid)	Deletes a relationship in the graph
Optional<Long>	getAssetLineageUpdateTime()	Gets last asset lineage update time from the graph
void	handleSaveAssetLineageUpdateTimeException(Exception e)
Boolean	isEntityInGraph(String guid)	Returns whether an entity exists in the graph or not
void	saveAssetLineageUpdateTime(Long lastUpdateTime)	Save last asset lineage update time in the graph
void	storeToGraph(Set<GraphContext> graphContext)	Creates vertices and the relationships between them
void	updateClassification(Set<GraphContext> classificationContext)	Updates the classification of a vertex
void	updateEntity(LineageEntity lineageEntity)	Updates the properties of a vertex
void	updateNeighbours(LineageSyncUpdateContext syncUpdateContext)	Updates the neighbours of a node by removing all the entities that no longer have a relationship with it.
void	updateRelationship(LineageRelationship lineageRelationship)	Updates the properties of an edge
void	upsertRelationship(LineageRelationship lineageRelationship)	Create or update the relationship between two edges In case the vertexes are not created, they are firstly created

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LineageGraphStorageService

public LineageGraphStorageService(GraphHelper graphHelper,
 AuditLog auditLog)

Method Details

storeToGraph

public void storeToGraph(Set<GraphContext> graphContext)

Creates vertices and the relationships between them

Specified by:

storeToGraph in interface LineageWarehouseGraphStorageService

Parameters:

graphContext - - graph Collection that contains vertices and edges to be stored

updateNeighbours

public void updateNeighbours(LineageSyncUpdateContext syncUpdateContext)

Updates the neighbours of a node by removing all the entities that no longer have a relationship with it.

SyncUpdateContext contains the context for syncing the relationships of a node after an update.

Specified by:

updateNeighbours in interface LineageWarehouseGraphStorageService

Parameters:

syncUpdateContext - contains the context for syncing the relationships of a node after an update.

updateEntity

public void updateEntity(LineageEntity lineageEntity)

Updates the properties of a vertex

Specified by:

updateEntity in interface LineageWarehouseGraphStorageService

Parameters:

lineageEntity - - LineageEntity object that has the updated values

upsertRelationship

public void upsertRelationship(LineageRelationship lineageRelationship)

Create or update the relationship between two edges In case the vertexes are not created, they are firstly created

Specified by:

upsertRelationship in interface LineageWarehouseGraphStorageService

Parameters:

lineageRelationship - relationship to be updated or created

updateRelationship

public void updateRelationship(LineageRelationship lineageRelationship)

Updates the properties of an edge

Specified by:

updateRelationship in interface LineageWarehouseGraphStorageService

Parameters:

lineageRelationship - - lineageRelationship object that has the updated values

updateClassification

public void updateClassification(Set<GraphContext> classificationContext)

Updates the classification of a vertex

Specified by:

updateClassification in interface LineageWarehouseGraphStorageService

Parameters:

classificationContext - - LineageEntity object that has the updated values

deleteClassification

public void deleteClassification(Set<GraphContext> classificationContext)

Deletes a classification of a vertex

Specified by:

deleteClassification in interface LineageWarehouseGraphStorageService

Parameters:

classificationContext - - any remaining classifications, empty map if none

deleteRelationship

public void deleteRelationship(String guid)

Description copied from interface: LineageWarehouseGraphStorageService

Deletes a relationship in the graph

Specified by:

deleteRelationship in interface LineageWarehouseGraphStorageService

Parameters:

guid - unique identifier of the entity to be deleted

deleteEntity

public void deleteEntity(String guid,
 Object version)

Description copied from interface: LineageWarehouseGraphStorageService

Deletes a vertex in the graph

Specified by:

deleteEntity in interface LineageWarehouseGraphStorageService

Parameters:

guid - unique identifier of the entity to be deleted

version - version of the entity to be deleted

saveAssetLineageUpdateTime

public void saveAssetLineageUpdateTime(Long lastUpdateTime)

Description copied from interface: LineageWarehouseGraphStorageService

Save last asset lineage update time in the graph

Specified by:

saveAssetLineageUpdateTime in interface LineageWarehouseGraphStorageService

Parameters:

lastUpdateTime - the standard epoch time in milliseconds

handleSaveAssetLineageUpdateTimeException

public void handleSaveAssetLineageUpdateTimeException(Exception e)

getAssetLineageUpdateTime

public Optional<Long> getAssetLineageUpdateTime()

Description copied from interface: LineageWarehouseGraphStorageService

Gets last asset lineage update time from the graph

Specified by:

getAssetLineageUpdateTime in interface LineageWarehouseGraphStorageService

Returns:

last update time represented as epoch time milliseconds

isEntityInGraph

public Boolean isEntityInGraph(String guid)

Returns whether an entity exists in the graph or not

Specified by:

isEntityInGraph in interface LineageWarehouseGraphStorageService

Parameters:

guid - the lineage entity guid

Returns: