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

Class LineageGraphQueryHelper

java.lang.Object
org.odpi.openmetadata.openconnectors.governancedaemonconnectors.openlineageconnectors.janusconnector.graph.LineageGraphQueryHelper
public class LineageGraphQueryHelper extends Object

  • Constructor Details

    • LineageGraphQueryHelper

      public LineageGraphQueryHelper(GraphHelper graphHelper)

  • Method Details

    • getLineageVerticesAndEdges

      public LineageVerticesAndEdges getLineageVerticesAndEdges(org.apache.tinkerpop.gremlin.structure.Graph subGraph, boolean includeProcesses)
      Map a tinkerpop Graph object to an Open Lineage specific format.
      Parameters:
      subGraph - The graph to be mapped.
      Returns:
      The graph in an Open Lineage specific format.

    • getLineageVertices

      public Set<LineageVertex> getLineageVertices(org.apache.tinkerpop.gremlin.structure.Graph subGraph)

    • getLineageVertices

      public Set<LineageVertex> getLineageVertices(List<org.apache.tinkerpop.gremlin.structure.Vertex> vertexList)
      Convert a list of vertices from the janusgraph model to the list of vertices model used by egeria
      Parameters:
      vertexList - vertices to transform
      Returns:
      list of lineage vertices converted

    • getLineageEdges

      public Set<LineageEdge> getLineageEdges(org.apache.tinkerpop.gremlin.structure.Graph subGraph)

    • abstractVertex

      public LineageVertex abstractVertex(org.apache.tinkerpop.gremlin.structure.Vertex originalVertex)
      Map a Tinkerpop vertex to the Open Lineage format.
      Parameters:
      originalVertex - The vertex to be mapped.
      Returns:
      The vertex in the Open Lineage format.

    • addColumnProperties

      public void addColumnProperties(LineageVerticesAndEdges lineageVerticesAndEdges)