Package de.cxp.ocs.elasticsearch

Class ElasticsearchIndexer

java.lang.Object

de.cxp.ocs.indexer.AbstractIndexer

de.cxp.ocs.elasticsearch.ElasticsearchIndexer

All Implemented Interfaces:

FullIndexationService, UpdateIndexService

public class ElasticsearchIndexer
extends AbstractIndexer

Nested Class Summary

Nested classes/interfaces inherited from interface de.cxp.ocs.api.indexer.UpdateIndexService

UpdateIndexService.Result

Constructor Summary

Constructors

Constructor	Description
ElasticsearchIndexer(IndexSettings settings, FieldConfigIndex fieldConfAccess, org.elasticsearch.client.RestHighLevelClient restClient, List<DocumentPreProcessor> preProcessors, List<DocumentPostProcessor> postProcessors)

Method Summary

Modifier and Type	Method	Description
protected Document	_get(String indexName, @NonNull String id)
protected UpdateIndexService.Result	_patch(String index, IndexableItem doc)
protected UpdateIndexService.Result	_put(String indexName, Boolean replaceExisting, IndexableItem doc)
protected int	addToIndex(ImportSession session, List<IndexableItem> bulk)
protected void	cleanupAbandonedImports(String indexName, int minAgeSeconds)
Map<String,UpdateIndexService.Result>	deleteDocuments(String indexName, List<String> ids)	Delete existing document.
protected void	deleteIndex(String indexName)
boolean	deploy(ImportSession session)
boolean	indexExists(String indexName)
protected String	initNewIndex(String indexName, String locale)	checks to which actual index this "nice indexName (alias)" points to.
boolean	isImportRunning(String indexName)	Checks if an active import session exists for that index.
protected void	validateSession(ImportSession session)

Methods inherited from class de.cxp.ocs.indexer.AbstractIndexer

add, cancel, done, patchDocument, patchDocuments, putDocument, putDocuments, putDocuments, startImport

Methods inherited from class java.lang.Object

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

Constructor Details

ElasticsearchIndexer

public ElasticsearchIndexer(IndexSettings settings,
 FieldConfigIndex fieldConfAccess,
 org.elasticsearch.client.RestHighLevelClient restClient,
 List<DocumentPreProcessor> preProcessors,
 List<DocumentPostProcessor> postProcessors)

Method Details

indexExists

public boolean indexExists(String indexName)

Specified by:

indexExists in class AbstractIndexer

isImportRunning

public boolean isImportRunning(String indexName)

Description copied from class: AbstractIndexer

Checks if an active import session exists for that index.

This could either be the full internal or the minimal/final index name.

Specified by:

isImportRunning in class AbstractIndexer

Parameters:

indexName - internal or external index name

Returns:

initNewIndex

protected String initNewIndex(String indexName,
 String locale)
                       throws IOException

checks to which actual index this "nice indexName (alias)" points to. Expects a indexName ending with a number and will return a new index name

Specified by:

initNewIndex in class AbstractIndexer

Throws:

IOException

validateSession

protected void validateSession(ImportSession session)
                        throws IllegalArgumentException

Specified by:

validateSession in class AbstractIndexer

Throws:

IllegalArgumentException

addToIndex

protected int addToIndex(ImportSession session,
 List<IndexableItem> bulk)
                  throws Exception

Specified by:

addToIndex in class AbstractIndexer

Throws:

Exception

deploy

public boolean deploy(ImportSession session)

Specified by:

deploy in class AbstractIndexer

deleteIndex

protected void deleteIndex(String indexName)

Specified by:

deleteIndex in class AbstractIndexer

_patch

protected UpdateIndexService.Result _patch(String index,
 IndexableItem doc)

Specified by:

_patch in class AbstractIndexer

_put

protected UpdateIndexService.Result _put(String indexName,
 Boolean replaceExisting,
 IndexableItem doc)

Specified by:

_put in class AbstractIndexer

deleteDocuments

public Map<String,UpdateIndexService.Result> deleteDocuments(String indexName,
 List<String> ids)

Description copied from interface: UpdateIndexService

Delete existing document. If document does not exist, it returns code 404.

Parameters:

indexName - name of the index that should receive that update

ids - Array of IDs of the documents that should be deleted

Returns:

Result code, one of DELETED, NOT_FOUND

_get

protected Document _get(String indexName,
 @NonNull
 @NonNull String id)

Specified by:

_get in class AbstractIndexer

cleanupAbandonedImports

protected void cleanupAbandonedImports(String indexName,
 int minAgeSeconds)

Specified by:

cleanupAbandonedImports in class AbstractIndexer