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

Class LineageGraphConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

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

All Implemented Interfaces:

SecureConnectorExtension, LineageWarehouseGraphConnectorBase

public class LineageGraphConnector
extends ConnectorBase
implements LineageWarehouseGraphConnectorBase

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, secretsStoreConnectorMap

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.
LineageWarehouseQueryService	getLineageQueryService()	Return the query service.
LineageWarehouseGraphStorageService	getLineageStorageService()	Return the storage service implementation.
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

disconnectConnectors, getArrayConfigurationProperty, getAssetTypeName, getBooleanConfigurationProperty, getConnectedAssetProperties, getConnection, getConnectorInstanceId, getIntConfigurationProperty, getNetworkAddresses, getStringConfigurationProperty, getSuppliedPlaceholderProperties, initialize, initializeConnectedAssetProperties, initializeSecretsStoreConnector, isActive, start, throwMissingResource, throwNoAsset, throwWrongTypeOfAsset, throwWrongTypeOfResource, throwWrongTypeOfRootSchema, 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.lineagewarehouse.connector.LineageWarehouseGraphConnectorBase

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 LineageWarehouseException

Instantiates the graph based on the configuration passed.

Specified by:

initializeGraphDB in interface LineageWarehouseGraphConnectorBase

Parameters:

auditLog - logging destination

Throws:

LineageWarehouseException - 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 LineageWarehouseGraphConnectorBase

Overrides:

disconnect in class ConnectorBase

Throws:

ConnectorCheckedException - there is a problem within the connector.

performLineageGraphJob

public void performLineageGraphJob()

Description copied from interface: LineageWarehouseGraphConnectorBase

Task that the scheduler performs based on the interval

Specified by:

performLineageGraphJob in interface LineageWarehouseGraphConnectorBase

getLineageQueryService

public LineageWarehouseQueryService getLineageQueryService()

Description copied from interface: LineageWarehouseGraphConnectorBase

Return the query service.

Specified by:

getLineageQueryService in interface LineageWarehouseGraphConnectorBase

Returns:

query service implementation

getLineageStorageService

public LineageWarehouseGraphStorageService getLineageStorageService()

Description copied from interface: LineageWarehouseGraphConnectorBase

Return the storage service implementation.

Specified by:

getLineageStorageService in interface LineageWarehouseGraphConnectorBase

Returns:

graph storage

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