Class UnionVectorWriter
java.lang.Object
org.apache.drill.exec.vector.complex.impl.UnionVectorWriter
- All Implemented Interfaces:
AutoCloseable,Positionable,BaseWriter,BaseWriter.DictWriter,BaseWriter.ListWriter,BaseWriter.MapWriter,BaseWriter.ScalarWriter,BigIntWriter,BitWriter,DateWriter,Decimal18Writer,Decimal28DenseWriter,Decimal28SparseWriter,Decimal38DenseWriter,Decimal38SparseWriter,Decimal9Writer,FieldWriter,Float4Writer,Float8Writer,IntervalDayWriter,IntervalWriter,IntervalYearWriter,IntWriter,SmallIntWriter,TimeStampWriter,TimeWriter,TinyIntWriter,UInt1Writer,UInt2Writer,UInt4Writer,UInt8Writer,Var16CharWriter,VarBinaryWriter,VarCharWriter,VarDecimalWriter
- Direct Known Subclasses:
UnionVectorListWriter
ListWriter-like writer with only difference that it acts only as a factory
for concrete type writers for UnionVector data vector.
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.drill.exec.vector.complex.writer.BaseWriter
BaseWriter.ComplexWriter, BaseWriter.DictWriter, BaseWriter.ListWriter, BaseWriter.MapOrListWriter, BaseWriter.MapWriter, BaseWriter.ScalarWriter -
Constructor Summary
ConstructorsConstructorDescriptionUnionVectorWriter(UnionVector vector, FieldWriter parent) Constructs writer with dataVector of UnionVector type. -
Method Summary
Modifier and TypeMethodDescriptionvoidallocate()bigInt()Get concrete writer for writing bigint data todataVector.bit()Get concrete writer for writing bit data todataVector.voidclear()voidclose()voidcopyReader(FieldReader reader) voidcopyReaderToField(String name, FieldReader reader) date()Get concrete writer for writing date data todataVector.decimal18(int precision, int scale) decimal28Dense(int precision, int scale) decimal28Dense(String name) decimal28Dense(String name, int precision, int scale) decimal28Sparse(int precision, int scale) decimal28Sparse(String name) decimal28Sparse(String name, int precision, int scale) decimal38Dense(int precision, int scale) decimal38Dense(String name) decimal38Dense(String name, int precision, int scale) decimal38Sparse(int precision, int scale) decimal38Sparse(String name) decimal38Sparse(String name, int precision, int scale) decimal9()decimal9(int precision, int scale) dict()voidend()voidFinalizes writing values to key and value writers.voidendList()float4()Get concrete writer for writing float4 data todataVector.float8()Get concrete writer for writing float8 data todataVector.getField()intinteger()Get concrete writer for writing int data todataVector.interval()Get concrete writer for writing interval data todataVector.Get concrete writer for writing intervalday data todataVector.intervalDay(String name) Get concrete writer for writing intervalyear data todataVector.intervalYear(String name) booleanThis implementation returnsfalse.booleanisRoot()list()map()voidsetPosition(int index) smallInt()Get concrete writer for writing smallint data todataVector.voidstart()voidPrepares key and value writers to write new values.voidtime()Get concrete writer for writing time data todataVector.Get concrete writer for writing timestamp data todataVector.tinyInt()Get concrete writer for writing tinyint data todataVector.toString()uInt1()Get concrete writer for writing uint1 data todataVector.uInt2()Get concrete writer for writing uint2 data todataVector.uInt4()Get concrete writer for writing uint4 data todataVector.uInt8()Get concrete writer for writing uint8 data todataVector.union()Get concrete writer for writing var16char data todataVector.Get concrete writer for writing varbinary data todataVector.varChar()Get concrete writer for writing varchar data todataVector.Get concrete writer for writing vardecimal data todataVector.varDecimal(int precision, int scale) varDecimal(String name) varDecimal(String name, int precision, int scale) voidwrite(BigIntHolder holder) voidvoidwrite(DateHolder holder) voidwrite(Decimal18Holder holder) voidwrite(Decimal28DenseHolder holder) voidwrite(Decimal28SparseHolder holder) voidwrite(Decimal38DenseHolder holder) voidwrite(Decimal38SparseHolder holder) voidwrite(Decimal9Holder holder) voidwrite(Float4Holder holder) voidwrite(Float8Holder holder) voidwrite(IntervalDayHolder holder) voidwrite(IntervalHolder holder) voidwrite(IntervalYearHolder holder) voidvoidwrite(SmallIntHolder holder) voidwrite(TimeHolder holder) voidwrite(TimeStampHolder holder) voidwrite(TinyIntHolder holder) voidwrite(UInt1Holder holder) voidwrite(UInt2Holder holder) voidwrite(UInt4Holder holder) voidwrite(UInt8Holder holder) voidwrite(Var16CharHolder holder) voidwrite(VarBinaryHolder holder) voidwrite(VarCharHolder holder) voidwrite(VarDecimalHolder holder) voidwriteBigInt(long value) voidwriteBit(int value) voidwriteDate(long value) voidwriteDecimal18(long value, int precision, int scale) voidwriteDecimal18(BigDecimal value) voidwriteDecimal28Dense(int start, DrillBuf buffer, int precision, int scale) voidwriteDecimal28Dense(BigDecimal value) voidwriteDecimal28Sparse(int start, DrillBuf buffer, int precision, int scale) voidwriteDecimal28Sparse(BigDecimal value) voidwriteDecimal38Dense(int start, DrillBuf buffer, int precision, int scale) voidwriteDecimal38Dense(BigDecimal value) voidwriteDecimal38Sparse(int start, DrillBuf buffer, int precision, int scale) voidwriteDecimal38Sparse(BigDecimal value) voidwriteDecimal9(int value, int precision, int scale) voidwriteDecimal9(BigDecimal value) voidwriteFloat4(float value) voidwriteFloat8(double value) voidwriteInt(int value) voidwriteInterval(int months, int days, int milliseconds) voidwriteIntervalDay(int days, int milliseconds) voidwriteIntervalYear(int value) voidvoidwriteSmallInt(short value) voidwriteTime(int value) voidwriteTimeStamp(long value) voidwriteTinyInt(byte value) voidwriteUInt1(byte value) voidwriteUInt2(char value) voidwriteUInt4(int value) voidwriteUInt8(long value) voidwriteVar16Char(int start, int end, DrillBuf buffer) voidwriteVarBinary(int start, int end, DrillBuf buffer) voidwriteVarChar(int start, int end, DrillBuf buffer) voidwriteVarDecimal(int start, int end, DrillBuf buffer, int precision, int scale) voidwriteVarDecimal(BigDecimal value) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.apache.drill.exec.vector.complex.writer.BaseWriter
getParentMethods inherited from interface org.apache.drill.exec.vector.complex.Positionable
setPosition
-
Constructor Details
-
UnionVectorWriter
Constructs writer with dataVector of UnionVector type.- Parameters:
vector- union data vectorparent- parent writer
-
-
Method Details
-
union
- Specified by:
unionin interfaceBaseWriter.ListWriter
-
map
- Specified by:
mapin interfaceBaseWriter.ListWriter
-
dict
- Specified by:
dictin interfaceBaseWriter.ListWriter
-
list
- Specified by:
listin interfaceBaseWriter.ListWriter
-
tinyInt
Get concrete writer for writing tinyint data todataVector.- Specified by:
tinyIntin interfaceBaseWriter.ListWriter- Returns:
- tinyint writer
-
uInt1
Get concrete writer for writing uint1 data todataVector.- Specified by:
uInt1in interfaceBaseWriter.ListWriter- Returns:
- uint1 writer
-
uInt2
Get concrete writer for writing uint2 data todataVector.- Specified by:
uInt2in interfaceBaseWriter.ListWriter- Returns:
- uint2 writer
-
smallInt
Get concrete writer for writing smallint data todataVector.- Specified by:
smallIntin interfaceBaseWriter.ListWriter- Returns:
- smallint writer
-
integer
Get concrete writer for writing int data todataVector.- Specified by:
integerin interfaceBaseWriter.ListWriter- Returns:
- int writer
-
uInt4
Get concrete writer for writing uint4 data todataVector.- Specified by:
uInt4in interfaceBaseWriter.ListWriter- Returns:
- uint4 writer
-
float4
Get concrete writer for writing float4 data todataVector.- Specified by:
float4in interfaceBaseWriter.ListWriter- Returns:
- float4 writer
-
time
Get concrete writer for writing time data todataVector.- Specified by:
timein interfaceBaseWriter.ListWriter- Returns:
- time writer
-
intervalYear
Get concrete writer for writing intervalyear data todataVector.- Specified by:
intervalYearin interfaceBaseWriter.ListWriter- Returns:
- intervalyear writer
-
bigInt
Get concrete writer for writing bigint data todataVector.- Specified by:
bigIntin interfaceBaseWriter.ListWriter- Returns:
- bigint writer
-
uInt8
Get concrete writer for writing uint8 data todataVector.- Specified by:
uInt8in interfaceBaseWriter.ListWriter- Returns:
- uint8 writer
-
float8
Get concrete writer for writing float8 data todataVector.- Specified by:
float8in interfaceBaseWriter.ListWriter- Returns:
- float8 writer
-
date
Get concrete writer for writing date data todataVector.- Specified by:
datein interfaceBaseWriter.ListWriter- Returns:
- date writer
-
timeStamp
Get concrete writer for writing timestamp data todataVector.- Specified by:
timeStampin interfaceBaseWriter.ListWriter- Returns:
- timestamp writer
-
intervalDay
Get concrete writer for writing intervalday data todataVector.- Specified by:
intervalDayin interfaceBaseWriter.ListWriter- Returns:
- intervalday writer
-
interval
Get concrete writer for writing interval data todataVector.- Specified by:
intervalin interfaceBaseWriter.ListWriter- Returns:
- interval writer
-
varBinary
Get concrete writer for writing varbinary data todataVector.- Specified by:
varBinaryin interfaceBaseWriter.ListWriter- Returns:
- varbinary writer
-
varChar
Get concrete writer for writing varchar data todataVector.- Specified by:
varCharin interfaceBaseWriter.ListWriter- Returns:
- varchar writer
-
var16Char
Get concrete writer for writing var16char data todataVector.- Specified by:
var16Charin interfaceBaseWriter.ListWriter- Returns:
- var16char writer
-
varDecimal
Get concrete writer for writing vardecimal data todataVector.- Specified by:
varDecimalin interfaceBaseWriter.ListWriter- Returns:
- vardecimal writer
-
varDecimal
- Specified by:
varDecimalin interfaceBaseWriter.ListWriter
-
bit
Get concrete writer for writing bit data todataVector.- Specified by:
bitin interfaceBaseWriter.ListWriter- Returns:
- bit writer
-
allocate
public void allocate() -
clear
public void clear() -
getValueCapacity
public int getValueCapacity() -
getField
-
close
- Throws:
Exception
-
writeNull
public void writeNull() -
start
public void start()- Specified by:
startin interfaceBaseWriter.MapWriter
-
end
public void end()- Specified by:
endin interfaceBaseWriter.MapWriter
-
startList
public void startList()- Specified by:
startListin interfaceBaseWriter.ListWriter
-
endList
public void endList()- Specified by:
endListin interfaceBaseWriter.ListWriter
-
write
- Specified by:
writein interfaceTinyIntWriter
-
writeTinyInt
public void writeTinyInt(byte value) - Specified by:
writeTinyIntin interfaceTinyIntWriter
-
write
- Specified by:
writein interfaceUInt1Writer
-
writeUInt1
public void writeUInt1(byte value) - Specified by:
writeUInt1in interfaceUInt1Writer
-
write
- Specified by:
writein interfaceUInt2Writer
-
writeUInt2
public void writeUInt2(char value) - Specified by:
writeUInt2in interfaceUInt2Writer
-
write
- Specified by:
writein interfaceSmallIntWriter
-
writeSmallInt
public void writeSmallInt(short value) - Specified by:
writeSmallIntin interfaceSmallIntWriter
-
write
-
writeInt
public void writeInt(int value) -
write
- Specified by:
writein interfaceUInt4Writer
-
writeUInt4
public void writeUInt4(int value) - Specified by:
writeUInt4in interfaceUInt4Writer
-
write
- Specified by:
writein interfaceFloat4Writer
-
writeFloat4
public void writeFloat4(float value) - Specified by:
writeFloat4in interfaceFloat4Writer
-
write
- Specified by:
writein interfaceTimeWriter
-
writeTime
public void writeTime(int value) - Specified by:
writeTimein interfaceTimeWriter
-
write
- Specified by:
writein interfaceIntervalYearWriter
-
writeIntervalYear
public void writeIntervalYear(int value) - Specified by:
writeIntervalYearin interfaceIntervalYearWriter
-
write
- Specified by:
writein interfaceDecimal9Writer
-
writeDecimal9
public void writeDecimal9(int value, int precision, int scale) -
writeDecimal9
-
write
- Specified by:
writein interfaceBigIntWriter
-
writeBigInt
public void writeBigInt(long value) - Specified by:
writeBigIntin interfaceBigIntWriter
-
write
- Specified by:
writein interfaceUInt8Writer
-
writeUInt8
public void writeUInt8(long value) - Specified by:
writeUInt8in interfaceUInt8Writer
-
write
- Specified by:
writein interfaceFloat8Writer
-
writeFloat8
public void writeFloat8(double value) - Specified by:
writeFloat8in interfaceFloat8Writer
-
write
- Specified by:
writein interfaceDateWriter
-
writeDate
public void writeDate(long value) - Specified by:
writeDatein interfaceDateWriter
-
write
- Specified by:
writein interfaceTimeStampWriter
-
writeTimeStamp
public void writeTimeStamp(long value) - Specified by:
writeTimeStampin interfaceTimeStampWriter
-
write
- Specified by:
writein interfaceDecimal18Writer
-
writeDecimal18
public void writeDecimal18(long value, int precision, int scale) -
writeDecimal18
-
write
- Specified by:
writein interfaceIntervalDayWriter
-
writeIntervalDay
public void writeIntervalDay(int days, int milliseconds) - Specified by:
writeIntervalDayin interfaceIntervalDayWriter
-
write
- Specified by:
writein interfaceIntervalWriter
-
writeInterval
public void writeInterval(int months, int days, int milliseconds) - Specified by:
writeIntervalin interfaceIntervalWriter
-
write
- Specified by:
writein interfaceDecimal28DenseWriter
-
writeDecimal28Dense
- Specified by:
writeDecimal28Densein interfaceDecimal28DenseWriter
-
writeDecimal28Dense
-
write
- Specified by:
writein interfaceDecimal38DenseWriter
-
writeDecimal38Dense
- Specified by:
writeDecimal38Densein interfaceDecimal38DenseWriter
-
writeDecimal38Dense
-
write
- Specified by:
writein interfaceDecimal38SparseWriter
-
writeDecimal38Sparse
- Specified by:
writeDecimal38Sparsein interfaceDecimal38SparseWriter
-
writeDecimal38Sparse
-
write
- Specified by:
writein interfaceDecimal28SparseWriter
-
writeDecimal28Sparse
- Specified by:
writeDecimal28Sparsein interfaceDecimal28SparseWriter
-
writeDecimal28Sparse
-
write
- Specified by:
writein interfaceVarBinaryWriter
-
writeVarBinary
- Specified by:
writeVarBinaryin interfaceVarBinaryWriter
-
write
- Specified by:
writein interfaceVarCharWriter
-
writeVarChar
- Specified by:
writeVarCharin interfaceVarCharWriter
-
write
- Specified by:
writein interfaceVar16CharWriter
-
writeVar16Char
- Specified by:
writeVar16Charin interfaceVar16CharWriter
-
write
- Specified by:
writein interfaceVarDecimalWriter
-
writeVarDecimal
- Specified by:
writeVarDecimalin interfaceVarDecimalWriter
-
writeVarDecimal
- Specified by:
writeVarDecimalin interfaceVarDecimalWriter
-
write
-
writeBit
public void writeBit(int value) -
isEmptyMap
public boolean isEmptyMap()This implementation returnsfalse.Must be overridden by map writers.
- Specified by:
isEmptyMapin interfaceBaseWriter.MapWriter
-
map
- Specified by:
mapin interfaceBaseWriter.MapWriter
-
dict
- Specified by:
dictin interfaceBaseWriter.MapWriter
-
getKeyWriter
- Specified by:
getKeyWriterin interfaceBaseWriter.DictWriter
-
getValueWriter
- Specified by:
getValueWriterin interfaceBaseWriter.DictWriter
-
startKeyValuePair
public void startKeyValuePair()Description copied from interface:BaseWriter.DictWriterPrepares key and value writers to write new values. Must be invoked before writing data to these fields.- Specified by:
startKeyValuePairin interfaceBaseWriter.DictWriter
-
endKeyValuePair
public void endKeyValuePair()Description copied from interface:BaseWriter.DictWriterFinalizes writing values to key and value writers. Must be invoked after the values for the fields are written.- Specified by:
endKeyValuePairin interfaceBaseWriter.DictWriter
-
list
- Specified by:
listin interfaceBaseWriter.MapWriter
-
union
- Specified by:
unionin interfaceBaseWriter.MapWriter
-
tinyInt
- Specified by:
tinyIntin interfaceBaseWriter.MapWriter
-
uInt1
- Specified by:
uInt1in interfaceBaseWriter.MapWriter
-
uInt2
- Specified by:
uInt2in interfaceBaseWriter.MapWriter
-
smallInt
- Specified by:
smallIntin interfaceBaseWriter.MapWriter
-
integer
- Specified by:
integerin interfaceBaseWriter.MapWriter
-
uInt4
- Specified by:
uInt4in interfaceBaseWriter.MapWriter
-
float4
- Specified by:
float4in interfaceBaseWriter.MapWriter
-
time
- Specified by:
timein interfaceBaseWriter.MapWriter
-
intervalYear
- Specified by:
intervalYearin interfaceBaseWriter.MapWriter
-
decimal9
- Specified by:
decimal9in interfaceBaseWriter.MapWriter
-
decimal9
- Specified by:
decimal9in interfaceBaseWriter.ListWriter
-
decimal9
- Specified by:
decimal9in interfaceBaseWriter.MapWriter
-
decimal9
- Specified by:
decimal9in interfaceBaseWriter.ListWriter
-
bigInt
- Specified by:
bigIntin interfaceBaseWriter.MapWriter
-
uInt8
- Specified by:
uInt8in interfaceBaseWriter.MapWriter
-
float8
- Specified by:
float8in interfaceBaseWriter.MapWriter
-
date
- Specified by:
datein interfaceBaseWriter.MapWriter
-
timeStamp
- Specified by:
timeStampin interfaceBaseWriter.MapWriter
-
decimal18
- Specified by:
decimal18in interfaceBaseWriter.MapWriter
-
decimal18
- Specified by:
decimal18in interfaceBaseWriter.ListWriter
-
decimal18
- Specified by:
decimal18in interfaceBaseWriter.MapWriter
-
decimal18
- Specified by:
decimal18in interfaceBaseWriter.ListWriter
-
intervalDay
- Specified by:
intervalDayin interfaceBaseWriter.MapWriter
-
interval
- Specified by:
intervalin interfaceBaseWriter.MapWriter
-
decimal28Dense
- Specified by:
decimal28Densein interfaceBaseWriter.MapWriter
-
decimal28Dense
- Specified by:
decimal28Densein interfaceBaseWriter.ListWriter
-
decimal28Dense
- Specified by:
decimal28Densein interfaceBaseWriter.MapWriter
-
decimal28Dense
- Specified by:
decimal28Densein interfaceBaseWriter.ListWriter
-
decimal38Dense
- Specified by:
decimal38Densein interfaceBaseWriter.MapWriter
-
decimal38Dense
- Specified by:
decimal38Densein interfaceBaseWriter.ListWriter
-
decimal38Dense
- Specified by:
decimal38Densein interfaceBaseWriter.MapWriter
-
decimal38Dense
- Specified by:
decimal38Densein interfaceBaseWriter.ListWriter
-
decimal38Sparse
- Specified by:
decimal38Sparsein interfaceBaseWriter.MapWriter
-
decimal38Sparse
- Specified by:
decimal38Sparsein interfaceBaseWriter.ListWriter
-
decimal38Sparse
- Specified by:
decimal38Sparsein interfaceBaseWriter.MapWriter
-
decimal38Sparse
- Specified by:
decimal38Sparsein interfaceBaseWriter.ListWriter
-
decimal28Sparse
- Specified by:
decimal28Sparsein interfaceBaseWriter.MapWriter
-
decimal28Sparse
- Specified by:
decimal28Sparsein interfaceBaseWriter.ListWriter
-
decimal28Sparse
- Specified by:
decimal28Sparsein interfaceBaseWriter.MapWriter
-
decimal28Sparse
- Specified by:
decimal28Sparsein interfaceBaseWriter.ListWriter
-
varBinary
- Specified by:
varBinaryin interfaceBaseWriter.MapWriter
-
varChar
- Specified by:
varCharin interfaceBaseWriter.MapWriter
-
var16Char
- Specified by:
var16Charin interfaceBaseWriter.MapWriter
-
varDecimal
- Specified by:
varDecimalin interfaceBaseWriter.MapWriter
-
varDecimal
- Specified by:
varDecimalin interfaceBaseWriter.MapWriter
-
bit
- Specified by:
bitin interfaceBaseWriter.MapWriter
-
copyReader
- Specified by:
copyReaderin interfaceBaseWriter.ListWriter
-
copyReaderToField
- Specified by:
copyReaderToFieldin interfaceBaseWriter.MapWriter
-
toString
-
getParent
- Specified by:
getParentin interfaceBaseWriter
-
isRoot
public boolean isRoot() -
setPosition
public void setPosition(int index) - Specified by:
setPositionin interfacePositionable
-