public class OneMergeWrappingMergePolicy extends MergePolicyWrapper
MergePolicy.OneMerge
objects returned by the wrapped merge policy.MergePolicy.MergeAbortedException, MergePolicy.MergeException, MergePolicy.MergeSpecification, MergePolicy.OneMerge, MergePolicy.OneMergeProgressinDEFAULT_MAX_CFS_SEGMENT_SIZE, DEFAULT_NO_CFS_RATIO, maxCFSSegmentSize, noCFSRatio| Constructor and Description |
|---|
OneMergeWrappingMergePolicy(MergePolicy in,
UnaryOperator<MergePolicy.OneMerge> wrapOneMerge)
Constructor
|
| 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.
|
getNoCFSRatio, setMaxCFSSegmentSizeMB, setNoCFSRatio, size, toString, useCompoundFilegetMaxCFSSegmentSizeMB, isMergedpublic OneMergeWrappingMergePolicy(MergePolicy in, UnaryOperator<MergePolicy.OneMerge> wrapOneMerge)
in - - the wrapped merge policywrapOneMerge - - operator for wrapping OneMerge objectspublic 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 MergePolicyWrappermergeTrigger - 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 MergePolicyWrappersegmentInfos - 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 MergePolicyWrappersegmentInfos - the total set of segments in the indexwriter - the IndexWriter to find the merges onIOExceptionCopyright © 2000-2017 Apache Software Foundation. All Rights Reserved.