Module org.apache.lucene.core

Package org.apache.lucene.index

Class FrozenBufferedUpdates

java.lang.Object

org.apache.lucene.index.FrozenBufferedUpdates

final class FrozenBufferedUpdates
extends Object

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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	FrozenBufferedUpdates.TermDocsIterator	This class helps iterating a term dictionary and consuming all the docs for each terms.

Field Summary

Fields

Modifier and Type	Field	Description
final CountDownLatch	applied	Counts down once all deletes/updates have been applied
private final ReentrantLock	applyLock
(package private) static final int	BYTES_PER_DEL_QUERY
(package private) final int	bytesUsed
(package private) final Query[]	deleteQueries
(package private) final int[]	deleteQueryLimits
(package private) final PrefixCodedTerms	deleteTerms
private long	delGen
private final Map<String,FieldUpdatesBuffer>	fieldUpdates
private final int	fieldUpdatesCount
private final InfoStream	infoStream
(package private) final SegmentCommitInfo	privateSegment
long	totalDelCount	How many total documents were deleted/updated.

Constructor Summary

Constructors

Constructor	Description
FrozenBufferedUpdates(InfoStream infoStream, BufferedUpdates updates, SegmentCommitInfo privateSegment)

Method Summary

Modifier and Type	Method	Description
(package private) boolean	any()
(package private) long	apply(BufferedUpdatesStream.SegmentState[] segStates)	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.
private long	applyDocValuesUpdates(BufferedUpdatesStream.SegmentState[] segStates)
private static long	applyDocValuesUpdates(BufferedUpdatesStream.SegmentState segState, Map<String,FieldUpdatesBuffer> updates, long delGen, boolean segmentPrivateDeletes)
private long	applyQueryDeletes(BufferedUpdatesStream.SegmentState[] segStates)
private long	applyTermDeletes(BufferedUpdatesStream.SegmentState[] segStates)
long	delGen()
(package private) boolean	isApplied()	Returns true iff this buffered updates instance was already applied
(package private) void	lock()	locks this buffered update instance
void	setDelGen(long delGen)
String	toString()
(package private) boolean	tryLock()	Tries to lock this buffered update instance
(package private) void	unlock()	Releases the lock of this buffered update instance

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

BYTES_PER_DEL_QUERY

static final int BYTES_PER_DEL_QUERY

deleteTerms

final PrefixCodedTerms deleteTerms

deleteQueries

final Query[] deleteQueries

deleteQueryLimits

final int[] deleteQueryLimits

applied

public final CountDownLatch applied

Counts down once all deletes/updates have been applied

applyLock

private final ReentrantLock applyLock

fieldUpdates

private final Map<String,FieldUpdatesBuffer> fieldUpdates

totalDelCount

public long totalDelCount

How many total documents were deleted/updated.

fieldUpdatesCount

private final int fieldUpdatesCount

bytesUsed

final int bytesUsed

delGen

private long delGen

privateSegment

final SegmentCommitInfo privateSegment

infoStream

private final InfoStream infoStream

Constructor Details

FrozenBufferedUpdates

public FrozenBufferedUpdates(InfoStream infoStream,
 BufferedUpdates updates,
 SegmentCommitInfo privateSegment)

Method Details

tryLock

boolean tryLock()

Tries to lock this buffered update instance

Returns:

true if the lock was successfully acquired. otherwise false.

lock

void lock()

locks this buffered update instance

unlock

void unlock()

Releases the lock of this buffered update instance

isApplied

boolean isApplied()

Returns true iff this buffered updates instance was already applied

apply

long apply(BufferedUpdatesStream.SegmentState[] segStates)
    throws IOException

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.

Throws:

IOException

applyDocValuesUpdates

private long applyDocValuesUpdates(BufferedUpdatesStream.SegmentState[] segStates)
                            throws IOException

Throws:

IOException

applyDocValuesUpdates

private static long applyDocValuesUpdates(BufferedUpdatesStream.SegmentState segState,
 Map<String,FieldUpdatesBuffer> updates,
 long delGen,
 boolean segmentPrivateDeletes)
                                   throws IOException

Throws:

IOException

applyQueryDeletes

private long applyQueryDeletes(BufferedUpdatesStream.SegmentState[] segStates)
                        throws IOException

Throws:

IOException

applyTermDeletes

private long applyTermDeletes(BufferedUpdatesStream.SegmentState[] segStates)
                       throws IOException

Throws:

IOException

setDelGen

public void setDelGen(long delGen)

delGen

public long delGen()

toString

public String toString()

Overrides:

toString in class Object

any

boolean any()