Class ElasticsearchIntegrationConnector
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
org.odpi.openmetadata.adapters.connectors.integration.elasticsearch.ElasticsearchIntegrationConnector
- All Implemented Interfaces:
AuditLoggingComponent
,SecureConnectorExtension
,VirtualConnectorExtension
,IntegrationConnector
,SearchIntegratorOMISConnector
ElasticsearchIntegrationConnector provides common methods for the connector in this module.
-
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 monitoringvoid
initialize
(String connectorInstanceId, ConnectionProperties connectionProperties) Initialize the connector.void
initializeElasticSearchClient
(String callingMethodName) void
refresh()
void
saveAsset
(AssetCatalogEvent assetCatalogEvent) Save the events received from asset catalog to the Elasticsearch servicevoid
start()
Indicates that the connector is completely configured and can begin processing.Methods inherited from class org.odpi.openmetadata.integrationservices.search.connector.SearchIntegratorConnector
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
disconnectConnectors, equals, getConnectedAssetProperties, getConnection, getConnectorInstanceId, hashCode, 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
-
ElasticsearchIntegrationConnector
public ElasticsearchIntegrationConnector()
-
-
Method Details
-
initialize
Initialize the connector.- Overrides:
initialize
in classConnectorBase
- Parameters:
connectorInstanceId
- - unique id for the connector instance - useful for messages etcconnectionProperties
- - POJO for the configuration used to create the connector.
-
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.
-
refresh
- Throws:
ConnectorCheckedException
- there is a problem with the connector. It is not able to refresh the metadata.
-
disconnect
Shutdown monitoring- Specified by:
disconnect
in interfaceIntegrationConnector
- Overrides:
disconnect
in classIntegrationConnectorBase
- Throws:
ConnectorCheckedException
- something failed in the super class
-
initializeElasticSearchClient
public void initializeElasticSearchClient(String callingMethodName) throws ConnectorCheckedException - Throws:
ConnectorCheckedException
-
saveAsset
Save the events received from asset catalog to the Elasticsearch service- Specified by:
saveAsset
in classSearchIntegratorConnector
- Parameters:
assetCatalogEvent
- the event which contains the asset
-