com.flowable.indexing.impl

Class IndexingServiceImpl

java.lang.Object

com.flowable.indexing.impl.IndexingServiceImpl

All Implemented Interfaces:

IndexingService, LowLevelIndexingService

public class IndexingServiceImpl
extends Object
implements IndexingService, LowLevelIndexingService

Field Summary

Fields

Modifier and Type	Field and Description
protected org.flowable.spring.job.service.SpringAsyncHistoryExecutor	asyncHistoryExecutor
protected List<BulkIndexRequestInterceptor>	bulkIndexRequestInterceptors
protected ElasticsearchClient	elasticsearchClient
protected boolean	indexingEnabled
protected IndexManager	indexManager
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected ObjectSerializationService	objectSerializationService

Constructor Summary

Constructors

Constructor and Description
IndexingServiceImpl(boolean indexingEnabled, ElasticsearchClient elasticsearchClient, ObjectSerializationService objectSerializationService, IndexManager indexManager, com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.flowable.spring.job.service.SpringAsyncHistoryExecutor asyncHistoryExecutor, List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors)

Method Summary

Modifier and Type	Method and Description
void	addToBulkIndexRequest(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, com.fasterxml.jackson.databind.node.ObjectNode data, String idFieldName)
protected org.flowable.job.service.impl.persistence.entity.HistoryJobEntity	createHistoryJobEntity(String handlerType)
void	deleteByQuery(String aliasName, com.fasterxml.jackson.databind.node.ObjectNode query) Delete indexed objects based on a query.
void	deleteIndexedObject(String aliasName, String id) Delete the indexed object using the provided id.
protected String	determineIndex(IndexMapping indexMapping)
protected String	determineIndex(com.fasterxml.jackson.databind.node.ObjectNode objectNode, IndexedDataObject indexedDataObject)
void	indexObject(Object object, String idFieldName) Similar to LowLevelIndexingService.indexObject(Object), but by providing an alternative field name that contains the id, instead of depending on the IndexingJsonConstants.PROPERTY_ID in the json.
boolean	isIndexingEnabled()
void	scheduleIndexedObjectDelete(String aliasName, String id) Schedule a delete of an object from an index.
void	scheduleIndexing(Object object, String tenantId) Schedule to index a generic object, that will pass the IndexableObjectSerializer first.
void	scheduleIndexing(String type, com.fasterxml.jackson.databind.node.ObjectNode dataNode, String tenantId) Schedule the json directly to be indexed using the provided type.
protected com.fasterxml.jackson.databind.node.ObjectNode	serializeObject(Object object)
protected List<IndexedDataObject>	transformObjectToIndexedDataObjects(com.fasterxml.jackson.databind.node.ObjectNode objectNode, String idFieldName)
void	updateByQuery(String mappingType, com.fasterxml.jackson.databind.node.ObjectNode data) Perform Update by Query for the given Mapping type.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.flowable.indexing.api.LowLevelIndexingService

addToBulkIndexRequest, indexObject

Field Detail

indexingEnabled

protected boolean indexingEnabled

elasticsearchClient

protected ElasticsearchClient elasticsearchClient

objectSerializationService

protected ObjectSerializationService objectSerializationService

indexManager

protected IndexManager indexManager

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

asyncHistoryExecutor

protected org.flowable.spring.job.service.SpringAsyncHistoryExecutor asyncHistoryExecutor

bulkIndexRequestInterceptors

protected List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors

Constructor Detail

IndexingServiceImpl

public IndexingServiceImpl(boolean indexingEnabled,
                           ElasticsearchClient elasticsearchClient,
                           ObjectSerializationService objectSerializationService,
                           IndexManager indexManager,
                           com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                           org.flowable.spring.job.service.SpringAsyncHistoryExecutor asyncHistoryExecutor,
                           List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors)

Method Detail

isIndexingEnabled

public boolean isIndexingEnabled()

Specified by:

isIndexingEnabled in interface IndexingService

indexObject

public void indexObject(Object object,
                        String idFieldName)

Description copied from interface: LowLevelIndexingService

Similar to LowLevelIndexingService.indexObject(Object), but by providing an alternative field name that contains the id, instead of depending on the IndexingJsonConstants.PROPERTY_ID in the json.

Specified by:

indexObject in interface LowLevelIndexingService

transformObjectToIndexedDataObjects

protected List<IndexedDataObject> transformObjectToIndexedDataObjects(com.fasterxml.jackson.databind.node.ObjectNode objectNode,
                                                                      String idFieldName)

serializeObject

protected com.fasterxml.jackson.databind.node.ObjectNode serializeObject(Object object)

scheduleIndexing

public void scheduleIndexing(Object object,
                             String tenantId)

Description copied from interface: IndexingService

Schedule to index a generic object, that will pass the IndexableObjectSerializer first.

Specified by:

scheduleIndexing in interface IndexingService

scheduleIndexing

public void scheduleIndexing(String type,
                             com.fasterxml.jackson.databind.node.ObjectNode dataNode,
                             String tenantId)

Description copied from interface: IndexingService

Schedule the json directly to be indexed using the provided type.

Specified by:

scheduleIndexing in interface IndexingService

deleteIndexedObject

public void deleteIndexedObject(String aliasName,
                                String id)

Description copied from interface: LowLevelIndexingService

Delete the indexed object using the provided id.

Specified by:

deleteIndexedObject in interface LowLevelIndexingService

deleteByQuery

public void deleteByQuery(String aliasName,
                          com.fasterxml.jackson.databind.node.ObjectNode query)

Description copied from interface: LowLevelIndexingService

Delete indexed objects based on a query.

Specified by:

deleteByQuery in interface LowLevelIndexingService

updateByQuery

public void updateByQuery(String mappingType,
                          com.fasterxml.jackson.databind.node.ObjectNode data)

Description copied from interface: LowLevelIndexingService

Perform Update by Query for the given Mapping type.

Specified by:

updateByQuery in interface LowLevelIndexingService

Parameters:

mappingType - the type of the mapping for which the update should be done

data - the update by query request data

scheduleIndexedObjectDelete

public void scheduleIndexedObjectDelete(String aliasName,
                                        String id)

Description copied from interface: IndexingService

Schedule a delete of an object from an index.

Specified by:

scheduleIndexedObjectDelete in interface IndexingService

addToBulkIndexRequest

public void addToBulkIndexRequest(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
                                  com.fasterxml.jackson.databind.node.ObjectNode data,
                                  String idFieldName)

Specified by:

addToBulkIndexRequest in interface LowLevelIndexingService

determineIndex

protected String determineIndex(com.fasterxml.jackson.databind.node.ObjectNode objectNode,
                                IndexedDataObject indexedDataObject)

determineIndex

protected String determineIndex(IndexMapping indexMapping)

createHistoryJobEntity

protected org.flowable.job.service.impl.persistence.entity.HistoryJobEntity createHistoryJobEntity(String handlerType)