public class ParallelReader extends IndexReader
This is useful, e.g., with collections that have large fields which change rarely and small fields that change more frequently. The smaller fields may be re-indexed in a new index and both indexes may be searched together.
Warning: It is up to you to make sure all indexes are created and modified the same way. For example, if you add documents to one index, you need to add the same documents in the same order to the other indexes. Failure to do so will result in undefined behavior.
IndexReader.FieldOptionhasChanges| Constructor and Description |
|---|
ParallelReader()
Construct a ParallelReader.
|
ParallelReader(boolean closeSubReaders)
Construct a ParallelReader.
|
| Modifier and Type | Method and Description |
|---|---|
void |
add(IndexReader reader)
Add an IndexReader.
|
void |
add(IndexReader reader,
boolean ignoreStoredFields)
Add an IndexReader whose stored fields will not be returned.
|
java.lang.Object |
clone()
Efficiently clones the IndexReader (sharing most
internal state).
|
int |
docFreq(Term term)
Returns the number of documents containing the term
t. |
protected void |
doClose()
Implements close.
|
protected void |
doCommit()
Deprecated.
|
protected void |
doCommit(java.util.Map commitUserData)
Implements commit.
|
Document |
document(int n,
FieldSelector fieldSelector)
Get the
Document at the n
th position. |
protected void |
doDelete(int n)
Implements deletion of the document numbered
docNum. |
protected IndexReader |
doReopen(boolean doClone) |
protected void |
doSetNorm(int n,
java.lang.String field,
byte value)
Implements setNorm in subclass.
|
protected void |
doUndeleteAll()
Implements actual undeleteAll() in subclass.
|
java.util.Collection |
getFieldNames(IndexReader.FieldOption fieldNames)
Get a list of unique field names that exist in this index and have the specified
field option information.
|
TermFreqVector |
getTermFreqVector(int n,
java.lang.String field)
Return a term frequency vector for the specified document and field.
|
void |
getTermFreqVector(int docNumber,
java.lang.String field,
TermVectorMapper mapper)
Load the Term Vector into a user-defined data structure instead of relying on the parallel arrays of
the
TermFreqVector. |
void |
getTermFreqVector(int docNumber,
TermVectorMapper mapper)
Map all the term vectors for all fields in a Document
|
TermFreqVector[] |
getTermFreqVectors(int n)
Return an array of term frequency vectors for the specified document.
|
long |
getVersion()
Not implemented.
|
boolean |
hasDeletions()
Returns true if any documents have been deleted
|
boolean |
hasNorms(java.lang.String field)
Returns true if there are norms stored for this field.
|
boolean |
isCurrent()
Checks recursively if all subreaders are up to date.
|
boolean |
isDeleted(int n)
Returns true if document n has been deleted
|
boolean |
isOptimized()
Checks recursively if all subindexes are optimized
|
int |
maxDoc()
Returns one greater than the largest possible document number.
|
byte[] |
norms(java.lang.String field)
Returns the byte-encoded normalization factor for the named field of
every document.
|
void |
norms(java.lang.String field,
byte[] result,
int offset)
Reads the byte-encoded normalization factor for the named field of every
document.
|
int |
numDocs()
Returns the number of documents in this index.
|
IndexReader |
reopen()
Tries to reopen the subreaders.
|
TermDocs |
termDocs()
Returns an unpositioned
TermDocs enumerator. |
TermDocs |
termDocs(Term term)
Returns an enumeration of all the documents which contain
term. |
TermPositions |
termPositions()
Returns an unpositioned
TermPositions enumerator. |
TermPositions |
termPositions(Term term)
Returns an enumeration of all the documents which contain
term. |
TermEnum |
terms()
Returns an enumeration of all the terms in the index.
|
TermEnum |
terms(Term term)
Returns an enumeration of all terms starting at a given term.
|
acquireWriteLock, clone, close, commit, commit, decRef, deleteDocument, deleteDocuments, directory, document, ensureOpen, flush, flush, getCommitUserData, getCommitUserData, getCurrentVersion, getCurrentVersion, getCurrentVersion, getDeletesCacheKey, getDisableFakeNorms, getFieldCacheKey, getIndexCommit, getRefCount, getSequentialSubReaders, getTermInfosIndexDivisor, getUniqueTermCount, incRef, indexExists, indexExists, indexExists, isLocked, isLocked, lastModified, lastModified, lastModified, listCommits, main, numDeletedDocs, open, open, open, open, open, open, open, open, open, open, open, open, open, open, reopen, reopen, setDisableFakeNorms, setNorm, setNorm, setTermInfosIndexDivisor, undeleteAll, unlockpublic ParallelReader()
throws java.io.IOException
Note that all subreaders are closed if this ParallelReader is closed.
java.io.IOExceptionpublic ParallelReader(boolean closeSubReaders)
throws java.io.IOException
closeSubReaders - indicates whether the subreaders should be closed
when this ParallelReader is closedjava.io.IOExceptionpublic void add(IndexReader reader) throws java.io.IOException
java.io.IOException - if there is a low-level IO errorpublic void add(IndexReader reader, boolean ignoreStoredFields) throws java.io.IOException
java.lang.IllegalArgumentException - if not all indexes contain the same number
of documentsjava.lang.IllegalArgumentException - if not all indexes have the same value
of IndexReader.maxDoc()java.io.IOException - if there is a low-level IO errorpublic java.lang.Object clone()
IndexReaderOn cloning a reader with pending changes (deletions, norms), the original reader transfers its write lock to the cloned reader. This means only the cloned reader may make further changes to the index, and commit the changes to the index on close, but the old reader still reflects all changes made up until it was cloned.
Like IndexReader.reopen(), it's safe to make changes to
either the original or the cloned reader: all shared
mutable state obeys "copy on write" semantics to ensure
the changes are not seen by other readers.
clone in class IndexReaderpublic IndexReader reopen() throws CorruptIndexException, java.io.IOException
A re-opened instance might share one or more subreaders with the old
instance. Index modification operations result in undefined behavior
when performed before the old instance is closed.
(see IndexReader.reopen()).
If subreaders are shared, then the reference count of those readers is increased to ensure that the subreaders remain open until the last referring reader is closed.
reopen in class IndexReaderCorruptIndexException - if the index is corruptjava.io.IOException - if there is a low-level IO errorprotected IndexReader doReopen(boolean doClone) throws CorruptIndexException, java.io.IOException
CorruptIndexExceptionjava.io.IOExceptionpublic int numDocs()
IndexReadernumDocs in class IndexReaderpublic int maxDoc()
IndexReadermaxDoc in class IndexReaderpublic boolean hasDeletions()
IndexReaderhasDeletions in class IndexReaderpublic boolean isDeleted(int n)
IndexReaderisDeleted in class IndexReaderprotected void doDelete(int n)
throws CorruptIndexException,
java.io.IOException
IndexReaderdocNum.
Applications should call IndexReader.deleteDocument(int) or IndexReader.deleteDocuments(Term).doDelete in class IndexReaderCorruptIndexExceptionjava.io.IOExceptionprotected void doUndeleteAll()
throws CorruptIndexException,
java.io.IOException
IndexReaderdoUndeleteAll in class IndexReaderCorruptIndexExceptionjava.io.IOExceptionpublic Document document(int n, FieldSelector fieldSelector) throws CorruptIndexException, java.io.IOException
IndexReaderDocument at the n
th position. The FieldSelector may be used to determine
what Fields to load and how they should
be loaded. NOTE: If this Reader (more specifically, the underlying
FieldsReader) is closed before the lazy
Field is loaded an exception may be
thrown. If you want the value of a lazy
Field to be available after closing you
must explicitly load it or fetch the Document again with a new loader.
NOTE: for performance reasons, this method does not check if the
requested document is deleted, and therefore asking for a deleted document
may yield unspecified results. Usually this is not required, however you
can call IndexReader.isDeleted(int) with the requested document ID to verify
the document is not deleted.
document in class IndexReadern - Get the document at the nth positionfieldSelector - The FieldSelector to use to determine what
Fields should be loaded on the Document. May be null, in which case
all Fields will be loaded.Document at the nth positionCorruptIndexException - if the index is corruptjava.io.IOException - if there is a low-level IO errorFieldable,
FieldSelector,
SetBasedFieldSelector,
LoadFirstFieldSelectorpublic TermFreqVector[] getTermFreqVectors(int n) throws java.io.IOException
IndexReaderTermFreqVector
or of type TermPositionVector if
positions or offsets have been stored.getTermFreqVectors in class IndexReadern - document for which term frequency vectors are returnedjava.io.IOException - if index cannot be accessedField.TermVectorpublic TermFreqVector getTermFreqVector(int n, java.lang.String field) throws java.io.IOException
IndexReaderTermPositionVector is returned.getTermFreqVector in class IndexReadern - document for which the term frequency vector is returnedfield - field for which the term frequency vector is returned.java.io.IOException - if index cannot be accessedField.TermVectorpublic void getTermFreqVector(int docNumber,
java.lang.String field,
TermVectorMapper mapper)
throws java.io.IOException
IndexReaderTermFreqVector.getTermFreqVector in class IndexReaderdocNumber - The number of the document to load the vector forfield - The name of the field to loadmapper - The TermVectorMapper to process the vector. Must not be nulljava.io.IOException - if term vectors cannot be accessed or if they do not exist on the field and doc. specified.public void getTermFreqVector(int docNumber,
TermVectorMapper mapper)
throws java.io.IOException
IndexReadergetTermFreqVector in class IndexReaderdocNumber - The number of the document to load the vector formapper - The TermVectorMapper to process the vector. Must not be nulljava.io.IOException - if term vectors cannot be accessed or if they do not exist on the field and doc. specified.public boolean hasNorms(java.lang.String field)
throws java.io.IOException
IndexReaderhasNorms in class IndexReaderjava.io.IOExceptionpublic byte[] norms(java.lang.String field)
throws java.io.IOException
IndexReadernorms in class IndexReaderjava.io.IOExceptionAbstractField.setBoost(float)public void norms(java.lang.String field,
byte[] result,
int offset)
throws java.io.IOException
IndexReadernorms in class IndexReaderjava.io.IOExceptionAbstractField.setBoost(float)protected void doSetNorm(int n,
java.lang.String field,
byte value)
throws CorruptIndexException,
java.io.IOException
IndexReaderdoSetNorm in class IndexReaderCorruptIndexExceptionjava.io.IOExceptionpublic TermEnum terms() throws java.io.IOException
IndexReaderTermEnum.next() must be called
on the resulting enumeration before calling other methods such as
TermEnum.term().terms in class IndexReaderjava.io.IOException - if there is a low-level IO errorpublic TermEnum terms(Term term) throws java.io.IOException
IndexReaderterms in class IndexReaderjava.io.IOException - if there is a low-level IO errorpublic int docFreq(Term term) throws java.io.IOException
IndexReadert.docFreq in class IndexReaderjava.io.IOException - if there is a low-level IO errorpublic TermDocs termDocs(Term term) throws java.io.IOException
IndexReaderterm. For each document, the document number, the frequency of
the term in that document is also provided, for use in
search scoring. If term is null, then all non-deleted
docs are returned with freq=1.
Thus, this method implements the mapping:
The enumeration is ordered by document number. Each document number is greater than all that precede it in the enumeration.
termDocs in class IndexReaderjava.io.IOException - if there is a low-level IO errorpublic TermDocs termDocs() throws java.io.IOException
IndexReaderTermDocs enumerator.termDocs in class IndexReaderjava.io.IOException - if there is a low-level IO errorpublic TermPositions termPositions(Term term) throws java.io.IOException
IndexReaderterm. For each document, in addition to the document number
and frequency of the term in that document, a list of all of the ordinal
positions of the term in the document is available. Thus, this method
implements the mapping:
This positional information facilitates phrase and proximity searching.
The enumeration is ordered by document number. Each document number is greater than all that precede it in the enumeration.
termPositions in class IndexReaderjava.io.IOException - if there is a low-level IO errorpublic TermPositions termPositions() throws java.io.IOException
IndexReaderTermPositions enumerator.termPositions in class IndexReaderjava.io.IOException - if there is a low-level IO errorpublic boolean isCurrent()
throws CorruptIndexException,
java.io.IOException
isCurrent in class IndexReaderCorruptIndexException - if the index is corruptjava.io.IOException - if there is a low-level IO errorpublic boolean isOptimized()
isOptimized in class IndexReadertrue if the index is optimized; false otherwisepublic long getVersion()
getVersion in class IndexReaderjava.lang.UnsupportedOperationExceptionprotected void doCommit()
throws java.io.IOException
IndexReaderdoCommit in class IndexReaderjava.io.IOExceptionprotected void doCommit(java.util.Map commitUserData)
throws java.io.IOException
IndexReaderjava.io.IOExceptionprotected void doClose()
throws java.io.IOException
IndexReaderdoClose in class IndexReaderjava.io.IOExceptionpublic java.util.Collection getFieldNames(IndexReader.FieldOption fieldNames)
IndexReadergetFieldNames in class IndexReaderfieldNames - specifies which field option should be available for the returned fieldsIndexReader.FieldOptionCopyright © 2000-2016 Apache Software Foundation. All Rights Reserved.