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 java.util.Deque<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 or null 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-pending DocumentsWriterPerThread 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 locked DocumentsWriterPerThread
(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 active DocumentsWriterPerThreads
(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 via DocumentsWriterPerThreadPool.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)
private DocumentsWriterPerThread	DocumentsWriterFlushControl.checkOutForFlush(DocumentsWriterPerThread perThread)
private void	DocumentsWriterFlushControl.commitPerThreadBytes(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-pending DocumentsWriterPerThread with at least one indexed document.
(package private) boolean	DocumentsWriterPerThreadPool.isRegistered(DocumentsWriterPerThread perThread)	Returns true if this DWPT is still part of the pool
protected void	FlushByRamOrCountsPolicy.markLargestWriterPending(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread)	Marks the most ram consuming active DocumentsWriterPerThread 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 given DocumentsWriterPerThreads DocumentsWriterPerThread.
void	FlushPolicy.onUpdate(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread)	Called for each document update on the given DocumentsWriterPerThread's DocumentsWriterPerThread.
private boolean	DocumentsWriter.postUpdate(DocumentsWriterPerThread flushingDWPT, boolean hasEvents)
void	DocumentsWriterFlushControl.setFlushPending(DocumentsWriterPerThread perThread)	Sets flush pending state on the given DocumentsWriterPerThread.

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 via DocumentsWriterPerThreadPool.checkout(DocumentsWriterPerThread).

Constructor parameters in org.apache.lucene.index with type arguments of type DocumentsWriterPerThread

Constructor	Description
DocumentsWriterPerThreadPool(java.util.function.Supplier<DocumentsWriterPerThread> dwptFactory)