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 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 LockableConcurrentApproximatePriorityQueue<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) final DocumentsWriterPerThread	DocumentsWriterFlushControl.checkoutLargestNonPendingWriter()	Returns the largest non-pending flushable DWPT or null 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-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
Iterator<DocumentsWriterPerThread>	DocumentsWriterFlushControl.allActiveWriters()	Returns an iterator that provides access to all currently active DocumentsWriterPerThreads
(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 via DocumentsWriterPerThreadPool.checkout(DocumentsWriterPerThread).
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)
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 lock
private 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-pending DocumentsWriterPerThread with at least one indexed document.
private void	FlushByRamOrCountsPolicy.flushActiveBytes(DocumentsWriterFlushControl control, DocumentsWriterPerThread perThread)
(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.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 given DocumentsWriterPerThread.

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

Modifier and Type	Method	Description
(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 via DocumentsWriterPerThreadPool.checkout(DocumentsWriterPerThread).

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

Modifier	Constructor	Description
(package private)	DocumentsWriterPerThreadPool(Supplier<DocumentsWriterPerThread> dwptFactory)