public class UnionWriter extends Object implements FieldWriter
BaseWriter.ComplexWriter, BaseWriter.ListWriter, BaseWriter.MapWriter, BaseWriter.ScalarWriter, BaseWriter.StructOrListWriter, BaseWriter.StructWriter| Modifier and Type | Field and Description |
|---|---|
protected boolean |
addVectorAsNullable |
| Constructor and Description |
|---|
UnionWriter(UnionVector vector) |
UnionWriter(UnionVector vector,
NullableStructWriterFactory nullableStructWriterFactory) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitcopyReaderToField, isEmptyStructcopyReaderwriteBigEndianBytesToDecimal256, writeDecimal256writeBigEndianBytesToDecimal, writeDecimalgetPositionpublic UnionWriter(UnionVector vector)
public UnionWriter(UnionVector vector, NullableStructWriterFactory nullableStructWriterFactory)
public void setPosition(int index)
setPosition in interface Positionablepublic void start()
start in interface BaseWriter.StructWriterpublic void end()
end in interface BaseWriter.StructWriterpublic void startList()
startList in interface BaseWriter.ListWriterpublic void endList()
endList in interface BaseWriter.ListWriterpublic void startMap()
startMap in interface BaseWriter.MapWriterpublic void endMap()
endMap in interface BaseWriter.MapWriterpublic void startEntry()
startEntry in interface BaseWriter.MapWriterpublic BaseWriter.MapWriter key()
key in interface BaseWriter.MapWriterpublic BaseWriter.MapWriter value()
value in interface BaseWriter.MapWriterpublic void endEntry()
endEntry in interface BaseWriter.MapWriterpublic BaseWriter.StructWriter asStruct()
public BaseWriter.ListWriter asList()
public BaseWriter.MapWriter asMap(ArrowType arrowType)
public TinyIntWriter asTinyInt()
public void write(TinyIntHolder holder)
write in interface TinyIntWriterpublic void writeTinyInt(byte value)
writeTinyInt in interface TinyIntWriterpublic UInt1Writer asUInt1()
public void write(UInt1Holder holder)
write in interface UInt1Writerpublic void writeUInt1(byte value)
writeUInt1 in interface UInt1Writerpublic UInt2Writer asUInt2()
public void write(UInt2Holder holder)
write in interface UInt2Writerpublic void writeUInt2(char value)
writeUInt2 in interface UInt2Writerpublic SmallIntWriter asSmallInt()
public void write(SmallIntHolder holder)
write in interface SmallIntWriterpublic void writeSmallInt(short value)
writeSmallInt in interface SmallIntWriterpublic Float2Writer asFloat2()
public void write(Float2Holder holder)
write in interface Float2Writerpublic void writeFloat2(short value)
writeFloat2 in interface Float2Writerpublic IntWriter asInt()
public UInt4Writer asUInt4()
public void write(UInt4Holder holder)
write in interface UInt4Writerpublic void writeUInt4(int value)
writeUInt4 in interface UInt4Writerpublic Float4Writer asFloat4()
public void write(Float4Holder holder)
write in interface Float4Writerpublic void writeFloat4(float value)
writeFloat4 in interface Float4Writerpublic DateDayWriter asDateDay()
public void write(DateDayHolder holder)
write in interface DateDayWriterpublic void writeDateDay(int value)
writeDateDay in interface DateDayWriterpublic IntervalYearWriter asIntervalYear()
public void write(IntervalYearHolder holder)
write in interface IntervalYearWriterpublic void writeIntervalYear(int value)
writeIntervalYear in interface IntervalYearWriterpublic TimeSecWriter asTimeSec()
public void write(TimeSecHolder holder)
write in interface TimeSecWriterpublic void writeTimeSec(int value)
writeTimeSec in interface TimeSecWriterpublic TimeMilliWriter asTimeMilli()
public void write(TimeMilliHolder holder)
write in interface TimeMilliWriterpublic void writeTimeMilli(int value)
writeTimeMilli in interface TimeMilliWriterpublic BigIntWriter asBigInt()
public void write(BigIntHolder holder)
write in interface BigIntWriterpublic void writeBigInt(long value)
writeBigInt in interface BigIntWriterpublic UInt8Writer asUInt8()
public void write(UInt8Holder holder)
write in interface UInt8Writerpublic void writeUInt8(long value)
writeUInt8 in interface UInt8Writerpublic Float8Writer asFloat8()
public void write(Float8Holder holder)
write in interface Float8Writerpublic void writeFloat8(double value)
writeFloat8 in interface Float8Writerpublic DateMilliWriter asDateMilli()
public void write(DateMilliHolder holder)
write in interface DateMilliWriterpublic void writeDateMilli(long value)
writeDateMilli in interface DateMilliWriterpublic DurationWriter asDuration(ArrowType arrowType)
public void write(DurationHolder holder)
write in interface DurationWriterpublic void writeDuration(long value)
writeDuration in interface DurationWriterDurationWriter.write(DurationHolder)public TimeStampSecWriter asTimeStampSec()
public void write(TimeStampSecHolder holder)
write in interface TimeStampSecWriterpublic void writeTimeStampSec(long value)
writeTimeStampSec in interface TimeStampSecWriterpublic TimeStampMilliWriter asTimeStampMilli()
public void write(TimeStampMilliHolder holder)
write in interface TimeStampMilliWriterpublic void writeTimeStampMilli(long value)
writeTimeStampMilli in interface TimeStampMilliWriterpublic TimeStampMicroWriter asTimeStampMicro()
public void write(TimeStampMicroHolder holder)
write in interface TimeStampMicroWriterpublic void writeTimeStampMicro(long value)
writeTimeStampMicro in interface TimeStampMicroWriterpublic TimeStampNanoWriter asTimeStampNano()
public void write(TimeStampNanoHolder holder)
write in interface TimeStampNanoWriterpublic void writeTimeStampNano(long value)
writeTimeStampNano in interface TimeStampNanoWriterpublic TimeStampSecTZWriter asTimeStampSecTZ(ArrowType arrowType)
public void write(TimeStampSecTZHolder holder)
write in interface TimeStampSecTZWriterpublic void writeTimeStampSecTZ(long value)
writeTimeStampSecTZ in interface TimeStampSecTZWriterTimeStampSecTZWriter.write(TimeStampSecTZHolder)public TimeStampMilliTZWriter asTimeStampMilliTZ(ArrowType arrowType)
public void write(TimeStampMilliTZHolder holder)
write in interface TimeStampMilliTZWriterpublic void writeTimeStampMilliTZ(long value)
writeTimeStampMilliTZ in interface TimeStampMilliTZWriterTimeStampMilliTZWriter.write(TimeStampMilliTZHolder)public TimeStampMicroTZWriter asTimeStampMicroTZ(ArrowType arrowType)
public void write(TimeStampMicroTZHolder holder)
write in interface TimeStampMicroTZWriterpublic void writeTimeStampMicroTZ(long value)
writeTimeStampMicroTZ in interface TimeStampMicroTZWriterTimeStampMicroTZWriter.write(TimeStampMicroTZHolder)public TimeStampNanoTZWriter asTimeStampNanoTZ(ArrowType arrowType)
public void write(TimeStampNanoTZHolder holder)
write in interface TimeStampNanoTZWriterpublic void writeTimeStampNanoTZ(long value)
writeTimeStampNanoTZ in interface TimeStampNanoTZWriterTimeStampNanoTZWriter.write(TimeStampNanoTZHolder)public TimeMicroWriter asTimeMicro()
public void write(TimeMicroHolder holder)
write in interface TimeMicroWriterpublic void writeTimeMicro(long value)
writeTimeMicro in interface TimeMicroWriterpublic TimeNanoWriter asTimeNano()
public void write(TimeNanoHolder holder)
write in interface TimeNanoWriterpublic void writeTimeNano(long value)
writeTimeNano in interface TimeNanoWriterpublic IntervalDayWriter asIntervalDay()
public void write(IntervalDayHolder holder)
write in interface IntervalDayWriterpublic void writeIntervalDay(int days,
int milliseconds)
writeIntervalDay in interface IntervalDayWriterpublic IntervalMonthDayNanoWriter asIntervalMonthDayNano()
public void write(IntervalMonthDayNanoHolder holder)
write in interface IntervalMonthDayNanoWriterpublic void writeIntervalMonthDayNano(int months,
int days,
long nanoseconds)
writeIntervalMonthDayNano in interface IntervalMonthDayNanoWriterpublic Decimal256Writer asDecimal256(ArrowType arrowType)
public void write(Decimal256Holder holder)
write in interface Decimal256Writerpublic void writeDecimal256(long start,
ArrowBuf buffer,
ArrowType arrowType)
writeDecimal256 in interface Decimal256Writerpublic void writeDecimal256(BigDecimal value)
writeDecimal256 in interface Decimal256Writerpublic void writeBigEndianBytesToDecimal256(byte[] value,
ArrowType arrowType)
writeBigEndianBytesToDecimal256 in interface Decimal256Writerpublic DecimalWriter asDecimal(ArrowType arrowType)
public void write(DecimalHolder holder)
write in interface DecimalWriterpublic void writeDecimal(long start,
ArrowBuf buffer,
ArrowType arrowType)
writeDecimal in interface DecimalWriterpublic void writeDecimal(BigDecimal value)
writeDecimal in interface DecimalWriterpublic void writeBigEndianBytesToDecimal(byte[] value,
ArrowType arrowType)
writeBigEndianBytesToDecimal in interface DecimalWriterpublic FixedSizeBinaryWriter asFixedSizeBinary(ArrowType arrowType)
public void write(FixedSizeBinaryHolder holder)
write in interface FixedSizeBinaryWriterpublic void writeFixedSizeBinary(ArrowBuf buffer)
writeFixedSizeBinary in interface FixedSizeBinaryWriterFixedSizeBinaryWriter.write(FixedSizeBinaryHolder)public VarBinaryWriter asVarBinary()
public void write(VarBinaryHolder holder)
write in interface VarBinaryWriterpublic void writeVarBinary(int start,
int end,
ArrowBuf buffer)
writeVarBinary in interface VarBinaryWriterpublic void writeVarBinary(byte[] value)
writeVarBinary in interface VarBinaryWriterpublic void writeVarBinary(byte[] value,
int offset,
int length)
writeVarBinary in interface VarBinaryWriterpublic void writeVarBinary(ByteBuffer value)
writeVarBinary in interface VarBinaryWriterpublic void writeVarBinary(ByteBuffer value, int offset, int length)
writeVarBinary in interface VarBinaryWriterpublic VarCharWriter asVarChar()
public void write(VarCharHolder holder)
write in interface VarCharWriterpublic void writeVarChar(int start,
int end,
ArrowBuf buffer)
writeVarChar in interface VarCharWriterpublic void writeVarChar(Text value)
writeVarChar in interface VarCharWriterpublic void writeVarChar(String value)
writeVarChar in interface VarCharWriterpublic LargeVarCharWriter asLargeVarChar()
public void write(LargeVarCharHolder holder)
write in interface LargeVarCharWriterpublic void writeLargeVarChar(long start,
long end,
ArrowBuf buffer)
writeLargeVarChar in interface LargeVarCharWriterpublic void writeLargeVarChar(Text value)
writeLargeVarChar in interface LargeVarCharWriterpublic void writeLargeVarChar(String value)
writeLargeVarChar in interface LargeVarCharWriterpublic LargeVarBinaryWriter asLargeVarBinary()
public void write(LargeVarBinaryHolder holder)
write in interface LargeVarBinaryWriterpublic void writeLargeVarBinary(long start,
long end,
ArrowBuf buffer)
writeLargeVarBinary in interface LargeVarBinaryWriterpublic void writeLargeVarBinary(byte[] value)
writeLargeVarBinary in interface LargeVarBinaryWriterpublic void writeLargeVarBinary(byte[] value,
int offset,
int length)
writeLargeVarBinary in interface LargeVarBinaryWriterpublic void writeLargeVarBinary(ByteBuffer value)
writeLargeVarBinary in interface LargeVarBinaryWriterpublic void writeLargeVarBinary(ByteBuffer value, int offset, int length)
writeLargeVarBinary in interface LargeVarBinaryWriterpublic BitWriter asBit()
public void writeNull()
writeNull in interface BaseWriterpublic BaseWriter.StructWriter struct()
struct in interface BaseWriter.ListWriterpublic BaseWriter.ListWriter list()
list in interface BaseWriter.ListWriterpublic BaseWriter.ListWriter list(String name)
list in interface BaseWriter.StructWriterpublic BaseWriter.StructWriter struct(String name)
struct in interface BaseWriter.StructWriterpublic BaseWriter.MapWriter map()
map in interface BaseWriter.ListWriterpublic BaseWriter.MapWriter map(boolean keysSorted)
map in interface BaseWriter.ListWriterpublic BaseWriter.MapWriter map(String name)
map in interface BaseWriter.StructWriterpublic BaseWriter.MapWriter map(String name, boolean keysSorted)
map in interface BaseWriter.StructWriterpublic TinyIntWriter tinyInt(String name)
tinyInt in interface BaseWriter.StructWriterpublic TinyIntWriter tinyInt()
tinyInt in interface BaseWriter.ListWriterpublic UInt1Writer uInt1(String name)
uInt1 in interface BaseWriter.StructWriterpublic UInt1Writer uInt1()
uInt1 in interface BaseWriter.ListWriterpublic UInt2Writer uInt2(String name)
uInt2 in interface BaseWriter.StructWriterpublic UInt2Writer uInt2()
uInt2 in interface BaseWriter.ListWriterpublic SmallIntWriter smallInt(String name)
smallInt in interface BaseWriter.StructWriterpublic SmallIntWriter smallInt()
smallInt in interface BaseWriter.ListWriterpublic Float2Writer float2(String name)
float2 in interface BaseWriter.StructWriterpublic Float2Writer float2()
float2 in interface BaseWriter.ListWriterpublic IntWriter integer(String name)
integer in interface BaseWriter.StructWriterpublic IntWriter integer()
integer in interface BaseWriter.ListWriterpublic UInt4Writer uInt4(String name)
uInt4 in interface BaseWriter.StructWriterpublic UInt4Writer uInt4()
uInt4 in interface BaseWriter.ListWriterpublic Float4Writer float4(String name)
float4 in interface BaseWriter.StructWriterpublic Float4Writer float4()
float4 in interface BaseWriter.ListWriterpublic DateDayWriter dateDay(String name)
dateDay in interface BaseWriter.StructWriterpublic DateDayWriter dateDay()
dateDay in interface BaseWriter.ListWriterpublic IntervalYearWriter intervalYear(String name)
intervalYear in interface BaseWriter.StructWriterpublic IntervalYearWriter intervalYear()
intervalYear in interface BaseWriter.ListWriterpublic TimeSecWriter timeSec(String name)
timeSec in interface BaseWriter.StructWriterpublic TimeSecWriter timeSec()
timeSec in interface BaseWriter.ListWriterpublic TimeMilliWriter timeMilli(String name)
timeMilli in interface BaseWriter.StructWriterpublic TimeMilliWriter timeMilli()
timeMilli in interface BaseWriter.ListWriterpublic BigIntWriter bigInt(String name)
bigInt in interface BaseWriter.StructWriterpublic BigIntWriter bigInt()
bigInt in interface BaseWriter.ListWriterpublic UInt8Writer uInt8(String name)
uInt8 in interface BaseWriter.StructWriterpublic UInt8Writer uInt8()
uInt8 in interface BaseWriter.ListWriterpublic Float8Writer float8(String name)
float8 in interface BaseWriter.StructWriterpublic Float8Writer float8()
float8 in interface BaseWriter.ListWriterpublic DateMilliWriter dateMilli(String name)
dateMilli in interface BaseWriter.StructWriterpublic DateMilliWriter dateMilli()
dateMilli in interface BaseWriter.ListWriterpublic DurationWriter duration(String name)
duration in interface BaseWriter.StructWriterpublic DurationWriter duration()
duration in interface BaseWriter.ListWriterpublic DurationWriter duration(String name, TimeUnit unit)
duration in interface BaseWriter.StructWriterpublic TimeStampSecWriter timeStampSec(String name)
timeStampSec in interface BaseWriter.StructWriterpublic TimeStampSecWriter timeStampSec()
timeStampSec in interface BaseWriter.ListWriterpublic TimeStampMilliWriter timeStampMilli(String name)
timeStampMilli in interface BaseWriter.StructWriterpublic TimeStampMilliWriter timeStampMilli()
timeStampMilli in interface BaseWriter.ListWriterpublic TimeStampMicroWriter timeStampMicro(String name)
timeStampMicro in interface BaseWriter.StructWriterpublic TimeStampMicroWriter timeStampMicro()
timeStampMicro in interface BaseWriter.ListWriterpublic TimeStampNanoWriter timeStampNano(String name)
timeStampNano in interface BaseWriter.StructWriterpublic TimeStampNanoWriter timeStampNano()
timeStampNano in interface BaseWriter.ListWriterpublic TimeStampSecTZWriter timeStampSecTZ(String name)
timeStampSecTZ in interface BaseWriter.StructWriterpublic TimeStampSecTZWriter timeStampSecTZ()
timeStampSecTZ in interface BaseWriter.ListWriterpublic TimeStampSecTZWriter timeStampSecTZ(String name, String timezone)
timeStampSecTZ in interface BaseWriter.StructWriterpublic TimeStampMilliTZWriter timeStampMilliTZ(String name)
timeStampMilliTZ in interface BaseWriter.StructWriterpublic TimeStampMilliTZWriter timeStampMilliTZ()
timeStampMilliTZ in interface BaseWriter.ListWriterpublic TimeStampMilliTZWriter timeStampMilliTZ(String name, String timezone)
timeStampMilliTZ in interface BaseWriter.StructWriterpublic TimeStampMicroTZWriter timeStampMicroTZ(String name)
timeStampMicroTZ in interface BaseWriter.StructWriterpublic TimeStampMicroTZWriter timeStampMicroTZ()
timeStampMicroTZ in interface BaseWriter.ListWriterpublic TimeStampMicroTZWriter timeStampMicroTZ(String name, String timezone)
timeStampMicroTZ in interface BaseWriter.StructWriterpublic TimeStampNanoTZWriter timeStampNanoTZ(String name)
timeStampNanoTZ in interface BaseWriter.StructWriterpublic TimeStampNanoTZWriter timeStampNanoTZ()
timeStampNanoTZ in interface BaseWriter.ListWriterpublic TimeStampNanoTZWriter timeStampNanoTZ(String name, String timezone)
timeStampNanoTZ in interface BaseWriter.StructWriterpublic TimeMicroWriter timeMicro(String name)
timeMicro in interface BaseWriter.StructWriterpublic TimeMicroWriter timeMicro()
timeMicro in interface BaseWriter.ListWriterpublic TimeNanoWriter timeNano(String name)
timeNano in interface BaseWriter.StructWriterpublic TimeNanoWriter timeNano()
timeNano in interface BaseWriter.ListWriterpublic IntervalDayWriter intervalDay(String name)
intervalDay in interface BaseWriter.StructWriterpublic IntervalDayWriter intervalDay()
intervalDay in interface BaseWriter.ListWriterpublic IntervalMonthDayNanoWriter intervalMonthDayNano(String name)
intervalMonthDayNano in interface BaseWriter.StructWriterpublic IntervalMonthDayNanoWriter intervalMonthDayNano()
intervalMonthDayNano in interface BaseWriter.ListWriterpublic Decimal256Writer decimal256(String name)
decimal256 in interface BaseWriter.StructWriterpublic Decimal256Writer decimal256()
decimal256 in interface BaseWriter.ListWriterpublic Decimal256Writer decimal256(String name, int scale, int precision)
decimal256 in interface BaseWriter.StructWriterpublic DecimalWriter decimal(String name)
decimal in interface BaseWriter.StructWriterpublic DecimalWriter decimal()
decimal in interface BaseWriter.ListWriterpublic DecimalWriter decimal(String name, int scale, int precision)
decimal in interface BaseWriter.StructWriterpublic FixedSizeBinaryWriter fixedSizeBinary(String name)
fixedSizeBinary in interface BaseWriter.StructWriterpublic FixedSizeBinaryWriter fixedSizeBinary()
fixedSizeBinary in interface BaseWriter.ListWriterpublic FixedSizeBinaryWriter fixedSizeBinary(String name, int byteWidth)
fixedSizeBinary in interface BaseWriter.StructWriterpublic VarBinaryWriter varBinary(String name)
varBinary in interface BaseWriter.StructWriterpublic VarBinaryWriter varBinary()
varBinary in interface BaseWriter.ListWriterpublic VarCharWriter varChar(String name)
varChar in interface BaseWriter.StructWriterpublic VarCharWriter varChar()
varChar in interface BaseWriter.ListWriterpublic LargeVarCharWriter largeVarChar(String name)
largeVarChar in interface BaseWriter.StructWriterpublic LargeVarCharWriter largeVarChar()
largeVarChar in interface BaseWriter.ListWriterpublic LargeVarBinaryWriter largeVarBinary(String name)
largeVarBinary in interface BaseWriter.StructWriterpublic LargeVarBinaryWriter largeVarBinary()
largeVarBinary in interface BaseWriter.ListWriterpublic BitWriter bit(String name)
bit in interface BaseWriter.StructWriterpublic BitWriter bit()
bit in interface BaseWriter.ListWriterpublic void allocate()
allocate in interface FieldWriterpublic void clear()
clear in interface FieldWriterpublic void close()
throws Exception
close in interface AutoCloseableExceptionpublic Field getField()
getField in interface BaseWriter.StructWriterpublic int getValueCapacity()
getValueCapacity in interface BaseWriterpublic void setAddVectorAsNullable(boolean nullable)
nullable - Whether or not to create nullable vectors (default behavior is true)public void writeDecimal256(long start,
ArrowBuf buffer)
writeDecimal256 in interface Decimal256WriterDecimal256Writer.write(Decimal256Holder)public void writeBigEndianBytesToDecimal256(byte[] value)
writeBigEndianBytesToDecimal256 in interface Decimal256WriterDecimal256Writer.writeBigEndianBytesToDecimal256(byte[], ArrowType),
Decimal256Writer.write(Decimal256Holder)public void writeDecimal(long start,
ArrowBuf buffer)
writeDecimal in interface DecimalWriterDecimalWriter.write(DecimalHolder)public void writeBigEndianBytesToDecimal(byte[] value)
writeBigEndianBytesToDecimal in interface DecimalWriterDecimalWriter.writeBigEndianBytesToDecimal(byte[], ArrowType),
DecimalWriter.write(DecimalHolder)public boolean isEmptyStruct()
false.
Must be overridden by struct writers.
isEmptyStruct in interface BaseWriter.StructWriterpublic void copyReader(FieldReader reader)
copyReader in interface BaseWriter.ListWriterpublic void copyReaderToField(String name, FieldReader reader)
copyReaderToField in interface BaseWriter.StructWriterpublic int getPosition()
getPosition in interface PositionableCopyright © 2024 The Apache Software Foundation. All rights reserved.