Package org.odpi.openmetadata.integrationservices.lineage.rest

Class LineageIntegratorRESTServices

java.lang.Object

org.odpi.openmetadata.integrationservices.lineage.rest.LineageIntegratorRESTServices

public class LineageIntegratorRESTServices
extends Object

LineageIntegratorRESTServices provides the ability to validate that a connector will run successfully in this integration service. It is a convenience method for configuration tools.

Constructor Summary

Constructors

Constructor	Description
LineageIntegratorRESTServices()	The constructor registers this service with the integration daemon.

Method Summary

Modifier and Type	Method	Description
void	publishOpenLineageEvent(String serverName, String userId, String event)	Pass an open lineage event to the integration service.
ConnectorReportResponse	validateConnector(String serverName, String userId, String connectorProviderClassName)	Validate the connector and return its connector type.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LineageIntegratorRESTServices

public LineageIntegratorRESTServices()

The constructor registers this service with the integration daemon. It is called with the spring module is picked up by the component scan and instantiated.

Method Details

validateConnector

public ConnectorReportResponse validateConnector(String serverName,
 String userId,
 String connectorProviderClassName)

Validate the connector and return its connector type.

Parameters:

serverName - integration daemon server name

userId - calling user

connectorProviderClassName - name of a specific connector or null for all connectors

Returns:

connector type or InvalidParameterException the connector provider class name is not a valid connector for this service; UserNotAuthorizedException user not authorized to issue this request or PropertyServerException there was a problem detected by the integration service

publishOpenLineageEvent

public void publishOpenLineageEvent(String serverName,
 String userId,
 String event)

Pass an open lineage event to the integration service. It will pass it on to the integration connectors that have registered a listener for open lineage events.

Parameters:

serverName - integration daemon server name

userId - calling user

event - open lineage event to publish.