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

Class RepeatedMapReaderImpl

java.lang.Object

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

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

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

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 RepeatedMapReaderImpl
extends AbstractRepeatedMapReaderImpl<RepeatedMapVector>

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 inherited from class org.apache.drill.exec.vector.complex.impl.AbstractRepeatedMapReaderImpl

currentOffset, fields, maxOffset, NO_VALUES, vector

Constructor Summary

Constructors

Constructor	Description
RepeatedMapReaderImpl(RepeatedMapVector vector)

Method Summary

Modifier and Type	Method	Description
void	copyAsField(String name, BaseWriter.MapWriter writer)
void	copyAsValue(UnionWriter writer)
void	copyAsValue(BaseWriter.ListWriter writer)
void	copyAsValue(BaseWriter.MapWriter writer)
void	copyAsValueSingle(BaseWriter.MapWriter writer)
MaterializedField	getField()
String	getTypeString()	Returns String representation of the reader's type.
void	read(int index, UnionHolder holder)
void	read(UnionHolder holder)
void	read(UntypedNullHolder holder)
FieldReader	reader()
void	setSinglePosition(int index, int childIndex)

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

getType, isEmpty, isSet, iterator, next, reader, readObject, reset, setPosition, 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, 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, find, find, find, getVectorType, 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, read, read, read, readBigDecimal, readBigDecimal, readBoolean, readBoolean, readByte, readByte, readByteArray, readByteArray, readCharacter, readCharacter, readDouble, readDouble, 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, getTypeString, read, read

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

copyAsValue

Methods inherited from interface java.lang.Iterable

forEach, spliterator

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

read

Constructor Details

RepeatedMapReaderImpl

public RepeatedMapReaderImpl(RepeatedMapVector vector)

Method Details

reader

public FieldReader reader()

Specified by:

reader in interface BaseReader.ListReader

Overrides:

reader in class AbstractFieldReader

setSinglePosition

public void setSinglePosition(int index,
 int childIndex)

getField

public MaterializedField getField()

Specified by:

getField in interface BaseReader

copyAsValue

public void copyAsValue(BaseWriter.MapWriter writer)

Specified by:

copyAsValue in interface BaseReader.RepeatedMapReader

Overrides:

copyAsValue in class AbstractFieldReader

copyAsValueSingle

public void copyAsValueSingle(BaseWriter.MapWriter writer)

copyAsField

public void copyAsField(String name,
 BaseWriter.MapWriter writer)

Overrides:

copyAsField in class AbstractFieldReader

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

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.