Interface OpenLineageGraphConnector
- All Known Implementing Classes:
LineageGraphConnector
public interface OpenLineageGraphConnector
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Free up any resources held since the connector is no longer needed.void
initializeGraphDB
(AuditLog auditLog) Initialize the connectorsvoid
Task that the scheduler performs based on the intervalvoid
start()
Indicates that the connector is completely configured and can begin processing.
-
Method Details
-
start
Indicates that the connector is completely configured and can begin processing.- Throws:
ConnectorCheckedException
- there is a problem within the connector.
-
disconnect
Free up any resources held since the connector is no longer needed.- Throws:
ConnectorCheckedException
- there is a problem within the connector.
-
initializeGraphDB
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()
-