Package io.jmix.search.index.impl

Class EntityIndexerImpl

java.lang.Object

io.jmix.search.index.impl.EntityIndexerImpl

All Implemented Interfaces:

EntityIndexer

@Component("search_EntityIndexer")
public class EntityIndexerImpl
extends Object
implements EntityIndexer

Field Summary

Fields

Modifier and Type	Field	Description
protected UnconstrainedDataManager	dataManager
protected org.elasticsearch.client.RestHighLevelClient	esClient
protected FetchPlans	fetchPlans
protected IdSerialization	idSerialization
protected IndexConfigurationManager	indexConfigurationManager
protected IndexStateRegistry	indexStateRegistry
protected Metadata	metadata
protected MetadataTools	metadataTools
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected SearchProperties	searchProperties

Constructor Summary

Constructors

Constructor	Description
EntityIndexerImpl()

Method Summary

Modifier and Type	Method	Description
protected void	addDeleteActionToBulkRequest(org.elasticsearch.action.bulk.BulkRequest request, IndexConfiguration indexConfiguration, String indexId)
protected void	addFieldValueToEntityIndexContent(com.fasterxml.jackson.databind.node.ObjectNode entityIndexContent, MappingFieldDescriptor field, Object entity)
protected void	addIndexActionToBulkRequest(org.elasticsearch.action.bulk.BulkRequest request, IndexConfiguration indexConfiguration, Object instance)
protected FetchPlan	createFetchPlan(IndexConfiguration indexConfiguration)
protected org.elasticsearch.action.bulk.BulkResponse	createNoopBulkResponse()
protected com.fasterxml.jackson.databind.node.ObjectNode	createObjectNodeForField(String key, com.fasterxml.jackson.databind.JsonNode value)
IndexResult	delete(Object entityInstance)	Deletes provided entity instance from index.
IndexResult	deleteByEntityId(Id<?> entityId)	Deletes entity instance from index by provided ID.
protected IndexResult	deleteByGroupedIndexIds(Map<IndexConfiguration,Collection<String>> groupedIndexIds)
IndexResult	deleteCollection(Collection<Object> entityInstances)	Deletes provided entity instances from index.
IndexResult	deleteCollectionByEntityIds(Collection<Id<?>> entityIds)	Deletes entity instances from index by provided IDs.
protected org.elasticsearch.action.bulk.BulkResponse	executeBulkRequest(org.elasticsearch.action.bulk.BulkRequest request)
IndexResult	index(Object entityInstance)	Stores provided entity instance to index.
IndexResult	indexByEntityId(Id<?> entityId)	Stores entity instance to index by provided ID.
IndexResult	indexCollection(Collection<Object> entityInstances)	Stores provided entity instances to index.
IndexResult	indexCollectionByEntityIds(Collection<Id<?>> entityIds)	Stores entity instances to index by provided IDs.
protected IndexResult	indexGroupedInstances(Map<IndexConfiguration,Collection<Object>> groupedInstancesForIndexing)
protected Map<IndexConfiguration,Collection<String>>	prepareIndexIdsByEntityIds(Collection<Id<?>> entityIds)
protected Map<IndexConfiguration,Collection<String>>	prepareIndexIdsByEntityInstances(Collection<Object> instances)
protected Map<IndexConfiguration,Collection<Object>>	prepareInstancesForIndexing(Collection<Object> instances)
protected Map<IndexConfiguration,Collection<Object>>	prepareInstancesForIndexingByIds(Collection<Id<?>> entityIds)
protected Map<IndexConfiguration,Collection<Object>>	reloadEntityInstances(Map<MetaClass,List<Object>> idsGroupedByMetaClass)

Methods inherited from class java.lang.Object

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

Field Details

dataManager

@Autowired
protected UnconstrainedDataManager dataManager

fetchPlans

@Autowired
protected FetchPlans fetchPlans

esClient

@Autowired
protected org.elasticsearch.client.RestHighLevelClient esClient

indexConfigurationManager

@Autowired
protected IndexConfigurationManager indexConfigurationManager

metadata

@Autowired
protected Metadata metadata

idSerialization

@Autowired
protected IdSerialization idSerialization

indexStateRegistry

@Autowired
protected IndexStateRegistry indexStateRegistry

metadataTools

@Autowired
protected MetadataTools metadataTools

searchProperties

@Autowired
protected SearchProperties searchProperties

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Details

EntityIndexerImpl

public EntityIndexerImpl()

Method Details

index

public IndexResult index(Object entityInstance)

Description copied from interface: EntityIndexer

Stores provided entity instance to index.

Specified by:

index in interface EntityIndexer

Parameters:

entityInstance - instance

Returns:

IndexResult

indexCollection

public IndexResult indexCollection(Collection<Object> entityInstances)

Description copied from interface: EntityIndexer

Stores provided entity instances to index.

Specified by:

indexCollection in interface EntityIndexer

Parameters:

entityInstances - instances

Returns:

IndexResult

indexByEntityId

public IndexResult indexByEntityId(Id<?> entityId)

Description copied from interface: EntityIndexer

Stores entity instance to index by provided ID.

Specified by:

indexByEntityId in interface EntityIndexer

Parameters:

entityId - ID of entity instance

Returns:

IndexResult

indexCollectionByEntityIds

public IndexResult indexCollectionByEntityIds(Collection<Id<?>> entityIds)

Description copied from interface: EntityIndexer

Stores entity instances to index by provided IDs.

Specified by:

indexCollectionByEntityIds in interface EntityIndexer

Parameters:

entityIds - IDs of entity instances

Returns:

IndexResult

delete

public IndexResult delete(Object entityInstance)

Description copied from interface: EntityIndexer

Deletes provided entity instance from index.

Specified by:

delete in interface EntityIndexer

Parameters:

entityInstance - instance

Returns:

IndexResult

deleteCollection

public IndexResult deleteCollection(Collection<Object> entityInstances)

Description copied from interface: EntityIndexer

Deletes provided entity instances from index.

Specified by:

deleteCollection in interface EntityIndexer

Parameters:

entityInstances - instances

Returns:

IndexResult

deleteByEntityId

public IndexResult deleteByEntityId(Id<?> entityId)

Description copied from interface: EntityIndexer

Deletes entity instance from index by provided ID.

Specified by:

deleteByEntityId in interface EntityIndexer

Parameters:

entityId - ID of entity instance

Returns:

IndexResult

deleteCollectionByEntityIds

public IndexResult deleteCollectionByEntityIds(Collection<Id<?>> entityIds)

Description copied from interface: EntityIndexer

Deletes entity instances from index by provided IDs.

Specified by:

deleteCollectionByEntityIds in interface EntityIndexer

Parameters:

entityIds - IDs of entity instances

Returns:

IndexResult

indexGroupedInstances

protected IndexResult indexGroupedInstances(Map<IndexConfiguration,Collection<Object>> groupedInstancesForIndexing)

executeBulkRequest

protected org.elasticsearch.action.bulk.BulkResponse executeBulkRequest(org.elasticsearch.action.bulk.BulkRequest request)

prepareInstancesForIndexing

protected Map<IndexConfiguration,Collection<Object>> prepareInstancesForIndexing(Collection<Object> instances)

prepareInstancesForIndexingByIds

protected Map<IndexConfiguration,Collection<Object>> prepareInstancesForIndexingByIds(Collection<Id<?>> entityIds)

reloadEntityInstances

protected Map<IndexConfiguration,Collection<Object>> reloadEntityInstances(Map<MetaClass,List<Object>> idsGroupedByMetaClass)

createFetchPlan

protected FetchPlan createFetchPlan(IndexConfiguration indexConfiguration)

addIndexActionToBulkRequest

protected void addIndexActionToBulkRequest(org.elasticsearch.action.bulk.BulkRequest request,
 IndexConfiguration indexConfiguration,
 Object instance)

prepareIndexIdsByEntityInstances

protected Map<IndexConfiguration,Collection<String>> prepareIndexIdsByEntityInstances(Collection<Object> instances)

prepareIndexIdsByEntityIds

protected Map<IndexConfiguration,Collection<String>> prepareIndexIdsByEntityIds(Collection<Id<?>> entityIds)

deleteByGroupedIndexIds

protected IndexResult deleteByGroupedIndexIds(Map<IndexConfiguration,Collection<String>> groupedIndexIds)

addDeleteActionToBulkRequest

protected void addDeleteActionToBulkRequest(org.elasticsearch.action.bulk.BulkRequest request,
 IndexConfiguration indexConfiguration,
 String indexId)

createObjectNodeForField

protected com.fasterxml.jackson.databind.node.ObjectNode createObjectNodeForField(String key,
 com.fasterxml.jackson.databind.JsonNode value)

addFieldValueToEntityIndexContent

protected void addFieldValueToEntityIndexContent(com.fasterxml.jackson.databind.node.ObjectNode entityIndexContent,
 MappingFieldDescriptor field,
 Object entity)

createNoopBulkResponse

protected org.elasticsearch.action.bulk.BulkResponse createNoopBulkResponse()