Package io.jmix.searchopensearch.index.impl

Class OpenSearchEntityIndexer

java.lang.Object

io.jmix.search.index.impl.BaseEntityIndexer

io.jmix.searchopensearch.index.impl.OpenSearchEntityIndexer

All Implemented Interfaces:

EntityIndexer

public class OpenSearchEntityIndexer
extends BaseEntityIndexer

Implementation for OpenSearch

Nested Class Summary

Nested classes/interfaces inherited from class io.jmix.search.index.impl.BaseEntityIndexer

BaseEntityIndexer.IndexDocumentData

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.opensearch.client.opensearch.OpenSearchClient	client

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

dataManager, fetchPlans, idSerialization, indexConfigurationManager, indexStateRegistry, metadata, metadataTools, objectMapper, searchProperties

Constructor Summary

Constructors

Constructor	Description
OpenSearchEntityIndexer(UnconstrainedDataManager dataManager, FetchPlans fetchPlans, IndexConfigurationManager indexConfigurationManager, Metadata metadata, IdSerialization idSerialization, IndexStateRegistry indexStateRegistry, MetadataTools metadataTools, SearchProperties searchProperties, org.opensearch.client.opensearch.OpenSearchClient client)

Method Summary

Modifier and Type	Method	Description
protected IndexResult	createIndexResult(org.opensearch.client.opensearch.core.BulkResponse response)
protected org.opensearch.client.opensearch.core.BulkResponse	createNoopBulkResponse()
protected IndexResult	deleteByGroupedDocIds(Map<IndexConfiguration,Collection<String>> groupedDocIds)
protected org.opensearch.client.opensearch.core.BulkResponse	execute(org.opensearch.client.opensearch.core.BulkRequest.Builder requestBuilder)
protected org.opensearch.client.opensearch.core.BulkResponse	executeBulkRequest(org.opensearch.client.opensearch.core.BulkRequest request)
protected IndexResult	indexDocuments(List<BaseEntityIndexer.IndexDocumentData> documents)
protected org.opensearch.client.opensearch._types.Refresh	resolveRefresh()

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

addFieldValueToEntityIndexContent, createFetchPlan, createObjectNodeForField, delete, deleteByEntityId, deleteByGroupedIndexIdsInternal, deleteCollection, deleteCollectionByEntityIds, generateIndexDocument, index, indexByEntityId, indexCollection, indexCollectionByEntityIds, indexGroupedInstances, merge, prepareIndexIdsByEntityIds, prepareIndexIdsByEntityInstances, prepareInstancesForIndexing, prepareInstancesForIndexingByIds, reloadEntityInstances, updateArray, updateObject

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

Constructor Details

OpenSearchEntityIndexer

public OpenSearchEntityIndexer(UnconstrainedDataManager dataManager,
 FetchPlans fetchPlans,
 IndexConfigurationManager indexConfigurationManager,
 Metadata metadata,
 IdSerialization idSerialization,
 IndexStateRegistry indexStateRegistry,
 MetadataTools metadataTools,
 SearchProperties searchProperties,
 org.opensearch.client.opensearch.OpenSearchClient client)

Method Details

indexDocuments

protected IndexResult indexDocuments(List<BaseEntityIndexer.IndexDocumentData> documents)

Specified by:

indexDocuments in class BaseEntityIndexer

deleteByGroupedDocIds

protected IndexResult deleteByGroupedDocIds(Map<IndexConfiguration,Collection<String>> groupedDocIds)

Specified by:

deleteByGroupedDocIds in class BaseEntityIndexer

execute

protected org.opensearch.client.opensearch.core.BulkResponse execute(org.opensearch.client.opensearch.core.BulkRequest.Builder requestBuilder)

executeBulkRequest

protected org.opensearch.client.opensearch.core.BulkResponse executeBulkRequest(org.opensearch.client.opensearch.core.BulkRequest request)

createNoopBulkResponse

protected org.opensearch.client.opensearch.core.BulkResponse createNoopBulkResponse()

createIndexResult

protected IndexResult createIndexResult(org.opensearch.client.opensearch.core.BulkResponse response)

resolveRefresh

protected org.opensearch.client.opensearch._types.Refresh resolveRefresh()