Uses of Class
org.apache.lucene.index.DocumentsWriterPerThread
Packages that use DocumentsWriterPerThread
-
Uses of DocumentsWriterPerThread in org.apache.lucene.index
Fields in org.apache.lucene.index with type parameters of type DocumentsWriterPerThreadModifier and TypeFieldDescriptionprivate final Queue
<DocumentsWriterPerThread> DocumentsWriterFlushControl.blockedFlushes
private final Supplier
<DocumentsWriterPerThread> DocumentsWriterPerThreadPool.dwptFactory
private final Set
<DocumentsWriterPerThread> DocumentsWriterPerThreadPool.dwpts
private final List
<DocumentsWriterPerThread> DocumentsWriterFlushControl.flushingWriters
private final Queue
<DocumentsWriterPerThread> DocumentsWriterFlushControl.flushQueue
private final ConcurrentApproximatePriorityQueue
<DocumentsWriterPerThread> DocumentsWriterPerThreadPool.freeList
Methods in org.apache.lucene.index that return DocumentsWriterPerThreadModifier and TypeMethodDescriptionprivate DocumentsWriterPerThread
DocumentsWriterFlushControl.checkout
(DocumentsWriterPerThread perThread, boolean markPending) private DocumentsWriterPerThread
DocumentsWriterFlushControl.checkOutForFlush
(DocumentsWriterPerThread perThread) (package private) final DocumentsWriterPerThread
DocumentsWriterFlushControl.checkoutLargestNonPendingWriter()
Returns the largest non-pending flushable DWPT ornull
if there is none.(package private) DocumentsWriterPerThread
DocumentsWriterFlushControl.doAfterDocument
(DocumentsWriterPerThread perThread) (package private) DocumentsWriterPerThread
DocumentsWriterFlushControl.findLargestNonPendingWriter()
protected DocumentsWriterPerThread
FlushPolicy.findLargestNonPendingWriter
(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread) Returns the current most RAM consuming non-pendingDocumentsWriterPerThread
with at least one indexed document.(package private) DocumentsWriterPerThread
DocumentsWriterPerThreadPool.getAndLock()
This method is used by DocumentsWriter/FlushControl to obtain a DWPT to do an indexing operation (add/updateDocument).private DocumentsWriterPerThread
DocumentsWriterPerThreadPool.newWriter()
Returns a new already lockedDocumentsWriterPerThread
(package private) DocumentsWriterPerThread
DocumentsWriterFlushControl.nextPendingFlush()
(package private) DocumentsWriterPerThread
DocumentsWriterFlushControl.obtainAndLock()
Methods in org.apache.lucene.index that return types with arguments of type DocumentsWriterPerThreadModifier and TypeMethodDescriptionDocumentsWriterFlushControl.allActiveWriters()
Returns an iterator that provides access to all currently activeDocumentsWriterPerThread
s(package private) List
<DocumentsWriterPerThread> DocumentsWriterPerThreadPool.filterAndLock
(Predicate<DocumentsWriterPerThread> predicate) Filters all DWPTs the given predicate applies to and that can be checked out of the pool viaDocumentsWriterPerThreadPool.checkout(DocumentsWriterPerThread)
.DocumentsWriterPerThreadPool.iterator()
Methods in org.apache.lucene.index with parameters of type DocumentsWriterPerThreadModifier and TypeMethodDescriptionprivate void
DocumentsWriter.abortDocumentsWriterPerThread
(DocumentsWriterPerThread perThread) Returns how many documents were aborted.private void
DocumentsWriterFlushControl.addFlushingDWPT
(DocumentsWriterPerThread perThread) private DocumentsWriterPerThread
DocumentsWriterFlushControl.checkout
(DocumentsWriterPerThread perThread, boolean markPending) (package private) boolean
DocumentsWriterPerThreadPool.checkout
(DocumentsWriterPerThread perThread) Removes the given DWPT from the pool unless it's already been removed before.private void
DocumentsWriterFlushControl.checkoutAndBlock
(DocumentsWriterPerThread perThread) To be called only by the owner of this object's monitor lockprivate DocumentsWriterPerThread
DocumentsWriterFlushControl.checkOutForFlush
(DocumentsWriterPerThread perThread) private boolean
DocumentsWriterPerThreadPool.contains
(DocumentsWriterPerThread state) (package private) DocumentsWriterPerThread
DocumentsWriterFlushControl.doAfterDocument
(DocumentsWriterPerThread perThread) (package private) void
DocumentsWriterFlushControl.doAfterFlush
(DocumentsWriterPerThread dwpt) private void
DocumentsWriter.doFlush
(DocumentsWriterPerThread flushingDWPT) (package private) void
DocumentsWriterFlushControl.doOnAbort
(DocumentsWriterPerThread perThread) protected DocumentsWriterPerThread
FlushPolicy.findLargestNonPendingWriter
(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread) Returns the current most RAM consuming non-pendingDocumentsWriterPerThread
with at least one indexed document.private void
FlushByRamOrCountsPolicy.flushActiveBytes
(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread) (package private) boolean
DocumentsWriterPerThreadPool.isRegistered
(DocumentsWriterPerThread perThread) Returnstrue
if this DWPT is still part of the poolprotected void
FlushByRamOrCountsPolicy.markLargestWriterPending
(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread) Marks the most ram consuming activeDocumentsWriterPerThread
flush pending(package private) void
DocumentsWriterPerThreadPool.marksAsFreeAndUnlock
(DocumentsWriterPerThread state) void
FlushByRamOrCountsPolicy.onChange
(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread) abstract void
FlushPolicy.onChange
(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread) Called for each delete, insert or update.private boolean
DocumentsWriter.postUpdate
(DocumentsWriterPerThread flushingDWPT, boolean hasEvents) void
DocumentsWriterFlushControl.setFlushPending
(DocumentsWriterPerThread perThread) Sets flush pending state on the givenDocumentsWriterPerThread
.Method parameters in org.apache.lucene.index with type arguments of type DocumentsWriterPerThreadModifier and TypeMethodDescription(package private) List
<DocumentsWriterPerThread> DocumentsWriterPerThreadPool.filterAndLock
(Predicate<DocumentsWriterPerThread> predicate) Filters all DWPTs the given predicate applies to and that can be checked out of the pool viaDocumentsWriterPerThreadPool.checkout(DocumentsWriterPerThread)
.Constructor parameters in org.apache.lucene.index with type arguments of type DocumentsWriterPerThreadModifierConstructorDescription(package private)
DocumentsWriterPerThreadPool
(Supplier<DocumentsWriterPerThread> dwptFactory)