public class MockRandomMergePolicy extends MergePolicy
MergePolicy.MergeAbortedException, MergePolicy.MergeContext, MergePolicy.MergeException, MergePolicy.MergeSpecification, MergePolicy.OneMerge, MergePolicy.OneMergeProgress
DEFAULT_MAX_CFS_SEGMENT_SIZE, DEFAULT_NO_CFS_RATIO, maxCFSSegmentSize, noCFSRatio
Constructor and Description |
---|
MockRandomMergePolicy(java.util.Random random) |
Modifier and Type | Method and Description |
---|---|
MergePolicy.MergeSpecification |
findForcedDeletesMerges(SegmentInfos segmentInfos,
MergePolicy.MergeContext mergeContext)
Determine what set of merge operations is necessary in order to expunge all
deletes from the index.
|
MergePolicy.MergeSpecification |
findForcedMerges(SegmentInfos segmentInfos,
int maxSegmentCount,
java.util.Map<SegmentCommitInfo,java.lang.Boolean> segmentsToMerge,
MergePolicy.MergeContext mergeContext)
Determine what set of merge operations is necessary in
order to merge to
<= the specified segment count. |
MergePolicy.MergeSpecification |
findMerges(MergeTrigger mergeTrigger,
SegmentInfos segmentInfos,
MergePolicy.MergeContext mergeContext)
Determine what set of merge operations are now necessary on the index.
|
void |
setDoNonBulkMerges(boolean v)
Set to true if sometimes readers to be merged should be wrapped in a FilterReader
to mixup bulk merging.
|
boolean |
useCompoundFile(SegmentInfos infos,
SegmentCommitInfo mergedInfo,
MergePolicy.MergeContext mergeContext)
Returns true if a new segment (regardless of its origin) should use the
compound file format.
|
assertDelCount, getMaxCFSSegmentSizeMB, getNoCFSRatio, isMerged, keepFullyDeletedSegment, message, numDeletesToMerge, segString, setMaxCFSSegmentSizeMB, setNoCFSRatio, size, verbose
public void setDoNonBulkMerges(boolean v)
public MergePolicy.MergeSpecification findMerges(MergeTrigger mergeTrigger, SegmentInfos segmentInfos, MergePolicy.MergeContext mergeContext)
MergePolicy
IndexWriter
calls this whenever there is a change to the segments.
This call is always synchronized on the IndexWriter
instance so
only one thread at a time will call this method.findMerges
in class MergePolicy
mergeTrigger
- the event that triggered the mergesegmentInfos
- the total set of segments in the indexmergeContext
- the IndexWriter to find the merges onpublic MergePolicy.MergeSpecification findForcedMerges(SegmentInfos segmentInfos, int maxSegmentCount, java.util.Map<SegmentCommitInfo,java.lang.Boolean> segmentsToMerge, MergePolicy.MergeContext mergeContext) throws java.io.IOException
MergePolicy
<=
the specified segment count. IndexWriter
calls this when its
IndexWriter.forceMerge(int)
method is called. This call is always
synchronized on the IndexWriter
instance so only one thread at a
time will call this method.findForcedMerges
in class MergePolicy
segmentInfos
- the total set of segments in the indexmaxSegmentCount
- requested maximum number of segments in the index (currently this
is always 1)segmentsToMerge
- contains the specific SegmentInfo instances that must be merged
away. This may be a subset of all
SegmentInfos. If the value is True for a
given SegmentInfo, that means this segment was
an original segment present in the
to-be-merged index; else, it was a segment
produced by a cascaded merge.mergeContext
- the IndexWriter to find the merges onjava.io.IOException
public MergePolicy.MergeSpecification findForcedDeletesMerges(SegmentInfos segmentInfos, MergePolicy.MergeContext mergeContext) throws java.io.IOException
MergePolicy
findForcedDeletesMerges
in class MergePolicy
segmentInfos
- the total set of segments in the indexmergeContext
- the IndexWriter to find the merges onjava.io.IOException
public boolean useCompoundFile(SegmentInfos infos, SegmentCommitInfo mergedInfo, MergePolicy.MergeContext mergeContext) throws java.io.IOException
MergePolicy
true
iff the size of the given mergedInfo is less or equal to
MergePolicy.getMaxCFSSegmentSizeMB()
and the size is less or equal to the
TotalIndexSize * MergePolicy.getNoCFSRatio()
otherwise false
.useCompoundFile
in class MergePolicy
java.io.IOException
Copyright © 2000–2019 The Apache Software Foundation. All rights reserved.