Uses of Class
org.apache.lucene.index.DocumentsWriterPerThread
-
Packages that use DocumentsWriterPerThread Package Description org.apache.lucene.index Code to maintain and access indices. -
-
Uses of DocumentsWriterPerThread in org.apache.lucene.index
Fields in org.apache.lucene.index with type parameters of type DocumentsWriterPerThread Modifier and Type Field Description private java.util.Queue<DocumentsWriterPerThread>
DocumentsWriterFlushControl. blockedFlushes
private java.util.function.Supplier<DocumentsWriterPerThread>
DocumentsWriterPerThreadPool. dwptFactory
private java.util.Set<DocumentsWriterPerThread>
DocumentsWriterPerThreadPool. dwpts
private java.util.List<DocumentsWriterPerThread>
DocumentsWriterFlushControl. flushingWriters
private java.util.Queue<DocumentsWriterPerThread>
DocumentsWriterFlushControl. flushQueue
private ApproximatePriorityQueue<DocumentsWriterPerThread>
DocumentsWriterPerThreadPool. freeList
Methods in org.apache.lucene.index that return DocumentsWriterPerThread Modifier and Type Method Description private DocumentsWriterPerThread
DocumentsWriterFlushControl. checkout(DocumentsWriterPerThread perThread, boolean markPending)
private DocumentsWriterPerThread
DocumentsWriterFlushControl. checkOutForFlush(DocumentsWriterPerThread perThread)
(package private) DocumentsWriterPerThread
DocumentsWriterFlushControl. checkoutLargestNonPendingWriter()
Returns the largest non-pending flushable DWPT ornull
if there is none.(package private) DocumentsWriterPerThread
DocumentsWriterFlushControl. doAfterDocument(DocumentsWriterPerThread perThread, boolean isUpdate)
(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 DocumentsWriterPerThread Modifier and Type Method Description java.util.Iterator<DocumentsWriterPerThread>
DocumentsWriterFlushControl. allActiveWriters()
Returns an iterator that provides access to all currently activeDocumentsWriterPerThread
s(package private) java.util.List<DocumentsWriterPerThread>
DocumentsWriterPerThreadPool. filterAndLock(java.util.function.Predicate<DocumentsWriterPerThread> predicate)
Filters all DWPTs the given predicate applies to and that can be checked out of the pool viaDocumentsWriterPerThreadPool.checkout(DocumentsWriterPerThread)
.java.util.Iterator<DocumentsWriterPerThread>
DocumentsWriterPerThreadPool. iterator()
Methods in org.apache.lucene.index with parameters of type DocumentsWriterPerThread Modifier and Type Method Description private void
DocumentsWriter. abortDocumentsWriterPerThread(DocumentsWriterPerThread perThread)
Returns how many documents were aborted.private void
DocumentsWriterFlushControl. addFlushingDWPT(DocumentsWriterPerThread perThread)
(package private) DocumentsWriterFlushQueue.FlushTicket
DocumentsWriterFlushQueue. addFlushTicket(DocumentsWriterPerThread dwpt)
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)
(package private) DocumentsWriterPerThread
DocumentsWriterFlushControl. doAfterDocument(DocumentsWriterPerThread perThread, boolean isUpdate)
(package private) void
DocumentsWriterFlushControl. doAfterFlush(DocumentsWriterPerThread dwpt)
private boolean
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.(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. onDelete(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread)
abstract void
FlushPolicy. onDelete(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread)
Called for each delete term.void
FlushByRamOrCountsPolicy. onInsert(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread)
abstract void
FlushPolicy. onInsert(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread)
Called for each document addition on the givenDocumentsWriterPerThread
sDocumentsWriterPerThread
.void
FlushPolicy. onUpdate(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread)
Called for each document update on the givenDocumentsWriterPerThread
'sDocumentsWriterPerThread
.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 DocumentsWriterPerThread Modifier and Type Method Description (package private) java.util.List<DocumentsWriterPerThread>
DocumentsWriterPerThreadPool. filterAndLock(java.util.function.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 DocumentsWriterPerThread Constructor Description DocumentsWriterPerThreadPool(java.util.function.Supplier<DocumentsWriterPerThread> dwptFactory)
-