Package org.odpi.openmetadata.adapters.connectors.integration.openlineage

Class OpenLineageEventReceiverIntegrationConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

org.odpi.openmetadata.frameworks.integration.connectors.IntegrationConnectorBase

org.odpi.openmetadata.integrationservices.lineage.connector.LineageIntegratorConnector

org.odpi.openmetadata.adapters.connectors.integration.openlineage.OpenLineageEventReceiverIntegrationConnector

All Implemented Interfaces:

AuditLoggingComponent, SecureConnectorExtension, VirtualConnectorExtension, IntegrationConnector, LineageIntegratorOMISConnector, OpenMetadataTopicListener

public class OpenLineageEventReceiverIntegrationConnector
extends LineageIntegratorConnector
implements OpenMetadataTopicListener

OpenLineageEventReceiverIntegrationConnector receives open lineage events from an event broker such as an Apache Kafka topic. It publishes them to other listening lineage integration connectors.

Nested Class Summary

Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

ConnectorBase.ProtectedConnection

Field Summary

Fields inherited from class org.odpi.openmetadata.frameworks.integration.connectors.IntegrationConnectorBase

auditLog, connectorName, embeddedConnectors, integrationContext

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

connectedAssetProperties, connectionBean, connectionProperties, connectorInstanceId, secretsStoreConnectorMap

Constructor Summary

Constructors

Constructor	Description
OpenLineageEventReceiverIntegrationConnector()	Default constructor

Method Summary

Modifier and Type	Method	Description
void	disconnect()	Shutdown event monitoring
void	processEvent(String event)	Method to pass an event received on topic to the Lineage Integrator OMIS to be published to listening integration connectors.
void	refresh()	No function needed in refresh()
void	start()	Indicates that the connector is completely configured and can begin processing.

Methods inherited from class org.odpi.openmetadata.integrationservices.lineage.connector.LineageIntegratorConnector

getContext, setContext

Methods inherited from class org.odpi.openmetadata.frameworks.integration.connectors.IntegrationConnectorBase

engage, getConnectorComponentDescription, initializeEmbeddedConnectors, setAuditLog, setConnectorName, setContext

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

equals, getConnectedAssetProperties, getConnection, getConnectorInstanceId, hashCode, initialize, initializeConnectedAssetProperties, initializeSecretsStoreConnector, isActive, 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

Constructor Details

OpenLineageEventReceiverIntegrationConnector

public OpenLineageEventReceiverIntegrationConnector()

Default constructor

Method Details

start

public void start()
           throws ConnectorCheckedException

Indicates that the connector is completely configured and can begin processing. This call can be used to register with non-blocking services.

Specified by:

start in interface IntegrationConnector

Overrides:

start in class ConnectorBase

Throws:

ConnectorCheckedException - there is a problem within the connector.

processEvent

public void processEvent(String event)

Method to pass an event received on topic to the Lineage Integrator OMIS to be published to listening integration connectors.

Specified by:

processEvent in interface OpenMetadataTopicListener

Parameters:

event - inbound event

refresh

public void refresh()

No function needed in refresh()

Specified by:

refresh in interface IntegrationConnector

disconnect

public void disconnect()
                throws ConnectorCheckedException

Shutdown event monitoring

Specified by:

disconnect in interface IntegrationConnector

Overrides:

disconnect in class IntegrationConnectorBase

Throws:

ConnectorCheckedException - something failed in the super class