org.nuxeo.elasticsearch.core

Class ElasticSearchIndexingImpl

java.lang.Object

org.nuxeo.elasticsearch.core.ElasticSearchIndexingImpl

All Implemented Interfaces:

ElasticSearchIndexing

public class ElasticSearchIndexingImpl
extends Object
implements ElasticSearchIndexing

Since:

6.0

Constructor Summary

Constructors

Constructor and Description
ElasticSearchIndexingImpl(ElasticSearchAdminImpl esa)
ElasticSearchIndexingImpl(ElasticSearchAdminImpl esa, JsonESDocumentWriter jsonESDocumentWriter)

Method Summary

Modifier and Type	Method and Description
void	indexNonRecursive(IndexingCommand cmd) Process the IndexingCommand.
void	indexNonRecursive(List<IndexingCommand> cmds) Same as ElasticSearchIndexing.indexNonRecursive(org.nuxeo.elasticsearch.commands.IndexingCommand) but process the list command using a bulk request.
boolean	isAlreadyScheduled(IndexingCommand cmd) {true} if a command has already been submitted for indexing.
void	runIndexingWorker(List<IndexingCommand> cmds) Run a worker to process the IndexingCommand.
void	runReindexingWorker(String repositoryName, String nxql) Reindex documents matching the NXQL query, This is asynchronous.

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticSearchIndexingImpl

public ElasticSearchIndexingImpl(ElasticSearchAdminImpl esa)

ElasticSearchIndexingImpl

public ElasticSearchIndexingImpl(ElasticSearchAdminImpl esa,
                                 JsonESDocumentWriter jsonESDocumentWriter)

Since:

7.2

Method Detail

runIndexingWorker

public void runIndexingWorker(List<IndexingCommand> cmds)

Description copied from interface: ElasticSearchIndexing

Run a worker to process the IndexingCommand.

Asynchronous command schedules an indexing job and return.

Synchronous command execute an indexing job using a new Tx then refresh the index so the document is searchable immediately. if the command is also recursive the children are processed asynchronously.

If there is more than one cmd the elasticsearch request is done in bulk mode.

Specified by:

runIndexingWorker in interface ElasticSearchIndexing

runReindexingWorker

public void runReindexingWorker(String repositoryName,
                                String nxql)

Description copied from interface: ElasticSearchIndexing

Reindex documents matching the NXQL query, This is asynchronous.

Specified by:

runReindexingWorker in interface ElasticSearchIndexing

indexNonRecursive

public void indexNonRecursive(List<IndexingCommand> cmds)
                       throws ClientException

Description copied from interface: ElasticSearchIndexing

Same as ElasticSearchIndexing.indexNonRecursive(org.nuxeo.elasticsearch.commands.IndexingCommand) but process the list command using a bulk request.

Specified by:

indexNonRecursive in interface ElasticSearchIndexing

Throws:

ClientException

indexNonRecursive

public void indexNonRecursive(IndexingCommand cmd)
                       throws ClientException

Description copied from interface: ElasticSearchIndexing

Process the IndexingCommand.

Send indexing command to Elasticsearch, if the command is synchronous the index is refreshed so the document is searchable immediately. Recursive indexing is not taken in account except for deletion. This is not a transactional operation, a rollback will not discard the executed commands.

Specified by:

indexNonRecursive in interface ElasticSearchIndexing

Throws:

ClientException

isAlreadyScheduled

public boolean isAlreadyScheduled(IndexingCommand cmd)

Description copied from interface: ElasticSearchIndexing

{true} if a command has already been submitted for indexing.

Specified by:

isAlreadyScheduled in interface ElasticSearchIndexing