Package org.odpi.openmetadata.governanceservers.openlineage.services

Class StoringServices

java.lang.Object
org.odpi.openmetadata.governanceservers.openlineage.services.StoringServices
public class StoringServices extends Object

  • Constructor Details

    • StoringServices

      public StoringServices(LineageGraph graphStore)

  • Method Details

    • addEntityContext

      public void addEntityContext(LineageRelationshipsEvent lineageRelationshipsEvent)
      Delegates the call for the creation of entities and relationships to the connector

    • upsertEntityContext

      public void upsertEntityContext(LineageRelationshipsEvent lineageRelationshipsEvent)
      Delegates the call for the creation of entities and relationships to the connector

    • addEntityContext

      public void addEntityContext(Set<GraphContext> relationships)
      Delegates the call for the creation of entities and relationships to the connector

    • updateEntity

      public void updateEntity(LineageEntityEvent lineageEntityEvent)
      Delegates the call for the update of an entity to the connector

    • updateRelationship

      public void updateRelationship(LineageRelationshipEvent lineageRelationshipEvent)
      Delegates the call for the update of a relationship to the connector

    • updateClassification

      public void updateClassification(LineageRelationshipsEvent lineageRelationshipsEvent)
      Delegates the call for the update of a classification to the connector

    • deleteEntity

      public void deleteEntity(LineageEntityEvent lineageEntityEvent)
      Delegates the call for the deletion of an entity to the connector

    • deleteRelationship

      public void deleteRelationship(LineageRelationshipEvent lineageRelationshipEvent)

    • upsertRelationship

      public void upsertRelationship(LineageRelationshipEvent lineageRelationshipEvent)
      Delegates the call for creating or adding a relationship to the connector
      Parameters:
      lineageRelationshipEvent - the transformed event based on which the relationship will be created

    • deleteClassification

      public void deleteClassification(LineageRelationshipsEvent lineageRelationshipsEvent)
      Delegates the call to delete a classification to the connector

    • apply

      public void apply(LineageSyncEvent lineageSyncEvent)
      Applies lineageSyncEvent using lineage storage connector.
      Parameters:
      lineageSyncEvent - event to be delegated to the respective connector interface.

    • isEntityInGraph

      public Boolean isEntityInGraph(String guid)
      Check entity existence boolean in the graph through the lineage connector.
      Parameters:
      guid - the guid
      Returns:
      the boolean