Package io.jmix.searchopensearch.index.impl

Class OpenSearchIndexManager

java.lang.Object

io.jmix.search.index.impl.BaseIndexManager

io.jmix.searchopensearch.index.impl.OpenSearchIndexManager

All Implemented Interfaces:

IndexManager

public class OpenSearchIndexManager
extends BaseIndexManager

Implementation for OpenSearch

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.opensearch.client.opensearch.OpenSearchClient	client
protected final OpenSearchIndexSettingsProvider	indexSettingsProcessor
protected final com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Fields inherited from class io.jmix.search.index.impl.BaseIndexManager

indexConfigurationManager, indexStateRegistry, MAP_TYPE_REF, searchProperties

Constructor Summary

Constructors

Constructor	Description
OpenSearchIndexManager(org.opensearch.client.opensearch.OpenSearchClient client, IndexStateRegistry indexStateRegistry, IndexConfigurationManager indexConfigurationManager, SearchProperties searchProperties, OpenSearchIndexSettingsProvider indexSettingsProcessor)

Method Summary

Modifier and Type	Method	Description
protected org.opensearch.client.opensearch._types.mapping.TypeMapping	buildMapping(IndexConfiguration indexConfiguration)
protected org.opensearch.client.opensearch.indices.IndexSettings	buildSettings(IndexConfiguration indexConfiguration)
boolean	createIndex(IndexConfiguration indexConfiguration)	Creates index if not exists using provided IndexConfiguration.
boolean	dropIndex(String indexName)	Drops index by name.
com.fasterxml.jackson.databind.node.ObjectNode	getIndexMetadata(String indexName)	Requests info about index from server.
protected org.opensearch.client.opensearch.indices.IndexState	getIndexMetadataInternal(String indexName)
protected Map<String,org.opensearch.client.opensearch.indices.IndexState>	getIndexMetadataMapInternal(String indexName)
protected boolean	isIndexActual(IndexConfiguration indexConfiguration)
boolean	isIndexExist(String indexName)	Checks if index exists.
protected boolean	isIndexMappingActual(IndexConfiguration indexConfiguration, org.opensearch.client.opensearch.indices.IndexState currentIndexState)
protected boolean	isIndexSettingsActual(IndexConfiguration indexConfiguration, org.opensearch.client.opensearch.indices.IndexState currentIndexState)
protected com.fasterxml.jackson.databind.JsonNode	toJsonNode(org.opensearch.client.json.JsonpSerializable object)
protected com.fasterxml.jackson.databind.node.ObjectNode	toObjectNode(org.opensearch.client.json.JsonpSerializable object)

Methods inherited from class io.jmix.search.index.impl.BaseIndexManager

handleIrrelevantIndex, handleMissingIndex, nodeContains, recreateIndex, recreateIndexes, recreateIndexes, synchronizeIndexSchema, synchronizeIndexSchema, synchronizeIndexSchemas, synchronizeIndexSchemas, validateIndex, validateIndexes, validateIndexes

Methods inherited from class java.lang.Object

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

Field Details

client

protected final org.opensearch.client.opensearch.OpenSearchClient client

indexSettingsProcessor

protected final OpenSearchIndexSettingsProvider indexSettingsProcessor

objectMapper

protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Details

OpenSearchIndexManager

public OpenSearchIndexManager(org.opensearch.client.opensearch.OpenSearchClient client,
 IndexStateRegistry indexStateRegistry,
 IndexConfigurationManager indexConfigurationManager,
 SearchProperties searchProperties,
 OpenSearchIndexSettingsProvider indexSettingsProcessor)

Method Details

createIndex

public boolean createIndex(IndexConfiguration indexConfiguration)

Description copied from interface: IndexManager

Creates index if not exists using provided IndexConfiguration.

Parameters:

indexConfiguration - index configuration

Returns:

true if index was successfully created, false otherwise

dropIndex

public boolean dropIndex(String indexName)

Description copied from interface: IndexManager

Drops index by name.

Parameters:

indexName - index name

Returns:

true if index was successfully dropped, false otherwise

isIndexExist

public boolean isIndexExist(String indexName)

Description copied from interface: IndexManager

Checks if index exists.

Parameters:

indexName - index name

Returns:

true if index exists, false otherwise

getIndexMetadata

public com.fasterxml.jackson.databind.node.ObjectNode getIndexMetadata(String indexName)

Description copied from interface: IndexManager

Requests info about index from server.

Parameters:

indexName - index name

Returns:

response as Json

isIndexActual

protected boolean isIndexActual(IndexConfiguration indexConfiguration)

Specified by:

isIndexActual in class BaseIndexManager

buildMapping

protected org.opensearch.client.opensearch._types.mapping.TypeMapping buildMapping(IndexConfiguration indexConfiguration)

buildSettings

protected org.opensearch.client.opensearch.indices.IndexSettings buildSettings(IndexConfiguration indexConfiguration)

toJsonNode

protected com.fasterxml.jackson.databind.JsonNode toJsonNode(org.opensearch.client.json.JsonpSerializable object)

toObjectNode

protected com.fasterxml.jackson.databind.node.ObjectNode toObjectNode(org.opensearch.client.json.JsonpSerializable object)

getIndexMetadataMapInternal

protected Map<String,org.opensearch.client.opensearch.indices.IndexState> getIndexMetadataMapInternal(String indexName)

getIndexMetadataInternal

@Nullable
protected org.opensearch.client.opensearch.indices.IndexState getIndexMetadataInternal(String indexName)

isIndexMappingActual

protected boolean isIndexMappingActual(IndexConfiguration indexConfiguration,
 org.opensearch.client.opensearch.indices.IndexState currentIndexState)

isIndexSettingsActual

protected boolean isIndexSettingsActual(IndexConfiguration indexConfiguration,
 org.opensearch.client.opensearch.indices.IndexState currentIndexState)