org.apache.lucene.index

Class ReadersAndUpdates

java.lang.Object

org.apache.lucene.index.ReadersAndUpdates

class ReadersAndUpdates
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
SegmentCommitInfo	info
private boolean	isMerging
private Bits	liveDocs
private boolean	liveDocsShared
private java.util.Map<java.lang.String,java.util.List<DocValuesFieldUpdates>>	mergingDVUpdates
private int	pendingDeleteCount
private java.util.Map<java.lang.String,java.util.List<DocValuesFieldUpdates>>	pendingDVUpdates
java.util.concurrent.atomic.AtomicLong	ramBytesUsed
private SegmentReader	reader
private java.util.concurrent.atomic.AtomicInteger	refCount
(package private) Sorter.DocMap	sortMap
private IndexWriter	writer

Constructor Summary

Constructors

Constructor and Description
ReadersAndUpdates(IndexWriter writer, SegmentCommitInfo info)
ReadersAndUpdates(IndexWriter writer, SegmentReader reader) Init from a previously opened SegmentReader.

Method Summary

Modifier and Type	Method and Description
void	addDVUpdate(DocValuesFieldUpdates update) Adds a new resolved (meaning it maps docIDs to new values) doc values packet.
private boolean	assertNoDupGen(java.util.List<DocValuesFieldUpdates> fieldUpdates, DocValuesFieldUpdates update)
void	decRef()
boolean	delete(int docID)
void	dropChanges()
void	dropMergingUpdates() Drops all merging updates.
void	dropReaders()
Bits	getLiveDocs()
java.util.Map<java.lang.String,java.util.List<DocValuesFieldUpdates>>	getMergingDVUpdates()
long	getNumDVUpdates()
int	getPendingDeleteCount()
SegmentReader	getReader(IOContext context) Returns a SegmentReader.
(package private) SegmentReader	getReaderForMerge(IOContext context) Returns a reader for merge, with the latest doc values updates and deletions.
SegmentReader	getReadOnlyClone(IOContext context) Returns a ref to a clone.
Bits	getReadOnlyLiveDocs()
private void	handleBinaryDVUpdates(FieldInfos infos, TrackingDirectoryWrapper dir, DocValuesFormat dvFormat, SegmentReader reader, java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> fieldFiles, long maxDelGen, InfoStream infoStream)
private void	handleNumericDVUpdates(FieldInfos infos, Directory dir, DocValuesFormat dvFormat, SegmentReader reader, java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> fieldFiles, long maxDelGen, InfoStream infoStream)
void	incRef()
private void	initWritableLiveDocs()
int	refCount()
void	release(SegmentReader sr)
void	setIsMerging()
java.lang.String	toString()
boolean	verifyDocCounts()
private java.util.Set<java.lang.String>	writeFieldInfosGen(FieldInfos fieldInfos, Directory dir, DocValuesFormat dvFormat, FieldInfosFormat infosFormat)
boolean	writeFieldUpdates(Directory dir, long maxDelGen, InfoStream infoStream)
boolean	writeLiveDocs(Directory dir)

Methods inherited from class java.lang.Object

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

Field Detail

info

public final SegmentCommitInfo info

refCount

private final java.util.concurrent.atomic.AtomicInteger refCount

writer

private final IndexWriter writer

reader

private SegmentReader reader

liveDocs

private Bits liveDocs

pendingDeleteCount

private int pendingDeleteCount

liveDocsShared

private boolean liveDocsShared

isMerging

private boolean isMerging

pendingDVUpdates

private final java.util.Map<java.lang.String,java.util.List<DocValuesFieldUpdates>> pendingDVUpdates

mergingDVUpdates

private final java.util.Map<java.lang.String,java.util.List<DocValuesFieldUpdates>> mergingDVUpdates

sortMap

Sorter.DocMap sortMap

ramBytesUsed

public final java.util.concurrent.atomic.AtomicLong ramBytesUsed

Constructor Detail

ReadersAndUpdates

public ReadersAndUpdates(IndexWriter writer,
                         SegmentCommitInfo info)

ReadersAndUpdates

public ReadersAndUpdates(IndexWriter writer,
                         SegmentReader reader)

Init from a previously opened SegmentReader.

NOTE: steals incoming ref from reader.

Method Detail

incRef

public void incRef()

decRef

public void decRef()

refCount

public int refCount()

getPendingDeleteCount

public int getPendingDeleteCount()

assertNoDupGen

private boolean assertNoDupGen(java.util.List<DocValuesFieldUpdates> fieldUpdates,
                               DocValuesFieldUpdates update)

addDVUpdate

public void addDVUpdate(DocValuesFieldUpdates update)

Adds a new resolved (meaning it maps docIDs to new values) doc values packet. We buffer these in RAM and write to disk when too much RAM is used or when a merge needs to kick off, or a commit/refresh.

getNumDVUpdates

public long getNumDVUpdates()

verifyDocCounts

public boolean verifyDocCounts()

getReader

public SegmentReader getReader(IOContext context)
                        throws java.io.IOException

Returns a SegmentReader.

Throws:

java.io.IOException

release

public void release(SegmentReader sr)
             throws java.io.IOException

Throws:

java.io.IOException

delete

public boolean delete(int docID)
               throws java.io.IOException

Throws:

java.io.IOException

dropReaders

public void dropReaders()
                 throws java.io.IOException

Throws:

java.io.IOException

getReadOnlyClone

public SegmentReader getReadOnlyClone(IOContext context)
                               throws java.io.IOException

Returns a ref to a clone. NOTE: you should decRef() the reader when you're done (ie do not call close()).

Throws:

java.io.IOException

initWritableLiveDocs

private void initWritableLiveDocs()
                           throws java.io.IOException

Throws:

java.io.IOException

getLiveDocs

public Bits getLiveDocs()

getReadOnlyLiveDocs

public Bits getReadOnlyLiveDocs()

dropChanges

public void dropChanges()

writeLiveDocs

public boolean writeLiveDocs(Directory dir)
                      throws java.io.IOException

Throws:

java.io.IOException

handleNumericDVUpdates

private void handleNumericDVUpdates(FieldInfos infos,
                                    Directory dir,
                                    DocValuesFormat dvFormat,
                                    SegmentReader reader,
                                    java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> fieldFiles,
                                    long maxDelGen,
                                    InfoStream infoStream)
                             throws java.io.IOException

Throws:

java.io.IOException

handleBinaryDVUpdates

private void handleBinaryDVUpdates(FieldInfos infos,
                                   TrackingDirectoryWrapper dir,
                                   DocValuesFormat dvFormat,
                                   SegmentReader reader,
                                   java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> fieldFiles,
                                   long maxDelGen,
                                   InfoStream infoStream)
                            throws java.io.IOException

Throws:

java.io.IOException

writeFieldInfosGen

private java.util.Set<java.lang.String> writeFieldInfosGen(FieldInfos fieldInfos,
                                                           Directory dir,
                                                           DocValuesFormat dvFormat,
                                                           FieldInfosFormat infosFormat)
                                                    throws java.io.IOException

Throws:

java.io.IOException

writeFieldUpdates

public boolean writeFieldUpdates(Directory dir,
                                 long maxDelGen,
                                 InfoStream infoStream)
                          throws java.io.IOException

Throws:

java.io.IOException

setIsMerging

public void setIsMerging()

getReaderForMerge

SegmentReader getReaderForMerge(IOContext context)
                         throws java.io.IOException

Returns a reader for merge, with the latest doc values updates and deletions.

Throws:

java.io.IOException

dropMergingUpdates

public void dropMergingUpdates()

Drops all merging updates. Called from IndexWriter after this segment finished merging (whether successfully or not).

getMergingDVUpdates

public java.util.Map<java.lang.String,java.util.List<DocValuesFieldUpdates>> getMergingDVUpdates()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object