Package org.odpi.openmetadata.integrationservices.search.connector

Class SearchIntegratorConnector

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.search.connector.SearchIntegratorConnector

All Implemented Interfaces:

AuditLoggingComponent, SecureConnectorExtension, VirtualConnectorExtension, IntegrationConnector, SearchIntegratorOMISConnector

Direct Known Subclasses:

ElasticsearchIntegrationConnector

public abstract class SearchIntegratorConnector
extends IntegrationConnectorBase
implements SearchIntegratorOMISConnector

SearchIntegratorConnector is the base class for an integration connector that is managed by the Search Integrator OMIS.

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
SearchIntegratorConnector()	Constructor
SearchIntegratorConnector(SearchIntegratorContext context)	Constructor

Method Summary

Modifier and Type	Method	Description
SearchIntegratorContext	getContext()	Return the context for this connector.
abstract void	saveAsset(AssetCatalogEvent assetCatalogEvent)	Save the events received from asset catalog to the Elasticsearch service
void	setContext(SearchIntegratorContext context)	Set up the context for this connector.

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

disconnect, engage, getConnectorComponentDescription, initializeEmbeddedConnectors, refreshCatalogTargets, setAuditLog, setConnectorName, setContext

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

disconnectConnectors, equals, getArrayConfigurationProperty, getAssetTypeName, getBooleanConfigurationProperty, getConnectedAssetProperties, getConnection, getConnectorInstanceId, getIntConfigurationProperty, getNetworkAddresses, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initialize, initializeConnectedAssetProperties, initializeSecretsStoreConnector, isActive, start, throwMissingResource, throwNoAsset, throwWrongTypeOfAsset, throwWrongTypeOfResource, throwWrongTypeOfRootSchema, 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

Methods inherited from interface org.odpi.openmetadata.frameworks.integration.connectors.IntegrationConnector

refresh, start

Constructor Details

SearchIntegratorConnector

public SearchIntegratorConnector()

Constructor

SearchIntegratorConnector

public SearchIntegratorConnector(SearchIntegratorContext context)

Constructor

Parameters:

context - integration context

Method Details

setContext

public void setContext(SearchIntegratorContext context)

Set up the context for this connector. It is called by the context manager.

Parameters:

context - context for this connector's private use.

getContext

public SearchIntegratorContext getContext()
                                   throws ConnectorCheckedException

Return the context for this connector. It is called by the connector.

Returns:

context for this connector's private use.

Throws:

ConnectorCheckedException - internal issue setting up context

saveAsset

public abstract void saveAsset(AssetCatalogEvent assetCatalogEvent)

Save the events received from asset catalog to the Elasticsearch service

Parameters:

assetCatalogEvent - the event which contains the asset