core/org.gnit.lucenekmp.index/MergeScheduler

MergeScheduler

abstract class MergeScheduler : AutoCloseable

Expert: IndexWriter uses an instance implementing this interface to execute the merges selected by a MergePolicy. The default MergeScheduler is [ ].

Inheritors

ConcurrentMergeScheduler

NoMergeScheduler

SerialMergeScheduler

Types

MergeSource

interface MergeSource

Provides access to new merges and executes the actual merge

Functions

open override fun close()

Close this MergeScheduler.

getIntraMergeExecutor

open fun getIntraMergeExecutor(merge: MergePolicy.OneMerge): Executor

Provides an executor for parallelism during a single merge operation. By default, the method returns a SameThreadExecutorService where all intra-merge actions occur in their calling thread.

initialize

open fun initialize(infoStream: InfoStream, directory: Directory)

IndexWriter calls this on init.

merge

abstract suspend fun merge(mergeSource: MergeScheduler.MergeSource, trigger: MergeTrigger)

Run the merges provided by MergeSource.getNextMerge.

message

fun message(message: String)

Outputs the given message - this method assumes .verbose was called and returned true.

verbose

fun verbose(): Boolean

Returns true if infoStream messages are enabled. This method is usually used in conjunction with .message:

wrapForMerge

open fun wrapForMerge(merge: MergePolicy.OneMerge, in: Directory): Directory

Wraps the incoming Directory so that we can merge-throttle it using [ ].