Package org.apache.lucene.index
Class DocumentsWriterFlushQueue
java.lang.Object
org.apache.lucene.index.DocumentsWriterFlushQueue
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ReentrantLock
private final Queue<DocumentsWriterFlushQueue.FlushTicket>
private final AtomicInteger
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) boolean
addDeletes
(DocumentsWriterDeleteQueue deleteQueue) (package private) DocumentsWriterFlushQueue.FlushTicket
(package private) void
addSegment
(DocumentsWriterFlushQueue.FlushTicket ticket, DocumentsWriterPerThread.FlushedSegment segment) private void
(package private) void
(package private) int
(package private) boolean
private void
private void
(package private) void
(package private) void
-
Field Details
-
queue
-
ticketCount
-
purgeLock
-
-
Constructor Details
-
DocumentsWriterFlushQueue
DocumentsWriterFlushQueue()
-
-
Method Details
-
addDeletes
- Throws:
IOException
-
incTickets
private void incTickets() -
decTickets
private void decTickets() -
addFlushTicket
DocumentsWriterFlushQueue.FlushTicket addFlushTicket(DocumentsWriterPerThread dwpt) throws IOException - Throws:
IOException
-
addSegment
void addSegment(DocumentsWriterFlushQueue.FlushTicket ticket, DocumentsWriterPerThread.FlushedSegment segment) -
markTicketFailed
-
hasTickets
boolean hasTickets() -
innerPurge
private void innerPurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer) throws IOException - Throws:
IOException
-
forcePurge
- Throws:
IOException
-
tryPurge
- Throws:
IOException
-
getTicketCount
int getTicketCount()
-