Module org.elasticsearch.server

Package org.elasticsearch.index.codec.tsdb

Class AbstractTSDBDocValuesProducer

java.lang.Object

org.apache.lucene.codecs.DocValuesProducer

org.elasticsearch.index.codec.tsdb.AbstractTSDBDocValuesProducer

All Implemented Interfaces:

Closeable, AutoCloseable

public abstract class AbstractTSDBDocValuesProducer
extends org.apache.lucene.codecs.DocValuesProducer

Abstract base class for TSDB doc values producers. Contains all shared wire-format reading logic. Subclasses provide the numeric block decoding strategy.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractTSDBDocValuesProducer.BaseDenseNumericValues
class	AbstractTSDBDocValuesProducer.BaseSortedDocValues
static class	AbstractTSDBDocValuesProducer.NumericEntry
static class	AbstractTSDBDocValuesProducer.SortedNumericEntry
static class	AbstractTSDBDocValuesProducer.TSDBBinaryDocValues

Field Summary

Fields

Modifier and Type	Field	Description
protected final int	numericBlockSize

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractTSDBDocValuesProducer(org.apache.lucene.index.SegmentReadState state, String dataCodec, String dataExtension, String metaCodec, String metaExtension, TSDBDocValuesFormatConfig formatConfig, DocOffsetsCodec.Decoder docOffsetsDecoder)
protected	AbstractTSDBDocValuesProducer(AbstractTSDBDocValuesProducer original)

Method Summary

Modifier and Type	Method	Description
void	checkIntegrity()
void	close()
protected abstract AbstractTSDBDocValuesProducer	createMergeInstance()	Creates a copy of this producer for merge operations.
protected abstract NumericFieldReader	createNumericFieldReader(AbstractTSDBDocValuesProducer.NumericEntry entry, int numericBlockSize)	Creates a numeric field reader for the given entry.
org.apache.lucene.index.BinaryDocValues	getBinary(org.apache.lucene.index.FieldInfo field)
org.apache.lucene.codecs.DocValuesProducer	getMergeInstance()
org.apache.lucene.index.NumericDocValues	getNumeric(org.apache.lucene.index.FieldInfo field)
org.apache.lucene.index.DocValuesSkipper	getSkipper(org.apache.lucene.index.FieldInfo field)
org.apache.lucene.index.SortedDocValues	getSorted(org.apache.lucene.index.FieldInfo field)
org.apache.lucene.index.SortedNumericDocValues	getSortedNumeric(org.apache.lucene.index.FieldInfo field)
org.apache.lucene.index.SortedSetDocValues	getSortedSet(org.apache.lucene.index.FieldInfo field)
static int	primarySortFieldNumber(org.apache.lucene.index.SegmentInfo segmentInfo, org.apache.lucene.index.FieldInfos fieldInfos)	Returns the field number of the primary sort field for the given segment, if the field is sorted in ascending order.

Methods inherited from class java.lang.Object

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

Field Details

numericBlockSize

protected final int numericBlockSize

Constructor Details

AbstractTSDBDocValuesProducer

protected AbstractTSDBDocValuesProducer(org.apache.lucene.index.SegmentReadState state,
 String dataCodec,
 String dataExtension,
 String metaCodec,
 String metaExtension,
 TSDBDocValuesFormatConfig formatConfig,
 DocOffsetsCodec.Decoder docOffsetsDecoder)
                                 throws IOException

Throws:

IOException

AbstractTSDBDocValuesProducer

protected AbstractTSDBDocValuesProducer(AbstractTSDBDocValuesProducer original)

Method Details

createNumericFieldReader

protected abstract NumericFieldReader createNumericFieldReader(AbstractTSDBDocValuesProducer.NumericEntry entry,
 int numericBlockSize)

Creates a numeric field reader for the given entry.

Each codec version provides its own decoding strategy. The returned reader has two levels: NumericFieldReader.readField(org.apache.lucene.store.IndexInput, org.elasticsearch.index.codec.tsdb.AbstractTSDBDocValuesProducer.NumericEntry, int) reads the full field metadata during segment init, and NumericFieldReader.decoder() provides a per-block decoder for iteration.

Parameters:

entry - the numeric entry for this field

numericBlockSize - the number of values per numeric block

Returns:

a reader for this field

See Also:

• NumericFieldReader

createMergeInstance

protected abstract AbstractTSDBDocValuesProducer createMergeInstance()

Creates a copy of this producer for merge operations.

The returned instance shares the underlying IndexInput (via clone) but maintains independent read state, allowing concurrent iteration during merges.

Returns:

a merge-safe copy of this producer

getMergeInstance

public org.apache.lucene.codecs.DocValuesProducer getMergeInstance()

Overrides:

getMergeInstance in class org.apache.lucene.codecs.DocValuesProducer

getNumeric

public org.apache.lucene.index.NumericDocValues getNumeric(org.apache.lucene.index.FieldInfo field)
                                                    throws IOException

Specified by:

getNumeric in class org.apache.lucene.codecs.DocValuesProducer

Throws:

IOException

getBinary

public org.apache.lucene.index.BinaryDocValues getBinary(org.apache.lucene.index.FieldInfo field)
                                                  throws IOException

Specified by:

getBinary in class org.apache.lucene.codecs.DocValuesProducer

Throws:

IOException

getSorted

public org.apache.lucene.index.SortedDocValues getSorted(org.apache.lucene.index.FieldInfo field)
                                                  throws IOException

Specified by:

getSorted in class org.apache.lucene.codecs.DocValuesProducer

Throws:

IOException

getSortedNumeric

public org.apache.lucene.index.SortedNumericDocValues getSortedNumeric(org.apache.lucene.index.FieldInfo field)
                                                                throws IOException

Specified by:

getSortedNumeric in class org.apache.lucene.codecs.DocValuesProducer

Throws:

IOException

getSortedSet

public org.apache.lucene.index.SortedSetDocValues getSortedSet(org.apache.lucene.index.FieldInfo field)
                                                        throws IOException

Specified by:

getSortedSet in class org.apache.lucene.codecs.DocValuesProducer

Throws:

IOException

getSkipper

public org.apache.lucene.index.DocValuesSkipper getSkipper(org.apache.lucene.index.FieldInfo field)
                                                    throws IOException

Specified by:

getSkipper in class org.apache.lucene.codecs.DocValuesProducer

Throws:

IOException

checkIntegrity

public void checkIntegrity()
                    throws IOException

Specified by:

checkIntegrity in class org.apache.lucene.codecs.DocValuesProducer

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

primarySortFieldNumber

public static int primarySortFieldNumber(org.apache.lucene.index.SegmentInfo segmentInfo,
 org.apache.lucene.index.FieldInfos fieldInfos)

Returns the field number of the primary sort field for the given segment, if the field is sorted in ascending order. Returns -1 if not found.