Package org.odpi.openmetadata.governanceservers.openlineage

Interface OpenLineageGraphConnector

All Known Implementing Classes:

LineageGraphConnector

public interface OpenLineageGraphConnector

Method Summary

Modifier and Type	Method	Description
void	disconnect()	Free up any resources held since the connector is no longer needed.
OpenLineageQueryService	getLineageQueryService()
LineageGraph	getLineageStorageService()
void	initializeGraphDB(AuditLog auditLog)	Initialize the connectors
void	performLineageGraphJob()	Task that the scheduler performs based on the interval
void	start()	Indicates that the connector is completely configured and can begin processing.

Method Details

start

void start()
    throws ConnectorCheckedException

Indicates that the connector is completely configured and can begin processing.

Throws:

ConnectorCheckedException - there is a problem within the connector.

disconnect

void disconnect()
         throws ConnectorCheckedException

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

Throws:

ConnectorCheckedException - there is a problem within the connector.

initializeGraphDB

void initializeGraphDB(AuditLog auditLog)
                throws OpenLineageException

Initialize the connectors

Parameters:

auditLog - logging destination

Throws:

OpenLineageException - internal error

performLineageGraphJob

void performLineageGraphJob()

Task that the scheduler performs based on the interval

getLineageQueryService

OpenLineageQueryService getLineageQueryService()

getLineageStorageService

LineageGraph getLineageStorageService()