Uses of Class
org.apache.lucene.index.MergePolicy.OneMerge
Packages that use MergePolicy.OneMerge
-
Uses of MergePolicy.OneMerge in org.apache.lucene.index
Fields in org.apache.lucene.index declared as MergePolicy.OneMergeModifier and TypeFieldDescription(package private) final MergePolicy.OneMergeConcurrentMergeScheduler.MergeThread.mergeFields in org.apache.lucene.index with type parameters of type MergePolicy.OneMergeModifier and TypeFieldDescriptionprivate final List<MergePolicy.OneMerge> IndexWriter.mergeExceptionsfinal List<MergePolicy.OneMerge> MergePolicy.MergeSpecification.mergesThe subset of segments to be included in the primitive merge.private final Queue<MergePolicy.OneMerge> IndexWriter.AddIndexesMergeSource.pendingAddIndexesMergesprivate final Deque<MergePolicy.OneMerge> IndexWriter.pendingMergesprivate final Set<MergePolicy.OneMerge> IndexWriter.runningMergesprivate final UnaryOperator<MergePolicy.OneMerge> OneMergeWrappingMergePolicy.wrapOneMergeMethods in org.apache.lucene.index that return MergePolicy.OneMergeModifier and TypeMethodDescriptionIndexWriter.AddIndexesMergeSource.getNextMerge()private MergePolicy.OneMergeIndexWriter.getNextMerge()Expert: theMergeSchedulercalls this method to retrieve the next merge requested by the MergePolicyIndexWriter.IndexWriterMergeSource.getNextMerge()MergeScheduler.MergeSource.getNextMerge()TheMergeSchedulercalls this method to retrieve the next merge requested by the MergePolicyMethods in org.apache.lucene.index with parameters of type MergePolicy.OneMergeModifier and TypeMethodDescriptionprivate voidIndexWriter._mergeInit(MergePolicy.OneMerge merge) private voidIndexWriter.abortOneMerge(MergePolicy.OneMerge merge) voidMergePolicy.MergeSpecification.add(MergePolicy.OneMerge merge) Adds the providedMergePolicy.OneMergeto this specification.voidIndexWriter.addIndexesReaderMerge(MergePolicy.OneMerge merge) Runs a single merge operation forIndexWriter.addIndexes(CodecReader...).private voidIndexWriter.addMergeException(MergePolicy.OneMerge merge) (package private) voidSegmentInfos.applyMergeChanges(MergePolicy.OneMerge merge, boolean dropSegment) applies all changes caused by committing a merge to this SegmentInfosprivate voidIndexWriter.closeMergeReaders(MergePolicy.OneMerge merge, boolean suppressExceptions, boolean droppedSegment) private booleanIndexWriter.commitMerge(MergePolicy.OneMerge merge, MergeState.DocMap[] docMaps) private ReadersAndUpdatesIndexWriter.commitMergedDeletesAndUpdates(MergePolicy.OneMerge merge, MergeState.DocMap[] docMaps) Carefully merges deletes and updates for the segments we just merged.protected voidConcurrentMergeScheduler.doMerge(MergeScheduler.MergeSource mergeSource, MergePolicy.OneMerge merge) Does the actual merge, by callingMergeScheduler.MergeSource.merge(org.apache.lucene.index.MergePolicy.OneMerge)private voidIndexWriter.ensureValidMerge(MergePolicy.OneMerge merge) ConcurrentMergeScheduler.getIntraMergeExecutor(MergePolicy.OneMerge merge) MergeScheduler.getIntraMergeExecutor(MergePolicy.OneMerge merge) Provides an executor for parallelism during a single merge operation.NoMergeScheduler.getIntraMergeExecutor(MergePolicy.OneMerge merge) protected ConcurrentMergeScheduler.MergeThreadConcurrentMergeScheduler.getMergeThread(MergeScheduler.MergeSource mergeSource, MergePolicy.OneMerge merge) Create and return a new MergeThreadprivate static StringConcurrentMergeScheduler.getSegmentName(MergePolicy.OneMerge merge) private voidIndexWriter.handleMergeException(Throwable t, MergePolicy.OneMerge merge) private booleanConcurrentMergeScheduler.isBacklog(long now, MergePolicy.OneMerge merge) voidIndexWriter.AddIndexesMergeSource.merge(MergePolicy.OneMerge merge) voidIndexWriter.IndexWriterMergeSource.merge(MergePolicy.OneMerge merge) protected voidIndexWriter.merge(MergePolicy.OneMerge merge) Merges the indicated segments, replacing them in the stack with a single segment.voidMergeScheduler.MergeSource.merge(MergePolicy.OneMerge merge) Merges the indicated segments, replacing them in the stack with a single segment.private voidIndexWriter.mergeFinish(MergePolicy.OneMerge merge) Does finishing for a merge, which is fast but holds the synchronized lock on IndexWriter instance.(package private) final voidIndexWriter.mergeInit(MergePolicy.OneMerge merge) Does initial setup for a merge, which is fast but holds the synchronized lock on IndexWriter instance.private intIndexWriter.mergeMiddle(MergePolicy.OneMerge merge, MergePolicy mergePolicy) Does the actual (time-consuming) work of the merge, but without holding synchronized lock on IndexWriter instanceprotected voidIndexWriter.mergeSuccess(MergePolicy.OneMerge merge) Hook that's called when the specified merge is complete.voidIndexWriter.AddIndexesMergeSource.onMergeFinished(MergePolicy.OneMerge merge) voidIndexWriter.IndexWriterMergeSource.onMergeFinished(MergePolicy.OneMerge merge) voidMergeScheduler.MergeSource.onMergeFinished(MergePolicy.OneMerge merge) Does finishing for a merge.voidIndexWriter.AddIndexesMergeSource.registerMerge(MergePolicy.OneMerge merge) private booleanIndexWriter.registerMerge(MergePolicy.OneMerge merge) Checks whether this merge involves any segments already participating in a merge.private voidConcurrentMergeScheduler.updateIOThrottle(MergePolicy.OneMerge newMerge, MergeRateLimiter rateLimiter) Tunes IO throttle when a new merge starts.ConcurrentMergeScheduler.wrapForMerge(MergePolicy.OneMerge merge, Directory in) MergeScheduler.wrapForMerge(MergePolicy.OneMerge merge, Directory in) Wraps the incomingDirectoryso that we can merge-throttle it usingRateLimitedIndexOutput.NoMergeScheduler.wrapForMerge(MergePolicy.OneMerge merge, Directory in) Constructors in org.apache.lucene.index with parameters of type MergePolicy.OneMergeModifierConstructorDescriptionMergeThread(MergeScheduler.MergeSource mergeSource, MergePolicy.OneMerge merge) Sole constructor.protectedOneMerge(MergePolicy.OneMerge oneMerge) Constructor for wrapping.Constructor parameters in org.apache.lucene.index with type arguments of type MergePolicy.OneMergeModifierConstructorDescriptionOneMergeWrappingMergePolicy(MergePolicy in, UnaryOperator<MergePolicy.OneMerge> wrapOneMerge) Constructor