Package org.nuxeo.elasticsearch.work

Class BucketIndexingWorker

java.lang.Object

org.nuxeo.ecm.core.work.AbstractWork

org.nuxeo.elasticsearch.work.BaseIndexingWorker

org.nuxeo.elasticsearch.work.BucketIndexingWorker

All Implemented Interfaces:

Serializable, Work

public class BucketIndexingWorker
extends BaseIndexingWorker
implements Work

œ Worker to index a bucket of documents

Since:

7.1

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.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
BucketIndexingWorker(String repositoryName, List<String> docIds, boolean syncAlias)

Method Summary

Modifier and Type	Method	Description
protected void	doWork()
protected int	getBucketSize()
String	getTitle()	Gets a human-readable name for this work instance.
protected List<DocumentModel>	loadDocumentsOneByOne(CoreSession session, List<String> documentIds)

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, initSession, initSession, 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 Detail

BucketIndexingWorker

public BucketIndexingWorker(String repositoryName,
                            List<String> docIds,
                            boolean syncAlias)

Method Detail

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

doWork

protected void doWork()

Specified by:

doWork in class BaseIndexingWorker

loadDocumentsOneByOne

protected List<DocumentModel> loadDocumentsOneByOne(CoreSession session,
                                                    List<String> documentIds)

getBucketSize

protected int getBucketSize()