test-framework/org.gnit.lucenekmp.tests.index/SuppressingConcurrentMergeScheduler

SuppressingConcurrentMergeScheduler

abstract class SuppressingConcurrentMergeScheduler : ConcurrentMergeScheduler

A ConcurrentMergeScheduler that ignores allowed exceptions.

Constructors

SuppressingConcurrentMergeScheduler

constructor()

Properties

var autoIOThrottle: Boolean

iORateLimitMBPerSec

val iORateLimitMBPerSec: Double

var maxMergeCount: Int

var maxThreadCount: Int

Functions

clearSuppressExceptions

fun clearSuppressExceptions()

open override fun close()

disableAutoIOThrottle

fun disableAutoIOThrottle()

enableAutoIOThrottle

fun enableAutoIOThrottle()

getForceMergeMBPerSec

fun getForceMergeMBPerSec(): Double

getIntraMergeExecutor

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

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

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

mergeThreadCount

fun mergeThreadCount(): Int

fun message(message: String)

removeMergeThread

fun removeMergeThread(currentJob: Job?)

runOnMergeFinished

suspend fun runOnMergeFinished(mergeSource: MergeScheduler.MergeSource)

setDefaultMaxMergesAndThreads

fun setDefaultMaxMergesAndThreads(spins: Boolean)

setForceMergeMBPerSec

fun setForceMergeMBPerSec(v: Double)

setMaxMergesAndThreads

fun setMaxMergesAndThreads(maxMergeCount: Int, maxThreadCount: Int)

setSuppressExceptions

fun setSuppressExceptions()

suspend fun sync()

open override fun toString(): String

fun verbose(): Boolean

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