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) void
addSegment
(DocumentsWriterFlushQueue.FlushTicket ticket, DocumentsWriterPerThread.FlushedSegment segment) (package private) DocumentsWriterFlushQueue.FlushTicket
addTicket
(Supplier<DocumentsWriterFlushQueue.FlushTicket> ticketSupplier) 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
-
addTicket
DocumentsWriterFlushQueue.FlushTicket addTicket(Supplier<DocumentsWriterFlushQueue.FlushTicket> ticketSupplier) throws IOException - Throws:
IOException
-
incTickets
private void incTickets() -
decTickets
private void decTickets() -
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()
-