org.apache.lucene.codecs.uniformsplit.sharedterms

Class STMergingBlockReader

java.lang.Object

org.apache.lucene.index.TermsEnum

org.apache.lucene.index.BaseTermsEnum

org.apache.lucene.codecs.uniformsplit.BlockReader

org.apache.lucene.codecs.uniformsplit.sharedterms.STBlockReader

org.apache.lucene.codecs.uniformsplit.sharedterms.STMergingBlockReader

All Implemented Interfaces:

Accountable, BytesRefIterator

public class STMergingBlockReader
extends STBlockReader

TermsEnum used when merging segments, to enumerate the terms of an input segment and get all the fields TermStates of each term.

It only supports calls to next() and no seek method.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.lucene.index.TermsEnum

TermsEnum.SeekStatus

Field Summary

Fields inherited from class org.apache.lucene.codecs.uniformsplit.sharedterms.STBlockReader

fieldInfos

Fields inherited from class org.apache.lucene.codecs.uniformsplit.BlockReader

blockDecoder, blockFirstLineStart, blockHeader, blockInput, blockLine, blockLineReader, blockReadBuffer, blockStartFP, dictionaryBrowser, dictionaryBrowserSupplier, fieldMetadata, forcedTerm, lineIndexInBlock, postingsReader, scratchBlockBytes, scratchTermState, termState, termStateForced, termStateSerializer, termStatesReadBuffer

Fields inherited from class org.apache.lucene.index.TermsEnum

EMPTY

Constructor Summary

Constructors

Constructor and Description
STMergingBlockReader(java.util.function.Supplier<IndexDictionary.Browser> dictionaryBrowserSupplier, IndexInput blockInput, PostingsReaderBase postingsReader, FieldMetadata fieldMetadata, BlockDecoder blockDecoder, FieldInfos fieldInfos)

Method Summary

Modifier and Type	Method and Description
BytesRef	next() Increments the iteration to the next BytesRef in the iterator.
PostingsEnum	postings(java.lang.String fieldName, BlockTermState termState, PostingsEnum reuse, int flags) Creates a new PostingsEnum for the provided field and BlockTermState.
void	readFieldTermStatesMap(java.util.Map<java.lang.String,BlockTermState> fieldTermStatesMap) Reads all the fields TermStates of the current term and put them in the provided map.
protected BlockTermState	readTermStateIfNotRead() Reads the BlockTermState if it is not already set.
TermsEnum.SeekStatus	seekCeil(BytesRef searchedTerm) Seeks to the specified term, if it exists, or to the next (ceiling) term.
boolean	seekExact(BytesRef searchedTerm) Attempts to seek to the exact term, returning true if the term is found.
void	seekExact(BytesRef term, TermState state) Positions this BlockReader without re-seeking the term dictionary.
void	seekExact(long ord) Not supported.

Methods inherited from class org.apache.lucene.codecs.uniformsplit.sharedterms.STBlockReader

isBeyondLastTerm, nextTerm, readTermState, seekCeilIgnoreField

Methods inherited from class org.apache.lucene.codecs.uniformsplit.BlockReader

clearTermState, compareToMiddleAndJump, decodeBlockBytesIfNeeded, docFreq, getOrCreateDictionaryBrowser, impacts, initializeBlockReadLazily, initializeHeader, isCurrentTerm, ord, postings, ramBytesUsed, readHeader, readLineInBlock, seekInBlock, seekInBlock, term, termState, totalTermFreq

Methods inherited from class org.apache.lucene.index.BaseTermsEnum

attributes

Methods inherited from class org.apache.lucene.index.TermsEnum

postings

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.lucene.util.Accountable

getChildResources

Constructor Detail

STMergingBlockReader

public STMergingBlockReader(java.util.function.Supplier<IndexDictionary.Browser> dictionaryBrowserSupplier,
                            IndexInput blockInput,
                            PostingsReaderBase postingsReader,
                            FieldMetadata fieldMetadata,
                            BlockDecoder blockDecoder,
                            FieldInfos fieldInfos)
                     throws java.io.IOException

Throws:

java.io.IOException

Method Detail

seekCeil

public TermsEnum.SeekStatus seekCeil(BytesRef searchedTerm)

Description copied from class: TermsEnum

Seeks to the specified term, if it exists, or to the next (ceiling) term. Returns SeekStatus to indicate whether exact term was found, a different term was found, or EOF was hit. The target term may be before or after the current term. If this returns SeekStatus.END, the enum is unpositioned.

Overrides:

seekCeil in class STBlockReader

seekExact

public boolean seekExact(BytesRef searchedTerm)

Description copied from class: TermsEnum

Attempts to seek to the exact term, returning true if the term is found. If this returns false, the enum is unpositioned. For some codecs, seekExact may be substantially faster than TermsEnum.seekCeil(org.apache.lucene.util.BytesRef).

Overrides:

seekExact in class STBlockReader

Returns:

true if the term is found; return false if the enum is unpositioned.

seekExact

public void seekExact(BytesRef term,
                      TermState state)

Description copied from class: BlockReader

Positions this BlockReader without re-seeking the term dictionary.

The block containing the term is not read by this method. It will be read lazily only if needed, for example if BlockReader.next() is called. Calling BlockReader.postings(org.apache.lucene.index.PostingsEnum, int) after this method does require the block to be read.

Overrides:

seekExact in class BlockReader

Parameters:

term - the term the TermState corresponds to

state - the TermState

seekExact

public void seekExact(long ord)

Description copied from class: BlockReader

Not supported.

Overrides:

seekExact in class BlockReader

readTermStateIfNotRead

protected BlockTermState readTermStateIfNotRead()

Description copied from class: BlockReader

Reads the BlockTermState if it is not already set. Sets BlockReader.termState.

Overrides:

readTermStateIfNotRead in class BlockReader

next

public BytesRef next()
              throws java.io.IOException

Description copied from interface: BytesRefIterator

Increments the iteration to the next BytesRef in the iterator. Returns the resulting BytesRef or null if the end of the iterator is reached. The returned BytesRef may be re-used across calls to next. After this method returns null, do not call it again: the results are undefined.

Specified by:

next in interface BytesRefIterator

Overrides:

next in class STBlockReader

Returns:

the next BytesRef in the iterator or null if the end of the iterator is reached.

Throws:

java.io.IOException - If there is a low-level I/O error.

postings

public PostingsEnum postings(java.lang.String fieldName,
                             BlockTermState termState,
                             PostingsEnum reuse,
                             int flags)
                      throws java.io.IOException

Creates a new PostingsEnum for the provided field and BlockTermState.

Parameters:

reuse - Previous PostingsEnum to reuse; or null to create a new one.

flags - Postings flags.

Throws:

java.io.IOException

readFieldTermStatesMap

public void readFieldTermStatesMap(java.util.Map<java.lang.String,BlockTermState> fieldTermStatesMap)
                            throws java.io.IOException

Reads all the fields TermStates of the current term and put them in the provided map. Clears the map first, before putting TermStates.

Throws:

java.io.IOException