Package org.nuxeo.elasticsearch.work

Class IndexingWorker

java.lang.Object

org.nuxeo.ecm.core.work.AbstractWork

org.nuxeo.elasticsearch.work.BaseIndexingWorker

org.nuxeo.elasticsearch.work.AbstractIndexingWorker

org.nuxeo.elasticsearch.work.IndexingWorker

All Implemented Interfaces:

Serializable, Work

public class IndexingWorker
extends AbstractIndexingWorker
implements Work

Simple Indexing Worker

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.nuxeo.ecm.core.work.api.Work

Work.Progress, Work.State

Field Summary

Fields inherited from class org.nuxeo.elasticsearch.work.AbstractIndexingWorker

cmds

Fields inherited from class org.nuxeo.ecm.core.work.AbstractWork

callerThread, completionTime, docId, docIds, FAILURE_EXCEPTION, FAILURE_MSG, GLOBAL_DLQ_COUNT_REGISTRY_NAME, id, isTree, loginContext, originatingUsername, progress, RANDOM, repositoryName, schedulePath, schedulingTime, session, startTime, state, status, suspended, suspending, traceContext, WORK_FAILED_EVENT, WORK_INSTANCE

Constructor Summary

Constructors

Constructor	Description
IndexingWorker(String repositoryName, List<IndexingCommand> cmds)

Method Summary

Modifier and Type	Method	Description
protected void	doIndexingWork(ElasticSearchIndexing esi, List<IndexingCommand> cmds)
String	getCmdsDigest()
protected String	getNxqlQuery(IndexingCommand cmd)
String	getTitle()	Gets a human-readable name for this work instance.
protected Work	getWorker(IndexingCommand cmd)
protected boolean	needRecurse(IndexingCommand cmd)

Methods inherited from class org.nuxeo.elasticsearch.work.AbstractIndexingWorker

doWork

Methods inherited from class org.nuxeo.elasticsearch.work.BaseIndexingWorker

getCategory, getRetryCount, work

Methods inherited from class org.nuxeo.ecm.core.work.AbstractWork

appendWorkToDeadLetterQueue, buildWorkFailureEventProps, cleanUp, closeSession, commitOrRollbackTransaction, equals, getCompletionTime, getDocument, getDocuments, getId, getOriginatingUsername, getPartitionKey, getProgress, getSchedulePath, getSchedulingTime, getSpanFromContext, getStartTime, getStatus, getWorkInstanceState, hashCode, isDocumentTree, isSuspending, isWorkInstanceSuspended, newDocumentLocation, openSystemSession, openUserSession, run, runWorkWithTransaction, setCompletionTime, setDocument, setDocument, setDocuments, setOriginatingUsername, setProgress, setSchedulePath, setStartTime, setStatus, setWorkInstanceState, setWorkInstanceSuspending, startTransaction, suspended, toString, workFailed

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.nuxeo.ecm.core.work.api.Work

cleanUp, getCategory, getCompletionTime, getDocument, getDocuments, getId, getOriginatingUsername, getPartitionKey, getProgress, getSchedulePath, getSchedulingTime, getStartTime, getStatus, getWorkInstanceState, isCoalescing, isDocumentTree, isGroupJoin, isIdempotent, isSuspending, isWorkInstanceSuspended, onGroupJoinCompletion, run, setProgress, setSchedulePath, setStartTime, setWorkInstanceState, setWorkInstanceSuspending, suspended, work

Constructor Details

IndexingWorker

public IndexingWorker(String repositoryName,
 List<IndexingCommand> cmds)

Method Details

getTitle

public String getTitle()

Description copied from interface: Work

Gets a human-readable name for this work instance.

Specified by:

getTitle in interface Work

Returns:

a human-readable name

needRecurse

protected boolean needRecurse(IndexingCommand cmd)

doIndexingWork

protected void doIndexingWork(ElasticSearchIndexing esi,
 List<IndexingCommand> cmds)

Specified by:

doIndexingWork in class AbstractIndexingWorker

getWorker

protected Work getWorker(IndexingCommand cmd)

getNxqlQuery

protected String getNxqlQuery(IndexingCommand cmd)

getCmdsDigest

public String getCmdsDigest()