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, isMergedprotected final MergePolicy in
MergePolicy.public MergePolicyWrapper(MergePolicy in)
in - the wrapped MergePolicypublic MergePolicy.MergeSpecification findMerges(MergeTrigger mergeTrigger, SegmentInfos segmentInfos, IndexWriter writer) throws IOException
MergePolicyIndexWriter 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 MergePolicymergeTrigger - the event that triggered the mergesegmentInfos - the total set of segments in the indexwriter - the IndexWriter to find the merges onIOExceptionpublic 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 MergePolicysegmentInfos - 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 onIOExceptionpublic MergePolicy.MergeSpecification findForcedDeletesMerges(SegmentInfos segmentInfos, IndexWriter writer) throws IOException
MergePolicyfindForcedDeletesMerges in class MergePolicysegmentInfos - the total set of segments in the indexwriter - the IndexWriter to find the merges onIOExceptionpublic boolean useCompoundFile(SegmentInfos infos, SegmentCommitInfo mergedInfo, IndexWriter writer) throws IOException
MergePolicytrue
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 MergePolicyIOExceptionprotected long size(SegmentCommitInfo info, IndexWriter writer) throws IOException
MergePolicySegmentCommitInfo, pro-rated by percentage of
non-deleted documents is set.size in class MergePolicyIOExceptionpublic double getNoCFSRatio()
MergePolicynoCFSRatio.getNoCFSRatio in class MergePolicyMergePolicy.setNoCFSRatio(double)public final void setNoCFSRatio(double noCFSRatio)
MergePolicysetNoCFSRatio in class MergePolicypublic final void setMaxCFSSegmentSizeMB(double v)
MergePolicysetMaxCFSSegmentSizeMB in class MergePolicyCopyright © 2000-2018 Apache Software Foundation. All Rights Reserved.