private int |
DocumentsWriter.abortThreadState(DocumentsWriterPerThreadPool.ThreadState perThread) |
Returns how many documents were aborted.
|
(package private) void |
DocumentsWriterFlushControl.addFlushableState(DocumentsWriterPerThreadPool.ThreadState perThread) |
|
private DocumentsWriterPerThread |
DocumentsWriterFlushControl.checkout(DocumentsWriterPerThreadPool.ThreadState perThread,
boolean markPending) |
|
private void |
DocumentsWriterFlushControl.checkoutAndBlock(DocumentsWriterPerThreadPool.ThreadState perThread) |
|
private void |
DocumentsWriterFlushControl.commitPerThreadBytes(DocumentsWriterPerThreadPool.ThreadState perThread) |
|
(package private) DocumentsWriterPerThread |
DocumentsWriterFlushControl.doAfterDocument(DocumentsWriterPerThreadPool.ThreadState perThread,
boolean isUpdate) |
|
(package private) void |
DocumentsWriterFlushControl.doOnAbort(DocumentsWriterPerThreadPool.ThreadState state) |
|
private void |
DocumentsWriter.ensureInitialized(DocumentsWriterPerThreadPool.ThreadState state) |
|
protected DocumentsWriterPerThreadPool.ThreadState |
FlushPolicy.findLargestNonPendingWriter(DocumentsWriterFlushControl control,
DocumentsWriterPerThreadPool.ThreadState perThreadState) |
|
private DocumentsWriterPerThread |
DocumentsWriterFlushControl.internalTryCheckOutForFlush(DocumentsWriterPerThreadPool.ThreadState perThread) |
|
protected void |
FlushByRamOrCountsPolicy.markLargestWriterPending(DocumentsWriterFlushControl control,
DocumentsWriterPerThreadPool.ThreadState perThreadState,
long currentBytesPerThread) |
|
void |
FlushByRamOrCountsPolicy.onDelete(DocumentsWriterFlushControl control,
DocumentsWriterPerThreadPool.ThreadState state) |
|
abstract void |
FlushPolicy.onDelete(DocumentsWriterFlushControl control,
DocumentsWriterPerThreadPool.ThreadState state) |
Called for each delete term.
|
void |
FlushByRamOrCountsPolicy.onInsert(DocumentsWriterFlushControl control,
DocumentsWriterPerThreadPool.ThreadState state) |
|
abstract void |
FlushPolicy.onInsert(DocumentsWriterFlushControl control,
DocumentsWriterPerThreadPool.ThreadState state) |
|
void |
FlushPolicy.onUpdate(DocumentsWriterFlushControl control,
DocumentsWriterPerThreadPool.ThreadState state) |
|
(package private) void |
DocumentsWriterPerThreadPool.release(DocumentsWriterPerThreadPool.ThreadState state) |
|
(package private) DocumentsWriterPerThread |
DocumentsWriterPerThreadPool.reset(DocumentsWriterPerThreadPool.ThreadState threadState) |
|
void |
DocumentsWriterFlushControl.setFlushPending(DocumentsWriterPerThreadPool.ThreadState perThread) |
|
(package private) DocumentsWriterPerThread |
DocumentsWriterFlushControl.tryCheckoutForFlush(DocumentsWriterPerThreadPool.ThreadState perThread) |
|