core/org.gnit.lucenekmp.index/FrozenBufferedUpdates

FrozenBufferedUpdates

class FrozenBufferedUpdates(infoStream: InfoStream, updates: BufferedUpdates, val privateSegment: SegmentCommitInfo?)

Holds buffered deletes and updates by term or query, once pushed. Pushed deletes/updates are write-once, so we shift to more memory efficient data structure to hold them. We don't hold docIDs because these are applied on flush.

Constructors

constructor(infoStream: InfoStream, updates: BufferedUpdates, privateSegment: SegmentCommitInfo?)

Types

Companion

object Companion

Properties

applied

val applied: CountDownLatch

Counts down once all deletes/updates have been applied

bytesUsed

val bytesUsed: Int

deleteQueries

val deleteQueries: Array<Query>

deleteQueryLimits

val deleteQueryLimits: IntArray

deleteTerms

val deleteTerms: PrefixCodedTerms

privateSegment

val privateSegment: SegmentCommitInfo?

totalDelCount

var totalDelCount: Long

How many total documents were deleted/updated.

Functions

any

fun any(): Boolean

apply

suspend fun apply(segStates: Array<BufferedUpdatesStream.SegmentState>): Long

Applies pending delete-by-term, delete-by-query and doc values updates to all segments in the index, returning the number of new deleted or updated documents.

delGen

fun delGen(): Long

isApplied

fun isApplied(): Boolean

Returns true iff this buffered updates instance was already applied

lock

fun lock()

locks this buffered update instance

setDelGen

fun setDelGen(delGen: Long)

toString

open override fun toString(): String