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
Modifier and TypeFieldDescriptionprotected static final int
protected String
protected final org.apache.commons.collections4.queue.CircularFifoQueue<String>
Cache already deletedprotected final org.apache.commons.collections4.queue.CircularFifoQueue<String>
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
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
compute
(CoreSession session, List<String> ids, Map<String, Serializable> properties) void
startBucket
(String bucketKey) Can be overridden to init stuff before processing the bucketMethods 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 Details
-
CACHE_SIZE
protected static final int CACHE_SIZE- See Also:
-
deletedVersions
Cache already deleted -
versionSeriesIds
-
currentCommand
-
-
Constructor Details
-
GarbageCollectOrphanVersionsComputation
public GarbageCollectOrphanVersionsComputation()
-
-
Method Details
-
startBucket
Description copied from class:AbstractBulkComputation
Can be overridden to init stuff before processing the bucket- Overrides:
startBucket
in classAbstractBulkComputation
-
compute
- Specified by:
compute
in classAbstractBulkComputation
-