Package 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	Description
protected long	documentCount
protected final String	nxql
protected final boolean	syncAlias
protected static final int	TRANSACTION_TIMEOUT_SECONDS
protected WorkManager	workManager

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

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

Field Details

TRANSACTION_TIMEOUT_SECONDS

protected static final int TRANSACTION_TIMEOUT_SECONDS

See Also:

• Constant Field Values

nxql

protected final String nxql

syncAlias

protected final boolean syncAlias

workManager

protected transient WorkManager workManager

documentCount

protected long documentCount

Constructor Details

ScrollingIndexingWorker

public ScrollingIndexingWorker(String repositoryName,
 String nxql)

ScrollingIndexingWorker

public ScrollingIndexingWorker(String repositoryName,
 String nxql,
 boolean syncAlias)

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

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()