core/org.gnit.lucenekmp.index/SerialMergeScheduler

SerialMergeScheduler

open class SerialMergeScheduler : MergeScheduler

A MergeScheduler that simply does each merge sequentially, using the current thread.

Constructors

constructor()

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

open suspend override 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 [ ].