Package | Description |
---|---|
org.apache.lucene.index |
Code to maintain and access indices.
|
Modifier and Type | Field and Description |
---|---|
(package private) MergePolicy.OneMerge |
ConcurrentMergeScheduler.MergeThread.merge |
Modifier and Type | Field and Description |
---|---|
private java.util.List<MergePolicy.OneMerge> |
IndexWriter.mergeExceptions |
java.util.List<MergePolicy.OneMerge> |
MergePolicy.MergeSpecification.merges
The subset of segments to be included in the primitive merge.
|
private java.util.LinkedList<MergePolicy.OneMerge> |
IndexWriter.pendingMerges |
private java.util.Set<MergePolicy.OneMerge> |
IndexWriter.runningMerges |
private java.util.function.UnaryOperator<MergePolicy.OneMerge> |
OneMergeWrappingMergePolicy.wrapOneMerge |
Modifier and Type | Method and Description |
---|---|
MergePolicy.OneMerge |
IndexWriter.getNextMerge()
Expert: the
MergeScheduler calls this method to retrieve the next
merge requested by the MergePolicy |
Modifier and Type | Method and Description |
---|---|
private void |
IndexWriter._mergeInit(MergePolicy.OneMerge merge) |
void |
MergePolicy.MergeSpecification.add(MergePolicy.OneMerge merge)
Adds the provided
MergePolicy.OneMerge to this
specification. |
(package private) void |
IndexWriter.addMergeException(MergePolicy.OneMerge merge) |
(package private) void |
SegmentInfos.applyMergeChanges(MergePolicy.OneMerge merge,
boolean dropSegment)
applies all changes caused by committing a merge to this SegmentInfos
|
private void |
IndexWriter.closeMergeReaders(MergePolicy.OneMerge merge,
boolean suppressExceptions) |
private boolean |
IndexWriter.commitMerge(MergePolicy.OneMerge merge,
MergeState mergeState) |
private ReadersAndUpdates |
IndexWriter.commitMergedDeletesAndUpdates(MergePolicy.OneMerge merge,
MergeState mergeState)
Carefully merges deletes and updates for the segments we just merged.
|
protected void |
ConcurrentMergeScheduler.doMerge(IndexWriter writer,
MergePolicy.OneMerge merge)
Does the actual merge, by calling
IndexWriter.merge(org.apache.lucene.index.MergePolicy.OneMerge) |
private void |
IndexWriter.ensureValidMerge(MergePolicy.OneMerge merge) |
protected ConcurrentMergeScheduler.MergeThread |
ConcurrentMergeScheduler.getMergeThread(IndexWriter writer,
MergePolicy.OneMerge merge)
Create and return a new MergeThread
|
private void |
IndexWriter.handleMergeException(java.lang.Throwable t,
MergePolicy.OneMerge merge) |
private boolean |
ConcurrentMergeScheduler.isBacklog(long now,
MergePolicy.OneMerge merge) |
void |
IndexWriter.merge(MergePolicy.OneMerge merge)
Merges the indicated segments, replacing them in the stack with a
single segment.
|
(package private) void |
IndexWriter.mergeFinish(MergePolicy.OneMerge merge)
Does fininishing for a merge, which is fast but holds
the synchronized lock on IndexWriter instance.
|
(package private) void |
IndexWriter.mergeInit(MergePolicy.OneMerge merge)
Does initial setup for a merge, which is fast but holds
the synchronized lock on IndexWriter instance.
|
private int |
IndexWriter.mergeMiddle(MergePolicy.OneMerge merge,
MergePolicy mergePolicy)
Does the actual (time-consuming) work of the merge,
but without holding synchronized lock on IndexWriter
instance
|
(package private) void |
IndexWriter.mergeSuccess(MergePolicy.OneMerge merge)
Hook that's called when the specified merge is complete.
|
(package private) boolean |
IndexWriter.registerMerge(MergePolicy.OneMerge merge)
Checks whether this merge involves any segments
already participating in a merge.
|
private void |
ConcurrentMergeScheduler.updateIOThrottle(MergePolicy.OneMerge newMerge,
MergeRateLimiter rateLimiter)
Tunes IO throttle when a new merge starts.
|
Directory |
MergeScheduler.wrapForMerge(MergePolicy.OneMerge merge,
Directory in)
Wraps the incoming
Directory so that we can merge-throttle it
using RateLimitedIndexOutput . |
Directory |
ConcurrentMergeScheduler.wrapForMerge(MergePolicy.OneMerge merge,
Directory in) |
Directory |
NoMergeScheduler.wrapForMerge(MergePolicy.OneMerge merge,
Directory in) |
Constructor and Description |
---|
MergeThread(IndexWriter writer,
MergePolicy.OneMerge merge)
Sole constructor.
|
Constructor and Description |
---|
OneMergeWrappingMergePolicy(MergePolicy in,
java.util.function.UnaryOperator<MergePolicy.OneMerge> wrapOneMerge)
Constructor
|