Package org.nuxeo.ecm.core.action

Class GarbageCollectOrphanVersionsAction.GarbageCollectOrphanVersionsComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

org.nuxeo.ecm.core.action.GarbageCollectOrphanVersionsAction.GarbageCollectOrphanVersionsComputation

All Implemented Interfaces:

Computation

Enclosing class:

GarbageCollectOrphanVersionsAction

public static class GarbageCollectOrphanVersionsAction.GarbageCollectOrphanVersionsComputation
extends AbstractBulkComputation

Field Summary

Fields

Modifier and Type	Field	Description
protected static int	CACHE_SIZE
protected String	currentCommand
protected org.apache.commons.collections4.queue.CircularFifoQueue<String>	deletedVersions	Cache already deleted
protected org.apache.commons.collections4.queue.CircularFifoQueue<String>	versionSeriesIds

Fields inherited from class org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

command, commands, delta, SELECT_DOCUMENTS_IN

Fields inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

INPUT_1, INPUT_2, INPUT_3, INPUT_NULL, metadata, OUTPUT_1, OUTPUT_2, OUTPUT_3, OUTPUT_4

Constructor Summary

Constructors

Constructor	Description
GarbageCollectOrphanVersionsComputation()

Method Summary

Modifier and Type	Method	Description
protected void	compute(CoreSession session, List<String> ids, Map<String,Serializable> properties)
void	startBucket(String bucketKey)	Can be overridden to init stuff before processing the bucket

Methods inherited from class org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

endBucket, getBatchTransactionTimeout, getCommand, getCurrentCommand, isAbortedCommand, loadDocuments, loadDocumentsOneByOne, loginSystemOrUser, processBatchOfDocuments, processFailure, processRecord, updateStatus

Methods inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

init, metadata, processRetry, processTimer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.nuxeo.lib.stream.computation.Computation

destroy, signalStop

Field Detail

CACHE_SIZE

protected static final int CACHE_SIZE

See Also:

Constant Field Values

deletedVersions

protected final org.apache.commons.collections4.queue.CircularFifoQueue<String> deletedVersions

Cache already deleted

versionSeriesIds

protected final org.apache.commons.collections4.queue.CircularFifoQueue<String> versionSeriesIds

currentCommand

protected String currentCommand

Constructor Detail

GarbageCollectOrphanVersionsComputation

public GarbageCollectOrphanVersionsComputation()

Method Detail

startBucket

public void startBucket(String bucketKey)

Description copied from class: AbstractBulkComputation

Can be overridden to init stuff before processing the bucket

Overrides:

startBucket in class AbstractBulkComputation

compute

protected void compute(CoreSession session,
                       List<String> ids,
                       Map<String,Serializable> properties)

Specified by:

compute in class AbstractBulkComputation