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 -
Method Summary
Modifier and TypeMethodDescriptionvoid
Shutdown event monitoringvoid
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
-
Constructor Details
-
OpenLineageEventReceiverIntegrationConnector
public OpenLineageEventReceiverIntegrationConnector()Default constructor
-
-
Method Details
-
start
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 interfaceIntegrationConnector
- Overrides:
start
in classConnectorBase
- Throws:
ConnectorCheckedException
- there is a problem within the connector.
-
processEvent
Method to pass an event received on topic to the Lineage Integrator OMIS to be published to listening integration connectors.- Specified by:
processEvent
in interfaceOpenMetadataTopicListener
- Parameters:
event
- inbound event
-
refresh
public void refresh()No function needed in refresh()- Specified by:
refresh
in interfaceIntegrationConnector
-
disconnect
Shutdown event monitoring- Specified by:
disconnect
in interfaceIntegrationConnector
- Overrides:
disconnect
in classIntegrationConnectorBase
- Throws:
ConnectorCheckedException
- something failed in the super class
-