org.nuxeo.elasticsearch.work

Class ScrollingIndexingWorker

java.lang.Object

org.nuxeo.ecm.core.work.AbstractWork

org.nuxeo.elasticsearch.work.BaseIndexingWorker

org.nuxeo.elasticsearch.work.ScrollingIndexingWorker

All Implemented Interfaces:

Serializable, Work

public class ScrollingIndexingWorker
extends BaseIndexingWorker
implements Work

Worker to reindex a large amount of document

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

Modifier and Type	Field and Description
protected long	documentCount
protected String	nxql
protected boolean	syncAlias
protected WorkManager	workManager

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

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

Constructor Summary

Constructors

Constructor and Description
ScrollingIndexingWorker(String repositoryName, String nxql)
ScrollingIndexingWorker(String repositoryName, String nxql, boolean syncAlias)

Method Summary

Modifier and Type	Method and Description
protected void	doWork()
protected int	getBucketSize()
String	getTitle() Gets a human-readable name for this work instance.
protected WorkManager	getWorkManager()
protected void	scheduleBucketWorker(List<String> bucket, boolean syncAlias)

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

getCategory, getRetryCount, work

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

buildWorkFailureEventProps, cleanUp, closeSession, commitOrRollbackTransaction, equals, getCompletionTime, getDocument, getDocuments, getId, getOriginatingUsername, getPartitionKey, getProgress, getSchedulePath, getSchedulingTime, 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, isIdempotent, isSuspending, isWorkInstanceSuspended, run, setProgress, setSchedulePath, setStartTime, setWorkInstanceState, setWorkInstanceSuspending, suspended, work

Field Detail

nxql

protected final String nxql

syncAlias

protected final boolean syncAlias

workManager

protected transient WorkManager workManager

documentCount

protected long documentCount

Constructor Detail

ScrollingIndexingWorker

public ScrollingIndexingWorker(String repositoryName,
                               String nxql)

ScrollingIndexingWorker

public ScrollingIndexingWorker(String repositoryName,
                               String nxql,
                               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

scheduleBucketWorker

protected void scheduleBucketWorker(List<String> bucket,
                                    boolean syncAlias)

getWorkManager

protected WorkManager getWorkManager()

getBucketSize

protected int getBucketSize()