Class SplitDocumentCleanUp
- java.lang.Object
-
- org.apache.jackrabbit.oak.plugins.document.SplitDocumentCleanUp
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public class SplitDocumentCleanUp extends java.lang.Object implements java.io.Closeable
Implements a split document cleanup.
-
-
Field Summary
Fields Modifier and Type Field Description protected int
deleteCount
protected java.util.List<java.lang.String>
idsToBeDeleted
protected java.lang.Iterable<NodeDocument>
splitDocGarbage
protected VersionGarbageCollector.VersionGCStats
stats
protected DocumentStore
store
-
Constructor Summary
Constructors Modifier Constructor Description protected
SplitDocumentCleanUp(DocumentStore store, VersionGarbageCollector.VersionGCStats stats, java.lang.Iterable<NodeDocument> splitDocGarbage)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
protected void
collectIdToBeDeleted(java.lang.String id)
Collects document IDs for subsequent deletion.protected int
deleteSplitDocuments()
protected SplitDocumentCleanUp
disconnect()
-
-
-
Field Detail
-
store
protected final DocumentStore store
-
splitDocGarbage
protected final java.lang.Iterable<NodeDocument> splitDocGarbage
-
stats
protected final VersionGarbageCollector.VersionGCStats stats
-
idsToBeDeleted
protected final java.util.List<java.lang.String> idsToBeDeleted
-
deleteCount
protected int deleteCount
-
-
Constructor Detail
-
SplitDocumentCleanUp
protected SplitDocumentCleanUp(DocumentStore store, VersionGarbageCollector.VersionGCStats stats, java.lang.Iterable<NodeDocument> splitDocGarbage)
-
-
Method Detail
-
disconnect
protected SplitDocumentCleanUp disconnect()
-
collectIdToBeDeleted
protected void collectIdToBeDeleted(java.lang.String id)
Collects document IDs for subsequent deletion.Implementations that override
deleteSplitDocuments()
should override this method as well.
-
deleteSplitDocuments
protected int deleteSplitDocuments()
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Throws:
java.io.IOException
-
-