Package org.apache.drill.exec.vector.complex.impl

Class SingleDictReaderImpl

java.lang.Object

org.apache.drill.exec.vector.complex.impl.AbstractFieldReader

org.apache.drill.exec.vector.complex.impl.AbstractRepeatedMapReaderImpl<DictVector>

org.apache.drill.exec.vector.complex.impl.SingleDictReaderImpl

All Implemented Interfaces:

Iterable<String>, Positionable, BaseReader, BaseReader.DictReader, BaseReader.ListReader, BaseReader.MapReader, BaseReader.RepeatedListReader, BaseReader.RepeatedMapReader, BaseReader.ScalarReader, BigIntReader, BitReader, DateReader, Decimal18Reader, Decimal28DenseReader, Decimal28SparseReader, Decimal38DenseReader, Decimal38SparseReader, Decimal9Reader, FieldReader, Float4Reader, Float8Reader, IntervalDayReader, IntervalReader, IntervalYearReader, IntReader, RepeatedBigIntReader, RepeatedBitReader, RepeatedDateReader, RepeatedDecimal18Reader, RepeatedDecimal28DenseReader, RepeatedDecimal28SparseReader, RepeatedDecimal38DenseReader, RepeatedDecimal38SparseReader, RepeatedDecimal9Reader, RepeatedFloat4Reader, RepeatedFloat8Reader, RepeatedIntervalDayReader, RepeatedIntervalReader, RepeatedIntervalYearReader, RepeatedIntReader, RepeatedSmallIntReader, RepeatedTimeReader, RepeatedTimeStampReader, RepeatedTinyIntReader, RepeatedUInt1Reader, RepeatedUInt2Reader, RepeatedUInt4Reader, RepeatedUInt8Reader, RepeatedVar16CharReader, RepeatedVarBinaryReader, RepeatedVarCharReader, RepeatedVarDecimalReader, SmallIntReader, TimeReader, TimeStampReader, TinyIntReader, UInt1Reader, UInt2Reader, UInt4Reader, UInt8Reader, Var16CharReader, VarBinaryReader, VarCharReader, VarDecimalReader, UntypedReader

public class SingleDictReaderImpl
extends AbstractRepeatedMapReaderImpl<DictVector>
implements BaseReader.DictReader

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.vector.complex.reader.BaseReader

BaseReader.ComplexReader, BaseReader.DictReader, BaseReader.ListReader, BaseReader.MapReader, BaseReader.RepeatedListReader, BaseReader.RepeatedMapReader, BaseReader.ScalarReader

Field Summary

Fields

Modifier and Type	Field	Description
static final int	NOT_FOUND

Fields inherited from class org.apache.drill.exec.vector.complex.impl.AbstractRepeatedMapReaderImpl

currentOffset, fields, maxOffset, NO_VALUES, vector

Constructor Summary

Constructors

Constructor	Description
SingleDictReaderImpl(DictVector vector)

Method Summary

Modifier and Type	Method	Description
void	copyAsValue(UnionWriter writer)
void	copyAsValue(BaseWriter.DictWriter writer)
void	copyAsValue(BaseWriter.ListWriter writer)
int	find(int key)	Obtain the index for given key in current row used to find a corresponding value with.
int	find(Object key)	Obtain the index for given key in current row used to find a corresponding value with.
int	find(String key)	Obtain the index for given key in current row used to find a corresponding value with.
MaterializedField	getField()
String	getTypeString()	Returns String representation of the reader's type.
TypeProtos.MinorType	getVectorType()	Returns the type of the vector, not value.
void	read(int index, UnionHolder holder)
void	read(int key, ValueHolder holder)	Reads a value corresponding to a key into the holder.
void	read(Object key, ValueHolder holder)	Reads a value corresponding to a key into the holder.
void	read(String key, ValueHolder holder)	Reads a value corresponding to a key into the holder.
void	read(UnionHolder holder)
void	read(UntypedNullHolder holder)
FieldReader	reader(String name)
void	setPosition(int index)

Methods inherited from class org.apache.drill.exec.vector.complex.impl.AbstractRepeatedMapReaderImpl

getType, isEmpty, isSet, iterator, next, readObject, reset, size

Methods inherited from class org.apache.drill.exec.vector.complex.impl.AbstractFieldReader

copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsField, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, copyAsValue, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, read, readBigDecimal, readBigDecimal, readBoolean, readBoolean, readByte, readByte, readByteArray, readByteArray, readCharacter, readCharacter, readDouble, readDouble, reader, readFloat, readFloat, readInteger, readInteger, readLocalDate, readLocalDate, readLocalDateTime, readLocalDateTime, readLocalTime, readLocalTime, readLong, readLong, readObject, readPeriod, readPeriod, readShort, readShort, readString, readString, readText, readText

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.vector.complex.reader.BaseReader

copyAsValue, getField, getType, read, read, read, reset

Methods inherited from interface org.apache.drill.exec.vector.complex.reader.BaseReader.RepeatedMapReader

copyAsValue, next, size

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Methods inherited from interface org.apache.drill.exec.vector.UntypedReader

read

Field Details

NOT_FOUND

public static final int NOT_FOUND

See Also:

• Constant Field Values

Constructor Details

SingleDictReaderImpl

public SingleDictReaderImpl(DictVector vector)

Method Details

reader

public FieldReader reader(String name)

Specified by:

reader in interface BaseReader.MapReader

Overrides:

reader in class AbstractRepeatedMapReaderImpl<DictVector>

find

public int find(String key)

Description copied from interface: BaseReader.DictReader

Obtain the index for given key in current row used to find a corresponding value with. Used in generated code when retrieving value from Dict with PathSegment.NameSegment in cases when DictVector.getValueType() is complex.

Despite key is passed as String the value is converted to actual type based on DictVector.getKeyType().

Specified by:

find in interface BaseReader.DictReader

Overrides:

find in class AbstractFieldReader

Parameters:

key - literal representing key value

Returns:

index for the given key

See Also:

• DictVector

find

public int find(int key)

Description copied from interface: BaseReader.DictReader

Obtain the index for given key in current row used to find a corresponding value with. Used in generated code when retrieving value from Dict with PathSegment.ArraySegment in cases when DictVector.getValueType() is complex.

Despite key is passed as int the value is converted to actual type based on DictVector.getKeyType().

Specified by:

find in interface BaseReader.DictReader

Overrides:

find in class AbstractFieldReader

Parameters:

key - literal representing key value

Returns:

index for the given key

See Also:

• DictVector

find

public int find(Object key)

Description copied from interface: BaseReader.DictReader

Obtain the index for given key in current row used to find a corresponding value with. Used in generated code when retrieving value from Dict using PathSegment with provided PathSegment.getOriginalValue() in cases when DictVector.getValueType() is complex.

The key is assumed to be of actual type, is not converted and used as is.

Specified by:

find in interface BaseReader.DictReader

Overrides:

find in class AbstractFieldReader

Parameters:

key - key value

Returns:

index for the given key

See Also:

• DictVector

read

public void read(String key,
 ValueHolder holder)

Description copied from interface: BaseReader.DictReader

Reads a value corresponding to a key into the holder. If there is no entry in the row with the given key, value is set to null.

Used in generated code when retrieving value from Dict with PathSegment.NameSegment in cases when DictVector.getValueType() is primitive.

Despite key is passed as String the value is converted to actual type based on DictVector.getKeyType().

Specified by:

read in interface BaseReader.DictReader

Overrides:

read in class AbstractFieldReader

Parameters:

key - literal representing key value

holder - a holder to write value's value into

See Also:

• DictVector

read

public void read(int key,
 ValueHolder holder)

Description copied from interface: BaseReader.DictReader

Reads a value corresponding to a key into the holder. If there is no entry in the row with the given key, value is set to null.

Used in generated code when retrieving value from Dict with PathSegment.ArraySegment in cases when DictVector.getValueType() is primitive.

Despite key is passed as int the value is converted to actual type based on DictVector.getKeyType().

Specified by:

read in interface BaseReader.DictReader

Overrides:

read in class AbstractFieldReader

Parameters:

key - literal representing key value

holder - a holder to write value's value into

See Also:

• DictVector

read

public void read(Object key,
 ValueHolder holder)

Description copied from interface: BaseReader.DictReader

Reads a value corresponding to a key into the holder. If there is no entry in the row with the given key, value is set to null.

Used in generated code when retrieving value from Dict using PathSegment with provided PathSegment.getOriginalValue() in cases when DictVector.getValueType() is primitive.

The key is assumed to be of actual type, is not converted and used as is.

Specified by:

read in interface BaseReader.DictReader

Overrides:

read in class AbstractFieldReader

Parameters:

key - key value

holder - a holder to write value's value into

See Also:

• DictVector

setPosition

public void setPosition(int index)

Specified by:

setPosition in interface Positionable

Overrides:

setPosition in class AbstractRepeatedMapReaderImpl<DictVector>

copyAsValue

public void copyAsValue(BaseWriter.DictWriter writer)

Specified by:

copyAsValue in interface BaseReader.DictReader

Overrides:

copyAsValue in class AbstractFieldReader

copyAsValue

public void copyAsValue(BaseWriter.ListWriter writer)

Specified by:

copyAsValue in interface BaseReader.RepeatedListReader

getTypeString

public String getTypeString()

Description copied from interface: BaseReader

Returns String representation of the reader's type. In case if BaseReader.getType() is primitive, the method is equivalent to

invalid @link

{@link #getType().getMinorType().name()

}. If the reader has minor type equal to TypeProtos.MinorType.DICT, DICT<keyMinorType,valueMinorType>, with keyMinorType and valueMinorType being key's and value's minor types respectively, will be returned. Used in typeOf UDF.

Specified by:

getTypeString in interface BaseReader

Returns:

String representation of reader's type.

getVectorType

public TypeProtos.MinorType getVectorType()

Description copied from interface: BaseReader

Returns the type of the vector, not value. For all vectors, this is the same as the vector's getField().getType().getMinorType(). It is used to report the actual vector type in the getDrillType() function.

Specified by:

getVectorType in interface BaseReader

Overrides:

getVectorType in class AbstractFieldReader

getField

public MaterializedField getField()

Specified by:

getField in interface BaseReader

read

public void read(UnionHolder holder)

Specified by:

read in interface BaseReader

read

public void read(int index,
 UnionHolder holder)

Specified by:

read in interface BaseReader

read

public void read(UntypedNullHolder holder)

Specified by:

read in interface UntypedReader

copyAsValue

public void copyAsValue(UnionWriter writer)

Specified by:

copyAsValue in interface BaseReader