Package io.jmix.searchelasticsearch.index.impl

Class ElasticsearchEntityIndexer

java.lang.Object

io.jmix.search.index.impl.BaseEntityIndexer

io.jmix.searchelasticsearch.index.impl.ElasticsearchEntityIndexer

All Implemented Interfaces:

EntityIndexer

public class ElasticsearchEntityIndexer
extends BaseEntityIndexer

Implementation for Elasticsearch

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 co.elastic.clients.elasticsearch.ElasticsearchClient	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
ElasticsearchEntityIndexer(UnconstrainedDataManager dataManager, FetchPlans fetchPlans, IndexConfigurationManager indexConfigurationManager, Metadata metadata, IdSerialization idSerialization, IndexStateRegistry indexStateRegistry, MetadataTools metadataTools, SearchProperties searchProperties, co.elastic.clients.elasticsearch.ElasticsearchClient client)

Method Summary

Modifier and Type	Method	Description
protected IndexResult	createIndexResult(co.elastic.clients.elasticsearch.core.BulkResponse response)
protected co.elastic.clients.elasticsearch.core.BulkResponse	createNoopBulkResponse()
protected IndexResult	deleteByGroupedDocIds(Map<IndexConfiguration,Collection<String>> groupedDocIds)
protected co.elastic.clients.elasticsearch.core.BulkResponse	execute(co.elastic.clients.elasticsearch.core.BulkRequest.Builder requestBuilder)
protected co.elastic.clients.elasticsearch.core.BulkResponse	executeBulkRequest(co.elastic.clients.elasticsearch.core.BulkRequest request)
protected IndexResult	indexDocuments(List<BaseEntityIndexer.IndexDocumentData> documents)
protected co.elastic.clients.elasticsearch._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 co.elastic.clients.elasticsearch.ElasticsearchClient client

Constructor Details

ElasticsearchEntityIndexer

public ElasticsearchEntityIndexer(UnconstrainedDataManager dataManager,
 FetchPlans fetchPlans,
 IndexConfigurationManager indexConfigurationManager,
 Metadata metadata,
 IdSerialization idSerialization,
 IndexStateRegistry indexStateRegistry,
 MetadataTools metadataTools,
 SearchProperties searchProperties,
 co.elastic.clients.elasticsearch.ElasticsearchClient 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 co.elastic.clients.elasticsearch.core.BulkResponse execute(co.elastic.clients.elasticsearch.core.BulkRequest.Builder requestBuilder)

executeBulkRequest

protected co.elastic.clients.elasticsearch.core.BulkResponse executeBulkRequest(co.elastic.clients.elasticsearch.core.BulkRequest request)

createNoopBulkResponse

protected co.elastic.clients.elasticsearch.core.BulkResponse createNoopBulkResponse()

createIndexResult

protected IndexResult createIndexResult(co.elastic.clients.elasticsearch.core.BulkResponse response)

resolveRefresh

protected co.elastic.clients.elasticsearch._types.Refresh resolveRefresh()