com.haulmont.fts.core.sys

Class LiveUpgradeMergePolicy

java.lang.Object

org.apache.lucene.index.MergePolicy

org.apache.lucene.index.FilterMergePolicy

com.haulmont.fts.core.sys.LiveUpgradeMergePolicy

public class LiveUpgradeMergePolicy
extends org.apache.lucene.index.FilterMergePolicy

This MergePolicy is used for upgrading all existing segments of an index when calling IndexWriter.forceMerge(int). This allows for an as-cheap-as possible upgrade of an older index by only upgrading segments that are created by previous Lucene versions. forceMerge does no longer really merge; it is just used to "forceMerge" older segment versions away.

For a fully customizeable upgrade, you can use this like any other MergePolicy and call IndexWriter.forceMerge(int):

  IndexWriterConfig iwc = new IndexWriterConfig(Version.LUCENE_XX, new KeywordAnalyzer());
  iwc.setMergePolicy(new LiveUpgradeMergePolicy(iwc.getMergePolicy()));
  IndexWriter w = new IndexWriter(dir, iwc);
  w.forceMerge(1);
  w.close();
 

Warning: This merge policy may reorder documents if the index was partially upgraded before calling forceMerge (e.g., documents were added). If your application relies on "monotonicity" of doc IDs (which means that the order in which the documents were added to the index is preserved), do a forceMerge(1) instead. Please note, the delegate MergePolicy may also reorder documents.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.lucene.index.MergePolicy

org.apache.lucene.index.MergePolicy.MergeAbortedException, org.apache.lucene.index.MergePolicy.MergeContext, org.apache.lucene.index.MergePolicy.MergeException, org.apache.lucene.index.MergePolicy.MergeSpecification, org.apache.lucene.index.MergePolicy.OneMerge, org.apache.lucene.index.MergePolicy.OneMergeProgress

Constructor Summary

Constructors

Constructor and Description
LiveUpgradeMergePolicy(org.apache.lucene.index.MergePolicy in) Creates a new merge policy instance.

Method Summary

Modifier and Type	Method and Description
org.apache.lucene.index.MergePolicy.MergeSpecification	findForcedMerges(org.apache.lucene.index.SegmentInfos segmentInfos, int maxSegmentCount, java.util.Map<org.apache.lucene.index.SegmentCommitInfo,java.lang.Boolean> segmentsToMerge, org.apache.lucene.index.MergePolicy.MergeContext mergeContext)
void	setUpgradeInProgress(boolean upgradeInProgress)

Methods inherited from class org.apache.lucene.index.FilterMergePolicy

findForcedDeletesMerges, findMerges, getMaxCFSSegmentSizeMB, getNoCFSRatio, keepFullyDeletedSegment, numDeletesToMerge, setMaxCFSSegmentSizeMB, setNoCFSRatio, toString, useCompoundFile

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

LiveUpgradeMergePolicy

public LiveUpgradeMergePolicy(org.apache.lucene.index.MergePolicy in)

Creates a new merge policy instance.

Parameters:

in - the wrapped MergePolicy

Method Detail

setUpgradeInProgress

public void setUpgradeInProgress(boolean upgradeInProgress)

findForcedMerges

public org.apache.lucene.index.MergePolicy.MergeSpecification findForcedMerges(org.apache.lucene.index.SegmentInfos segmentInfos,
                                                                               int maxSegmentCount,
                                                                               java.util.Map<org.apache.lucene.index.SegmentCommitInfo,java.lang.Boolean> segmentsToMerge,
                                                                               org.apache.lucene.index.MergePolicy.MergeContext mergeContext)
                                                                        throws java.io.IOException

Overrides:

findForcedMerges in class org.apache.lucene.index.FilterMergePolicy

Throws:

java.io.IOException