public class MergePolicyWrapper extends MergePolicy
MergePolicy
instances.MergePolicy.MergeAbortedException, MergePolicy.MergeException, MergePolicy.MergeSpecification, MergePolicy.OneMerge, MergePolicy.OneMergeProgress
Modifier and Type | Field and Description |
---|---|
protected MergePolicy |
in
The wrapped
MergePolicy . |
DEFAULT_MAX_CFS_SEGMENT_SIZE, DEFAULT_NO_CFS_RATIO, maxCFSSegmentSize, noCFSRatio
Constructor and Description |
---|
MergePolicyWrapper(MergePolicy in)
Creates a new merge policy instance.
|
Modifier and Type | Method and Description |
---|---|
MergePolicy.MergeSpecification |
findForcedDeletesMerges(SegmentInfos segmentInfos,
IndexWriter writer)
Determine what set of merge operations is necessary in order to expunge all
deletes from the index.
|
MergePolicy.MergeSpecification |
findForcedMerges(SegmentInfos segmentInfos,
int maxSegmentCount,
Map<SegmentCommitInfo,Boolean> segmentsToMerge,
IndexWriter writer)
Determine what set of merge operations is necessary in
order to merge to
<= the specified segment count. |
MergePolicy.MergeSpecification |
findMerges(MergeTrigger mergeTrigger,
SegmentInfos segmentInfos,
IndexWriter writer)
Determine what set of merge operations are now necessary on the index.
|
double |
getNoCFSRatio()
Returns current
noCFSRatio . |
void |
setMaxCFSSegmentSizeMB(double v)
If a merged segment will be more than this value,
leave the segment as
non-compound file even if compound file is enabled.
|
void |
setNoCFSRatio(double noCFSRatio)
If a merged segment will be more than this percentage
of the total size of the index, leave the segment as
non-compound file even if compound file is enabled.
|
protected long |
size(SegmentCommitInfo info,
IndexWriter writer)
Return the byte size of the provided
SegmentCommitInfo , pro-rated by percentage of
non-deleted documents is set. |
String |
toString() |
boolean |
useCompoundFile(SegmentInfos infos,
SegmentCommitInfo mergedInfo,
IndexWriter writer)
Returns true if a new segment (regardless of its origin) should use the
compound file format.
|
getMaxCFSSegmentSizeMB, isMerged
protected final MergePolicy in
MergePolicy
.public MergePolicyWrapper(MergePolicy in)
in
- the wrapped MergePolicy
public MergePolicy.MergeSpecification findMerges(MergeTrigger mergeTrigger, SegmentInfos segmentInfos, IndexWriter writer) throws IOException
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 indexwriter
- the IndexWriter to find the merges onIOException
public MergePolicy.MergeSpecification findForcedMerges(SegmentInfos segmentInfos, int maxSegmentCount, Map<SegmentCommitInfo,Boolean> segmentsToMerge, IndexWriter writer) throws 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.writer
- the IndexWriter to find the merges onIOException
public MergePolicy.MergeSpecification findForcedDeletesMerges(SegmentInfos segmentInfos, IndexWriter writer) throws IOException
MergePolicy
findForcedDeletesMerges
in class MergePolicy
segmentInfos
- the total set of segments in the indexwriter
- the IndexWriter to find the merges onIOException
public boolean useCompoundFile(SegmentInfos infos, SegmentCommitInfo mergedInfo, IndexWriter writer) throws 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
IOException
protected long size(SegmentCommitInfo info, IndexWriter writer) throws IOException
MergePolicy
SegmentCommitInfo
, pro-rated by percentage of
non-deleted documents is set.size
in class MergePolicy
IOException
public double getNoCFSRatio()
MergePolicy
noCFSRatio
.getNoCFSRatio
in class MergePolicy
MergePolicy.setNoCFSRatio(double)
public final void setNoCFSRatio(double noCFSRatio)
MergePolicy
setNoCFSRatio
in class MergePolicy
public final void setMaxCFSSegmentSizeMB(double v)
MergePolicy
setMaxCFSSegmentSizeMB
in class MergePolicy
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.