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
œ Worker to index a bucket of documents
- Since:
- 7.1
- See Also:
-
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
ConstructorDescriptionBucketIndexingWorker
(String repositoryName, List<String> docIds, boolean syncAlias) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
doWork()
protected int
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, 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
-
BucketIndexingWorker
-
-
Method Details
-
getTitle
Description copied from interface:Work
Gets a human-readable name for this work instance. -
doWork
protected void doWork()- Specified by:
doWork
in classBaseIndexingWorker
-
loadDocumentsOneByOne
-
getBucketSize
protected int getBucketSize()
-