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

Class LineageGraphConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

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

All Implemented Interfaces:

OpenLineageGraphConnector

public class LineageGraphConnector
extends ConnectorBase
implements OpenLineageGraphConnector

Nested Class Summary

Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

ConnectorBase.ProtectedConnection

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CLOSE_LINEAGE_GRAPH_EXCEPTION
static final String	CLOSE_LINEAGE_GRAPH_EXCEPTION_MESSAGE
static final String	EXCEPTION_WHILE_CLOSING_LINEAGE_GRAPH_MESSAGE
static final String	INPUT_PORT
static final String	OLS_HAS_CORRESPONDING_ELEMENTS
static final String	THE_LINEAGE_GRAPH_COULD_NOT_BE_INITIALIZED_DUE_TO_AN_ERROR
static final String	VERTEX_NOT_FOUND

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

connectedAssetProperties, connectionBean, connectionProperties, connectorInstanceId, securedProperties

Constructor Summary

Constructors

Constructor	Description
LineageGraphConnector()

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(Object other)
void	disconnect()	Free up any resources held since the connector is no longer needed.
boolean	equals(Object o)	Provide a common implementation of equals for all OCF Connector Provider objects.
OpenLineageQueryService	getLineageQueryService()
LineageGraph	getLineageStorageService()
int	hashCode()	Provide a common implementation of hashCode for all OCF Connector objects.
void	initializeGraphDB(AuditLog auditLog)	Instantiates the graph based on the configuration passed.
void	performLineageGraphJob()	Task that the scheduler performs based on the interval

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

getConnectedAssetProperties, getConnection, getConnectorInstanceId, initialize, initializeConnectedAssetProperties, isActive, start, toString

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector

clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, setStatisticProperty, setStatisticTimestamp

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.odpi.openmetadata.governanceservers.openlineage.OpenLineageGraphConnector

start

Field Details

CLOSE_LINEAGE_GRAPH_EXCEPTION

public static final String CLOSE_LINEAGE_GRAPH_EXCEPTION

See Also:

• Constant Field Values

EXCEPTION_WHILE_CLOSING_LINEAGE_GRAPH_MESSAGE

public static final String EXCEPTION_WHILE_CLOSING_LINEAGE_GRAPH_MESSAGE

See Also:

• Constant Field Values

CLOSE_LINEAGE_GRAPH_EXCEPTION_MESSAGE

public static final String CLOSE_LINEAGE_GRAPH_EXCEPTION_MESSAGE

See Also:

• Constant Field Values

INPUT_PORT

public static final String INPUT_PORT

See Also:

• Constant Field Values

OLS_HAS_CORRESPONDING_ELEMENTS

public static final String OLS_HAS_CORRESPONDING_ELEMENTS

See Also:

• Constant Field Values

VERTEX_NOT_FOUND

public static final String VERTEX_NOT_FOUND

See Also:

• Constant Field Values

THE_LINEAGE_GRAPH_COULD_NOT_BE_INITIALIZED_DUE_TO_AN_ERROR

public static final String THE_LINEAGE_GRAPH_COULD_NOT_BE_INITIALIZED_DUE_TO_AN_ERROR

See Also:

• Constant Field Values

Constructor Details

LineageGraphConnector

public LineageGraphConnector()

Method Details

initializeGraphDB

public void initializeGraphDB(AuditLog auditLog)
                       throws OpenLineageException

Instantiates the graph based on the configuration passed.

Specified by:

initializeGraphDB in interface OpenLineageGraphConnector

Parameters:

auditLog - logging destination

Throws:

OpenLineageException - internal error

disconnect

public void disconnect()
                throws ConnectorCheckedException

Description copied from class: ConnectorBase

Free up any resources held since the connector is no longer needed.

Specified by:

disconnect in interface OpenLineageGraphConnector

Overrides:

disconnect in class ConnectorBase

Throws:

ConnectorCheckedException - there is a problem within the connector.

performLineageGraphJob

public void performLineageGraphJob()

Description copied from interface: OpenLineageGraphConnector

Task that the scheduler performs based on the interval

Specified by:

performLineageGraphJob in interface OpenLineageGraphConnector

getLineageQueryService

public OpenLineageQueryService getLineageQueryService()

Specified by:

getLineageQueryService in interface OpenLineageGraphConnector

getLineageStorageService

public LineageGraph getLineageStorageService()

Specified by:

getLineageStorageService in interface OpenLineageGraphConnector

equals

public boolean equals(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(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