Interface LineageWarehouseGraphConnectorBase
- All Known Implementing Classes:
LineageGraphConnector
public interface LineageWarehouseGraphConnectorBase
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Free up any resources held since the connector is no longer needed.Return the query service.Return the storage service implementation.void
initializeGraphDB
(AuditLog auditLog) Initialize the graph services.void
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 graph services.- Parameters:
auditLog
- logging destination- Throws:
LineageWarehouseException
- internal error
-
performLineageGraphJob
void performLineageGraphJob()Task that the scheduler performs based on the interval -
getLineageQueryService
LineageWarehouseQueryService getLineageQueryService()Return the query service.- Returns:
- query service implementation
-
getLineageStorageService
LineageWarehouseGraphStorageService getLineageStorageService()Return the storage service implementation.- Returns:
- graph storage
-