Class UnionReader
java.lang.Object
org.apache.drill.exec.vector.complex.impl.AbstractFieldReader
org.apache.drill.exec.vector.complex.impl.UnionReader
- 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
-
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 -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidcopyAsValue(UnionWriter writer) voidcopyAsValue(BaseWriter.ListWriter writer) voidcopyAsValue(BigIntWriter writer) voidcopyAsValue(BitWriter writer) voidcopyAsValue(DateWriter writer) voidcopyAsValue(Float4Writer writer) voidcopyAsValue(Float8Writer writer) voidcopyAsValue(IntervalDayWriter writer) voidcopyAsValue(IntervalWriter writer) voidcopyAsValue(IntervalYearWriter writer) voidcopyAsValue(IntWriter writer) voidcopyAsValue(SmallIntWriter writer) voidcopyAsValue(TimeStampWriter writer) voidcopyAsValue(TimeWriter writer) voidcopyAsValue(TinyIntWriter writer) voidcopyAsValue(UInt1Writer writer) voidcopyAsValue(UInt2Writer writer) voidcopyAsValue(UInt4Writer writer) voidcopyAsValue(UInt8Writer writer) voidcopyAsValue(Var16CharWriter writer) voidcopyAsValue(VarBinaryWriter writer) voidcopyAsValue(VarCharWriter writer) voidcopyAsValue(VarDecimalWriter writer) getField()getType()ReturnsStringrepresentation of the reader's type.Returns the type of the vector, not value.booleanisSet()Returns true if the current value of the reader is not nulliterator()booleannext()voidread(int index, UnionHolder holder) voidread(NullableBigIntHolder holder) voidread(NullableBitHolder holder) voidread(NullableDateHolder holder) voidread(NullableFloat4Holder holder) voidread(NullableFloat8Holder holder) voidread(NullableIntervalDayHolder holder) voidread(NullableIntervalHolder holder) voidread(NullableIntervalYearHolder holder) voidread(NullableIntHolder holder) voidread(NullableSmallIntHolder holder) voidread(NullableTimeHolder holder) voidread(NullableTimeStampHolder holder) voidread(NullableTinyIntHolder holder) voidread(NullableUInt1Holder holder) voidread(NullableUInt2Holder holder) voidread(NullableUInt4Holder holder) voidread(NullableUInt8Holder holder) voidread(NullableVar16CharHolder holder) voidread(NullableVarBinaryHolder holder) voidread(NullableVarCharHolder holder) voidread(NullableVarDecimalHolder holder) voidread(UnionHolder holder) voidread(UntypedNullHolder holder) readByte()byte[]reader()readLong()org.joda.time.PeriodreadText()voidreset()voidsetPosition(int index) 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, find, find, find, 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, readBoolean, readByte, readByteArray, readCharacter, readDouble, readFloat, readInteger, readLocalDate, readLocalDateTime, readLocalTime, readLong, readObject, readPeriod, readShort, readString, readText, sizeMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.drill.exec.vector.complex.reader.BaseReader
getField, resetMethods inherited from interface java.lang.Iterable
forEach, spliteratorMethods inherited from interface org.apache.drill.exec.vector.UntypedReader
read
-
Field Details
-
data
-
-
Constructor Details
-
UnionReader
-
-
Method Details
-
getType
- Specified by:
getTypein interfaceBaseReader
-
getVectorType
Description copied from interface:BaseReaderReturns 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:
getVectorTypein interfaceBaseReader- Overrides:
getVectorTypein classAbstractFieldReader
-
isSet
public boolean isSet()Description copied from class:AbstractFieldReaderReturns true if the current value of the reader is not null- Specified by:
isSetin interfaceBaseReader- Specified by:
isSetin interfaceBigIntReader- Specified by:
isSetin interfaceBitReader- Specified by:
isSetin interfaceDateReader- Specified by:
isSetin interfaceDecimal18Reader- Specified by:
isSetin interfaceDecimal28DenseReader- Specified by:
isSetin interfaceDecimal28SparseReader- Specified by:
isSetin interfaceDecimal38DenseReader- Specified by:
isSetin interfaceDecimal38SparseReader- Specified by:
isSetin interfaceDecimal9Reader- Specified by:
isSetin interfaceFloat4Reader- Specified by:
isSetin interfaceFloat8Reader- Specified by:
isSetin interfaceIntervalDayReader- Specified by:
isSetin interfaceIntervalReader- Specified by:
isSetin interfaceIntervalYearReader- Specified by:
isSetin interfaceIntReader- Specified by:
isSetin interfaceRepeatedBigIntReader- Specified by:
isSetin interfaceRepeatedBitReader- Specified by:
isSetin interfaceRepeatedDateReader- Specified by:
isSetin interfaceRepeatedDecimal18Reader- Specified by:
isSetin interfaceRepeatedDecimal28DenseReader- Specified by:
isSetin interfaceRepeatedDecimal28SparseReader- Specified by:
isSetin interfaceRepeatedDecimal38DenseReader- Specified by:
isSetin interfaceRepeatedDecimal38SparseReader- Specified by:
isSetin interfaceRepeatedDecimal9Reader- Specified by:
isSetin interfaceRepeatedFloat4Reader- Specified by:
isSetin interfaceRepeatedFloat8Reader- Specified by:
isSetin interfaceRepeatedIntervalDayReader- Specified by:
isSetin interfaceRepeatedIntervalReader- Specified by:
isSetin interfaceRepeatedIntervalYearReader- Specified by:
isSetin interfaceRepeatedIntReader- Specified by:
isSetin interfaceRepeatedSmallIntReader- Specified by:
isSetin interfaceRepeatedTimeReader- Specified by:
isSetin interfaceRepeatedTimeStampReader- Specified by:
isSetin interfaceRepeatedTinyIntReader- Specified by:
isSetin interfaceRepeatedUInt1Reader- Specified by:
isSetin interfaceRepeatedUInt2Reader- Specified by:
isSetin interfaceRepeatedUInt4Reader- Specified by:
isSetin interfaceRepeatedUInt8Reader- Specified by:
isSetin interfaceRepeatedVar16CharReader- Specified by:
isSetin interfaceRepeatedVarBinaryReader- Specified by:
isSetin interfaceRepeatedVarCharReader- Specified by:
isSetin interfaceRepeatedVarDecimalReader- Specified by:
isSetin interfaceSmallIntReader- Specified by:
isSetin interfaceTimeReader- Specified by:
isSetin interfaceTimeStampReader- Specified by:
isSetin interfaceTinyIntReader- Specified by:
isSetin interfaceUInt1Reader- Specified by:
isSetin interfaceUInt2Reader- Specified by:
isSetin interfaceUInt4Reader- Specified by:
isSetin interfaceUInt8Reader- Specified by:
isSetin interfaceUntypedReader- Specified by:
isSetin interfaceVar16CharReader- Specified by:
isSetin interfaceVarBinaryReader- Specified by:
isSetin interfaceVarCharReader- Specified by:
isSetin interfaceVarDecimalReader- Overrides:
isSetin classAbstractFieldReader- Returns:
-
read
- Specified by:
readin interfaceBaseReader
-
read
- Specified by:
readin interfaceBaseReader
-
iterator
-
copyAsValue
- Specified by:
copyAsValuein interfaceBaseReader
-
readObject
- Specified by:
readObjectin interfaceBigIntReader- Specified by:
readObjectin interfaceBitReader- Specified by:
readObjectin interfaceDateReader- Specified by:
readObjectin interfaceDecimal18Reader- Specified by:
readObjectin interfaceDecimal28DenseReader- Specified by:
readObjectin interfaceDecimal28SparseReader- Specified by:
readObjectin interfaceDecimal38DenseReader- Specified by:
readObjectin interfaceDecimal38SparseReader- Specified by:
readObjectin interfaceDecimal9Reader- Specified by:
readObjectin interfaceFloat4Reader- Specified by:
readObjectin interfaceFloat8Reader- Specified by:
readObjectin interfaceIntervalDayReader- Specified by:
readObjectin interfaceIntervalReader- Specified by:
readObjectin interfaceIntervalYearReader- Specified by:
readObjectin interfaceIntReader- Specified by:
readObjectin interfaceSmallIntReader- Specified by:
readObjectin interfaceTimeReader- Specified by:
readObjectin interfaceTimeStampReader- Specified by:
readObjectin interfaceTinyIntReader- Specified by:
readObjectin interfaceUInt1Reader- Specified by:
readObjectin interfaceUInt2Reader- Specified by:
readObjectin interfaceUInt4Reader- Specified by:
readObjectin interfaceUInt8Reader- Specified by:
readObjectin interfaceVar16CharReader- Specified by:
readObjectin interfaceVarBinaryReader- Specified by:
readObjectin interfaceVarCharReader- Specified by:
readObjectin interfaceVarDecimalReader- Overrides:
readObjectin classAbstractFieldReader
-
readBigDecimal
- Specified by:
readBigDecimalin interfaceDecimal18Reader- Specified by:
readBigDecimalin interfaceDecimal28DenseReader- Specified by:
readBigDecimalin interfaceDecimal28SparseReader- Specified by:
readBigDecimalin interfaceDecimal38DenseReader- Specified by:
readBigDecimalin interfaceDecimal38SparseReader- Specified by:
readBigDecimalin interfaceDecimal9Reader- Specified by:
readBigDecimalin interfaceVarDecimalReader- Overrides:
readBigDecimalin classAbstractFieldReader
-
readInteger
- Specified by:
readIntegerin interfaceIntReader- Specified by:
readIntegerin interfaceUInt4Reader- Overrides:
readIntegerin classAbstractFieldReader
-
readLong
- Specified by:
readLongin interfaceBigIntReader- Specified by:
readLongin interfaceUInt8Reader- Overrides:
readLongin classAbstractFieldReader
-
readBoolean
- Specified by:
readBooleanin interfaceBitReader- Overrides:
readBooleanin classAbstractFieldReader
-
readCharacter
- Specified by:
readCharacterin interfaceUInt2Reader- Overrides:
readCharacterin classAbstractFieldReader
-
readLocalDate
- Specified by:
readLocalDatein interfaceDateReader- Overrides:
readLocalDatein classAbstractFieldReader
-
readLocalTime
- Specified by:
readLocalTimein interfaceTimeReader- Overrides:
readLocalTimein classAbstractFieldReader
-
readLocalDateTime
- Specified by:
readLocalDateTimein interfaceTimeStampReader- Overrides:
readLocalDateTimein classAbstractFieldReader
-
readPeriod
public org.joda.time.Period readPeriod()- Specified by:
readPeriodin interfaceIntervalDayReader- Specified by:
readPeriodin interfaceIntervalReader- Specified by:
readPeriodin interfaceIntervalYearReader- Overrides:
readPeriodin classAbstractFieldReader
-
readDouble
- Specified by:
readDoublein interfaceFloat8Reader- Overrides:
readDoublein classAbstractFieldReader
-
readFloat
- Specified by:
readFloatin interfaceFloat4Reader- Overrides:
readFloatin classAbstractFieldReader
-
readText
- Specified by:
readTextin interfaceVarCharReader- Overrides:
readTextin classAbstractFieldReader
-
readString
- Specified by:
readStringin interfaceVar16CharReader- Overrides:
readStringin classAbstractFieldReader
-
readByte
- Specified by:
readBytein interfaceTinyIntReader- Specified by:
readBytein interfaceUInt1Reader- Overrides:
readBytein classAbstractFieldReader
-
readShort
- Specified by:
readShortin interfaceSmallIntReader- Overrides:
readShortin classAbstractFieldReader
-
readByteArray
public byte[] readByteArray()- Specified by:
readByteArrayin interfaceVarBinaryReader- Overrides:
readByteArrayin classAbstractFieldReader
-
read
- Specified by:
readin interfaceTinyIntReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedTinyIntReader- Specified by:
copyAsValuein interfaceTinyIntReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceUInt1Reader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedUInt1Reader- Specified by:
copyAsValuein interfaceUInt1Reader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceUInt2Reader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedUInt2Reader- Specified by:
copyAsValuein interfaceUInt2Reader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceSmallIntReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedSmallIntReader- Specified by:
copyAsValuein interfaceSmallIntReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceIntReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceIntReader- Specified by:
copyAsValuein interfaceRepeatedIntReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceUInt4Reader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedUInt4Reader- Specified by:
copyAsValuein interfaceUInt4Reader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceFloat4Reader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceFloat4Reader- Specified by:
copyAsValuein interfaceRepeatedFloat4Reader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceTimeReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedTimeReader- Specified by:
copyAsValuein interfaceTimeReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceIntervalYearReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceIntervalYearReader- Specified by:
copyAsValuein interfaceRepeatedIntervalYearReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceBigIntReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceBigIntReader- Specified by:
copyAsValuein interfaceRepeatedBigIntReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceUInt8Reader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedUInt8Reader- Specified by:
copyAsValuein interfaceUInt8Reader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceFloat8Reader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceFloat8Reader- Specified by:
copyAsValuein interfaceRepeatedFloat8Reader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceDateReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceDateReader- Specified by:
copyAsValuein interfaceRepeatedDateReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceTimeStampReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedTimeStampReader- Specified by:
copyAsValuein interfaceTimeStampReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceIntervalDayReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceIntervalDayReader- Specified by:
copyAsValuein interfaceRepeatedIntervalDayReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceIntervalReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceIntervalReader- Specified by:
copyAsValuein interfaceRepeatedIntervalReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceVarBinaryReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedVarBinaryReader- Specified by:
copyAsValuein interfaceVarBinaryReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceVarCharReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedVarCharReader- Specified by:
copyAsValuein interfaceVarCharReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceVar16CharReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedVar16CharReader- Specified by:
copyAsValuein interfaceVar16CharReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceVarDecimalReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceRepeatedVarDecimalReader- Specified by:
copyAsValuein interfaceVarDecimalReader- Overrides:
copyAsValuein classAbstractFieldReader
-
read
- Specified by:
readin interfaceBitReader- Overrides:
readin classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceBitReader- Specified by:
copyAsValuein interfaceRepeatedBitReader- Overrides:
copyAsValuein classAbstractFieldReader
-
copyAsValue
- Specified by:
copyAsValuein interfaceBaseReader.RepeatedListReader
-
setPosition
public void setPosition(int index) - Specified by:
setPositionin interfacePositionable
-
reader
- Specified by:
readerin interfaceBaseReader.MapReader- Overrides:
readerin classAbstractFieldReader
-
reader
- Specified by:
readerin interfaceBaseReader.ListReader- Overrides:
readerin classAbstractFieldReader
-
next
public boolean next()- Specified by:
nextin interfaceBaseReader.RepeatedListReader- Specified by:
nextin interfaceBaseReader.RepeatedMapReader
-
getTypeString
Description copied from interface:BaseReaderReturnsStringrepresentation of the reader's type. In case ifBaseReader.getType()is primitive, the method is equivalent to}. If the reader has minor type equal toinvalid @link
{@link #getType().getMinorType().name()TypeProtos.MinorType.DICT,DICT<keyMinorType,valueMinorType>, withkeyMinorTypeandvalueMinorTypebeing key's and value's minor types respectively, will be returned. Used intypeOfUDF.- Specified by:
getTypeStringin interfaceBaseReader- Returns:
Stringrepresentation of reader's type.
-
reset
public void reset()- Specified by:
resetin interfaceBaseReader
-
getField
- Specified by:
getFieldin interfaceBaseReader
-
read
- Specified by:
readin interfaceUntypedReader
-