Class LineageGraphConnector

  • All Implemented Interfaces:
    org.odpi.openmetadata.governanceservers.openlineage.OpenLineageGraphConnector

    public class LineageGraphConnector
    extends ConnectorBase
    implements org.odpi.openmetadata.governanceservers.openlineage.OpenLineageGraphConnector
    • Field Detail

      • CLOSE_LINEAGE_GRAPH_EXCEPTION

        public static final java.lang.String CLOSE_LINEAGE_GRAPH_EXCEPTION
        See Also:
        Constant Field Values
      • EXCEPTION_WHILE_CLOSING_LINEAGE_GRAPH_MESSAGE

        public static final java.lang.String EXCEPTION_WHILE_CLOSING_LINEAGE_GRAPH_MESSAGE
        See Also:
        Constant Field Values
      • CLOSE_LINEAGE_GRAPH_EXCEPTION_MESSAGE

        public static final java.lang.String CLOSE_LINEAGE_GRAPH_EXCEPTION_MESSAGE
        See Also:
        Constant Field Values
      • OLS_HAS_CORRESPONDING_ELEMENTS

        public static final java.lang.String OLS_HAS_CORRESPONDING_ELEMENTS
        See Also:
        Constant Field Values
      • VERTEX_NOT_FOUND

        public static final java.lang.String VERTEX_NOT_FOUND
        See Also:
        Constant Field Values
      • THE_LINEAGE_GRAPH_COULD_NOT_BE_INITIALIZED_DUE_TO_AN_ERROR

        public static final java.lang.String THE_LINEAGE_GRAPH_COULD_NOT_BE_INITIALIZED_DUE_TO_AN_ERROR
        See Also:
        Constant Field Values
    • Constructor Detail

      • LineageGraphConnector

        public LineageGraphConnector()
    • Method Detail

      • initializeGraphDB

        public void initializeGraphDB​(AuditLog auditLog)
                               throws OpenLineageException
        Instantiates the graph based on the configuration passed.
        Specified by:
        initializeGraphDB in interface org.odpi.openmetadata.governanceservers.openlineage.OpenLineageGraphConnector
        Throws:
        OpenLineageException
      • performLineageGraphJob

        public void performLineageGraphJob()
        Specified by:
        performLineageGraphJob in interface org.odpi.openmetadata.governanceservers.openlineage.OpenLineageGraphConnector
      • getLineageQueryService

        public org.odpi.openmetadata.governanceservers.openlineage.OpenLineageQueryService getLineageQueryService()
        Specified by:
        getLineageQueryService in interface org.odpi.openmetadata.governanceservers.openlineage.OpenLineageGraphConnector
      • getLineageStorageService

        public LineageGraph getLineageStorageService()
        Specified by:
        getLineageStorageService in interface org.odpi.openmetadata.governanceservers.openlineage.OpenLineageGraphConnector
      • equals

        public boolean equals​(java.lang.Object o)
        Description copied from class: ConnectorBase
        Provide a common implementation of equals for all OCF Connector Provider objects. The UUID is unique and is randomly assigned and so its hashCode is as good as anything to evaluate the equality of the connector provider object.
        Overrides:
        equals in class ConnectorBase
        Parameters:
        o - object to test
        Returns:
        boolean flag
      • canEqual

        protected boolean canEqual​(java.lang.Object other)
      • hashCode

        public int hashCode()
        Description copied from class: ConnectorBase
        Provide a common implementation of hashCode for all OCF Connector objects. The UUID is unique and is randomly assigned and so its hashCode is as good as anything to describe the hash code of the connector object.
        Overrides:
        hashCode in class ConnectorBase
        Returns:
        random UUID as hashcode