Module org.apache.arrow.variant

Package org.apache.arrow.variant.impl

Class VariantWriterImpl

java.lang.Object

org.apache.arrow.vector.complex.impl.AbstractExtensionTypeWriter<VariantVector>

org.apache.arrow.variant.impl.VariantWriterImpl

All Implemented Interfaces:

AutoCloseable, Positionable, BaseWriter, BaseWriter.ExtensionWriter, BaseWriter.ListWriter, BaseWriter.MapWriter, BaseWriter.ScalarWriter, BaseWriter.StructWriter, BigIntWriter, BitWriter, DateDayWriter, DateMilliWriter, Decimal256Writer, DecimalWriter, DurationWriter, FieldWriter, FixedSizeBinaryWriter, Float2Writer, Float4Writer, Float8Writer, IntervalDayWriter, IntervalMonthDayNanoWriter, IntervalYearWriter, IntWriter, LargeVarBinaryWriter, LargeVarCharWriter, SmallIntWriter, TimeMicroWriter, TimeMilliWriter, TimeNanoWriter, TimeSecWriter, TimeStampMicroTZWriter, TimeStampMicroWriter, TimeStampMilliTZWriter, TimeStampMilliWriter, TimeStampNanoTZWriter, TimeStampNanoWriter, TimeStampSecTZWriter, TimeStampSecWriter, TinyIntWriter, UInt1Writer, UInt2Writer, UInt4Writer, UInt8Writer, VarBinaryWriter, VarCharWriter, ViewVarBinaryWriter, ViewVarCharWriter

public class VariantWriterImpl
extends AbstractExtensionTypeWriter<VariantVector>

Writer implementation for VARIANT extension type vectors.

This writer handles writing variant data to a VariantVector. It accepts both VariantHolder and NullableVariantHolder objects containing metadata and value buffers and writes them to the appropriate position in the vector.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.arrow.vector.complex.writer.BaseWriter

BaseWriter.ComplexWriter, BaseWriter.ExtensionWriter, BaseWriter.ListWriter, BaseWriter.MapWriter, BaseWriter.ScalarWriter, BaseWriter.StructOrListWriter, BaseWriter.StructWriter

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	addVectorAsNullable

Fields inherited from class org.apache.arrow.vector.complex.impl.AbstractExtensionTypeWriter

vector

Constructor Summary

Constructors

Constructor	Description
VariantWriterImpl(VariantVector vector)	Constructs a new VariantWriterImpl for the given vector.

Method Summary

Modifier and Type	Method	Description
BigIntWriter	bigInt()
BigIntWriter	bigInt(String name)
BitWriter	bit()
BitWriter	bit(String name)
void	copyReader(FieldReader reader)
void	copyReaderToField(String name, FieldReader reader)
DateDayWriter	dateDay()
DateDayWriter	dateDay(String name)
DateMilliWriter	dateMilli()
DateMilliWriter	dateMilli(String name)
DecimalWriter	decimal()
DecimalWriter	decimal(String name)
DecimalWriter	decimal(String name, int scale, int precision)
Decimal256Writer	decimal256()
Decimal256Writer	decimal256(String name)
Decimal256Writer	decimal256(String name, int scale, int precision)
DurationWriter	duration()
DurationWriter	duration(String name)
DurationWriter	duration(String name, TimeUnit unit)
void	end()
void	endEntry()
void	endList()
void	endListView()
void	endMap()
BaseWriter.ExtensionWriter	extension(String name, ArrowType arrowType)
BaseWriter.ExtensionWriter	extension(ArrowType arrowType)
FixedSizeBinaryWriter	fixedSizeBinary()
FixedSizeBinaryWriter	fixedSizeBinary(String name)
FixedSizeBinaryWriter	fixedSizeBinary(String name, int byteWidth)
Float2Writer	float2()
Float2Writer	float2(String name)
Float4Writer	float4()
Float4Writer	float4(String name)
Float8Writer	float8()
Float8Writer	float8(String name)
int	getPosition()
IntWriter	integer()
IntWriter	integer(String name)
IntervalDayWriter	intervalDay()
IntervalDayWriter	intervalDay(String name)
IntervalMonthDayNanoWriter	intervalMonthDayNano()
IntervalMonthDayNanoWriter	intervalMonthDayNano(String name)
IntervalYearWriter	intervalYear()
IntervalYearWriter	intervalYear(String name)
boolean	isEmptyStruct()	This implementation returns false.
BaseWriter.MapWriter	key()
LargeVarBinaryWriter	largeVarBinary()
LargeVarBinaryWriter	largeVarBinary(String name)
LargeVarCharWriter	largeVarChar()
LargeVarCharWriter	largeVarChar(String name)
BaseWriter.ListWriter	list()
BaseWriter.ListWriter	list(String name)
BaseWriter.ListWriter	listView()
BaseWriter.ListWriter	listView(String name)
BaseWriter.MapWriter	map()
BaseWriter.MapWriter	map(boolean keysSorted)
BaseWriter.MapWriter	map(String name)
BaseWriter.MapWriter	map(String name, boolean keysSorted)
void	setAddVectorAsNullable(boolean nullable)	Set flag to control the FieldType.nullable property when a writer creates a new vector.
void	setPosition(int index)
SmallIntWriter	smallInt()
SmallIntWriter	smallInt(String name)
void	start()
void	startEntry()
void	startList()
void	startListView()
void	startMap()
BaseWriter.StructWriter	struct()
BaseWriter.StructWriter	struct(String name)
TimeMicroWriter	timeMicro()
TimeMicroWriter	timeMicro(String name)
TimeMilliWriter	timeMilli()
TimeMilliWriter	timeMilli(String name)
TimeNanoWriter	timeNano()
TimeNanoWriter	timeNano(String name)
TimeSecWriter	timeSec()
TimeSecWriter	timeSec(String name)
TimeStampMicroWriter	timeStampMicro()
TimeStampMicroWriter	timeStampMicro(String name)
TimeStampMicroTZWriter	timeStampMicroTZ()
TimeStampMicroTZWriter	timeStampMicroTZ(String name)
TimeStampMicroTZWriter	timeStampMicroTZ(String name, String timezone)
TimeStampMilliWriter	timeStampMilli()
TimeStampMilliWriter	timeStampMilli(String name)
TimeStampMilliTZWriter	timeStampMilliTZ()
TimeStampMilliTZWriter	timeStampMilliTZ(String name)
TimeStampMilliTZWriter	timeStampMilliTZ(String name, String timezone)
TimeStampNanoWriter	timeStampNano()
TimeStampNanoWriter	timeStampNano(String name)
TimeStampNanoTZWriter	timeStampNanoTZ()
TimeStampNanoTZWriter	timeStampNanoTZ(String name)
TimeStampNanoTZWriter	timeStampNanoTZ(String name, String timezone)
TimeStampSecWriter	timeStampSec()
TimeStampSecWriter	timeStampSec(String name)
TimeStampSecTZWriter	timeStampSecTZ()
TimeStampSecTZWriter	timeStampSecTZ(String name)
TimeStampSecTZWriter	timeStampSecTZ(String name, String timezone)
TinyIntWriter	tinyInt()
TinyIntWriter	tinyInt(String name)
String	toString()
UInt1Writer	uInt1()
UInt1Writer	uInt1(String name)
UInt2Writer	uInt2()
UInt2Writer	uInt2(String name)
UInt4Writer	uInt4()
UInt4Writer	uInt4(String name)
UInt8Writer	uInt8()
UInt8Writer	uInt8(String name)
BaseWriter.MapWriter	value()
VarBinaryWriter	varBinary()
VarBinaryWriter	varBinary(String name)
VarCharWriter	varChar()
VarCharWriter	varChar(String name)
ViewVarBinaryWriter	viewVarBinary()
ViewVarBinaryWriter	viewVarBinary(String name)
ViewVarCharWriter	viewVarChar()
ViewVarCharWriter	viewVarChar(String name)
void	write(BigIntHolder holder)
void	write(BitHolder holder)
void	write(DateDayHolder holder)
void	write(DateMilliHolder holder)
void	write(Decimal256Holder holder)
void	write(DecimalHolder holder)
void	write(DurationHolder holder)
void	write(ExtensionHolder extensionHolder)	Writes a variant holder to the vector at the current position.
void	write(FixedSizeBinaryHolder holder)
void	write(Float2Holder holder)
void	write(Float4Holder holder)
void	write(Float8Holder holder)
void	write(IntervalDayHolder holder)
void	write(IntervalMonthDayNanoHolder holder)
void	write(IntervalYearHolder holder)
void	write(IntHolder holder)
void	write(LargeVarBinaryHolder holder)
void	write(LargeVarCharHolder holder)
void	write(SmallIntHolder holder)
void	write(TimeMicroHolder holder)
void	write(TimeMilliHolder holder)
void	write(TimeNanoHolder holder)
void	write(TimeSecHolder holder)
void	write(TimeStampMicroHolder holder)
void	write(TimeStampMicroTZHolder holder)
void	write(TimeStampMilliHolder holder)
void	write(TimeStampMilliTZHolder holder)
void	write(TimeStampNanoHolder holder)
void	write(TimeStampNanoTZHolder holder)
void	write(TimeStampSecHolder holder)
void	write(TimeStampSecTZHolder holder)
void	write(TinyIntHolder holder)
void	write(UInt1Holder holder)
void	write(UInt2Holder holder)
void	write(UInt4Holder holder)
void	write(UInt8Holder holder)
void	write(VarBinaryHolder holder)
void	write(VarCharHolder holder)
void	write(ViewVarBinaryHolder holder)
void	write(ViewVarCharHolder holder)
void	writeBigEndianBytesToDecimal(byte[] value)
void	writeBigEndianBytesToDecimal(byte[] value, ArrowType arrowType)
void	writeBigEndianBytesToDecimal256(byte[] value)
void	writeBigEndianBytesToDecimal256(byte[] value, ArrowType arrowType)
void	writeBigInt(long value)
void	writeBit(int value)
void	writeDateDay(int value)
void	writeDateMilli(long value)
void	writeDecimal(long start, ArrowBuf buffer)
void	writeDecimal(long start, ArrowBuf buffer, ArrowType arrowType)
void	writeDecimal(BigDecimal value)
void	writeDecimal256(long start, ArrowBuf buffer)
void	writeDecimal256(long start, ArrowBuf buffer, ArrowType arrowType)
void	writeDecimal256(BigDecimal value)
void	writeDuration(long value)
void	writeExtension(Object object)	Writes an extension type or variant value to the vector.
void	writeExtension(Object value, ArrowType type)	Writes the given extension type value.
void	writeFixedSizeBinary(ArrowBuf buffer)
void	writeFloat2(short value)
void	writeFloat4(float value)
void	writeFloat8(double value)
void	writeInt(int value)
void	writeIntervalDay(int days, int milliseconds)
void	writeIntervalMonthDayNano(int months, int days, long nanoseconds)
void	writeIntervalYear(int value)
void	writeLargeVarBinary(byte[] value)
void	writeLargeVarBinary(byte[] value, int offset, int length)
void	writeLargeVarBinary(long start, long end, ArrowBuf buffer)
void	writeLargeVarBinary(ByteBuffer value)
void	writeLargeVarBinary(ByteBuffer value, int offset, int length)
void	writeLargeVarChar(long start, long end, ArrowBuf buffer)
void	writeLargeVarChar(String value)
void	writeLargeVarChar(Text value)
void	writeSmallInt(short value)
void	writeTimeMicro(long value)
void	writeTimeMilli(int value)
void	writeTimeNano(long value)
void	writeTimeSec(int value)
void	writeTimeStampMicro(long value)
void	writeTimeStampMicroTZ(long value)
void	writeTimeStampMilli(long value)
void	writeTimeStampMilliTZ(long value)
void	writeTimeStampNano(long value)
void	writeTimeStampNanoTZ(long value)
void	writeTimeStampSec(long value)
void	writeTimeStampSecTZ(long value)
void	writeTinyInt(byte value)
void	writeUInt1(byte value)
void	writeUInt2(char value)
void	writeUInt4(int value)
void	writeUInt8(long value)
void	writeVarBinary(byte[] value)
void	writeVarBinary(byte[] value, int offset, int length)
void	writeVarBinary(int start, int end, ArrowBuf buffer)
void	writeVarBinary(ByteBuffer value)
void	writeVarBinary(ByteBuffer value, int offset, int length)
void	writeVarChar(int start, int end, ArrowBuf buffer)
void	writeVarChar(String value)
void	writeVarChar(Text value)
void	writeViewVarBinary(byte[] value)
void	writeViewVarBinary(byte[] value, int offset, int length)
void	writeViewVarBinary(int start, int end, ArrowBuf buffer)
void	writeViewVarBinary(ByteBuffer value)
void	writeViewVarBinary(ByteBuffer value, int offset, int length)
void	writeViewVarChar(int start, int end, ArrowBuf buffer)
void	writeViewVarChar(String value)
void	writeViewVarChar(Text value)

Methods inherited from class org.apache.arrow.vector.complex.impl.AbstractExtensionTypeWriter

allocate, clear, close, getField, getValueCapacity, writeNull

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.arrow.vector.complex.Positionable

getPosition, setPosition

Field Details

addVectorAsNullable

protected boolean addVectorAsNullable

Constructor Details

VariantWriterImpl

public VariantWriterImpl(VariantVector vector)

Constructs a new VariantWriterImpl for the given vector.

Parameters:

vector - the variant vector to write to

Method Details

writeExtension

public void writeExtension(Object object)

Writes an extension type or variant value to the vector.

This method handles ExtensionHolder by delegating to write(ExtensionHolder) and Variant by delegating to writeVariant(Variant).

Specified by:

writeExtension in interface BaseWriter.ExtensionWriter

Parameters:

object - the object to write, must be an ExtensionHolder or Variant

Throws:

IllegalArgumentException - if the object is not an ExtensionHolder or Variant

writeExtension

public void writeExtension(Object value,
 ArrowType type)

Description copied from interface: BaseWriter.ExtensionWriter

Writes the given extension type value.

Specified by:

writeExtension in interface BaseWriter.ExtensionWriter

Parameters:

value - the extension type value to write

type - of the extension

write

public void write(ExtensionHolder extensionHolder)

Writes a variant holder to the vector at the current position.

The holder can be either a VariantHolder (non-nullable, always set) or a NullableVariantHolder (nullable, may be null). The data is written using VariantVector.setSafe(int, NullableVariantHolder) which handles buffer allocation and copying.

Specified by:

write in interface BaseWriter.ExtensionWriter

Parameters:

extensionHolder - the variant holder to write, must be a VariantHolder or NullableVariantHolder

Throws:

IllegalArgumentException - if the holder is neither a VariantHolder nor a NullableVariantHolder

setAddVectorAsNullable

public void setAddVectorAsNullable(boolean nullable)

Set flag to control the FieldType.nullable property when a writer creates a new vector. If true then vectors created will be nullable, this is the default behavior. If false then vectors created will be non-nullable.

Parameters:

nullable - Whether or not to create nullable vectors (default behavior is true)

start

public void start()

Specified by:

start in interface BaseWriter.StructWriter

end

public void end()

Specified by:

end in interface BaseWriter.StructWriter

startList

public void startList()

Specified by:

startList in interface BaseWriter.ListWriter

endList

public void endList()

Specified by:

endList in interface BaseWriter.ListWriter

startListView

public void startListView()

Specified by:

startListView in interface BaseWriter.ListWriter

endListView

public void endListView()

Specified by:

endListView in interface BaseWriter.ListWriter

startMap

public void startMap()

Specified by:

startMap in interface BaseWriter.MapWriter

endMap

public void endMap()

Specified by:

endMap in interface BaseWriter.MapWriter

startEntry

public void startEntry()

Specified by:

startEntry in interface BaseWriter.MapWriter

key

public BaseWriter.MapWriter key()

Specified by:

key in interface BaseWriter.MapWriter

value

public BaseWriter.MapWriter value()

Specified by:

value in interface BaseWriter.MapWriter

endEntry

public void endEntry()

Specified by:

endEntry in interface BaseWriter.MapWriter

write

public void write(TinyIntHolder holder)

Specified by:

write in interface TinyIntWriter

writeTinyInt

public void writeTinyInt(byte value)

Specified by:

writeTinyInt in interface TinyIntWriter

write

public void write(UInt1Holder holder)

Specified by:

write in interface UInt1Writer

writeUInt1

public void writeUInt1(byte value)

Specified by:

writeUInt1 in interface UInt1Writer

write

public void write(UInt2Holder holder)

Specified by:

write in interface UInt2Writer

writeUInt2

public void writeUInt2(char value)

Specified by:

writeUInt2 in interface UInt2Writer

write

public void write(SmallIntHolder holder)

Specified by:

write in interface SmallIntWriter

writeSmallInt

public void writeSmallInt(short value)

Specified by:

writeSmallInt in interface SmallIntWriter

write

public void write(Float2Holder holder)

Specified by:

write in interface Float2Writer

writeFloat2

public void writeFloat2(short value)

Specified by:

writeFloat2 in interface Float2Writer

write

public void write(IntHolder holder)

Specified by:

write in interface IntWriter

writeInt

public void writeInt(int value)

Specified by:

writeInt in interface IntWriter

write

public void write(UInt4Holder holder)

Specified by:

write in interface UInt4Writer

writeUInt4

public void writeUInt4(int value)

Specified by:

writeUInt4 in interface UInt4Writer

write

public void write(Float4Holder holder)

Specified by:

write in interface Float4Writer

writeFloat4

public void writeFloat4(float value)

Specified by:

writeFloat4 in interface Float4Writer

write

public void write(DateDayHolder holder)

Specified by:

write in interface DateDayWriter

writeDateDay

public void writeDateDay(int value)

Specified by:

writeDateDay in interface DateDayWriter

write

public void write(IntervalYearHolder holder)

Specified by:

write in interface IntervalYearWriter

writeIntervalYear

public void writeIntervalYear(int value)

Specified by:

writeIntervalYear in interface IntervalYearWriter

write

public void write(TimeSecHolder holder)

Specified by:

write in interface TimeSecWriter

writeTimeSec

public void writeTimeSec(int value)

Specified by:

writeTimeSec in interface TimeSecWriter

write

public void write(TimeMilliHolder holder)

Specified by:

write in interface TimeMilliWriter

writeTimeMilli

public void writeTimeMilli(int value)

Specified by:

writeTimeMilli in interface TimeMilliWriter

write

public void write(BigIntHolder holder)

Specified by:

write in interface BigIntWriter

writeBigInt

public void writeBigInt(long value)

Specified by:

writeBigInt in interface BigIntWriter

write

public void write(UInt8Holder holder)

Specified by:

write in interface UInt8Writer

writeUInt8

public void writeUInt8(long value)

Specified by:

writeUInt8 in interface UInt8Writer

write

public void write(Float8Holder holder)

Specified by:

write in interface Float8Writer

writeFloat8

public void writeFloat8(double value)

Specified by:

writeFloat8 in interface Float8Writer

write

public void write(DateMilliHolder holder)

Specified by:

write in interface DateMilliWriter

writeDateMilli

public void writeDateMilli(long value)

Specified by:

writeDateMilli in interface DateMilliWriter

write

public void write(DurationHolder holder)

Specified by:

write in interface DurationWriter

writeDuration

public void writeDuration(long value)

Specified by:

writeDuration in interface DurationWriter

See Also:

• DurationWriter.write(DurationHolder)

write

public void write(TimeStampSecHolder holder)

Specified by:

write in interface TimeStampSecWriter

writeTimeStampSec

public void writeTimeStampSec(long value)

Specified by:

writeTimeStampSec in interface TimeStampSecWriter

write

public void write(TimeStampMilliHolder holder)

Specified by:

write in interface TimeStampMilliWriter

writeTimeStampMilli

public void writeTimeStampMilli(long value)

Specified by:

writeTimeStampMilli in interface TimeStampMilliWriter

write

public void write(TimeStampMicroHolder holder)

Specified by:

write in interface TimeStampMicroWriter

writeTimeStampMicro

public void writeTimeStampMicro(long value)

Specified by:

writeTimeStampMicro in interface TimeStampMicroWriter

write

public void write(TimeStampNanoHolder holder)

Specified by:

write in interface TimeStampNanoWriter

writeTimeStampNano

public void writeTimeStampNano(long value)

Specified by:

writeTimeStampNano in interface TimeStampNanoWriter

write

public void write(TimeStampSecTZHolder holder)

Specified by:

write in interface TimeStampSecTZWriter

writeTimeStampSecTZ

public void writeTimeStampSecTZ(long value)

Specified by:

writeTimeStampSecTZ in interface TimeStampSecTZWriter

See Also:

• TimeStampSecTZWriter.write(TimeStampSecTZHolder)

write

public void write(TimeStampMilliTZHolder holder)

Specified by:

write in interface TimeStampMilliTZWriter

writeTimeStampMilliTZ

public void writeTimeStampMilliTZ(long value)

Specified by:

writeTimeStampMilliTZ in interface TimeStampMilliTZWriter

See Also:

• TimeStampMilliTZWriter.write(TimeStampMilliTZHolder)

write

public void write(TimeStampMicroTZHolder holder)

Specified by:

write in interface TimeStampMicroTZWriter

writeTimeStampMicroTZ

public void writeTimeStampMicroTZ(long value)

Specified by:

writeTimeStampMicroTZ in interface TimeStampMicroTZWriter

See Also:

• TimeStampMicroTZWriter.write(TimeStampMicroTZHolder)

write

public void write(TimeStampNanoTZHolder holder)

Specified by:

write in interface TimeStampNanoTZWriter

writeTimeStampNanoTZ

public void writeTimeStampNanoTZ(long value)

Specified by:

writeTimeStampNanoTZ in interface TimeStampNanoTZWriter

See Also:

• TimeStampNanoTZWriter.write(TimeStampNanoTZHolder)

write

public void write(TimeMicroHolder holder)

Specified by:

write in interface TimeMicroWriter

writeTimeMicro

public void writeTimeMicro(long value)

Specified by:

writeTimeMicro in interface TimeMicroWriter

write

public void write(TimeNanoHolder holder)

Specified by:

write in interface TimeNanoWriter

writeTimeNano

public void writeTimeNano(long value)

Specified by:

writeTimeNano in interface TimeNanoWriter

write

public void write(IntervalDayHolder holder)

Specified by:

write in interface IntervalDayWriter

writeIntervalDay

public void writeIntervalDay(int days,
 int milliseconds)

Specified by:

writeIntervalDay in interface IntervalDayWriter

write

public void write(IntervalMonthDayNanoHolder holder)

Specified by:

write in interface IntervalMonthDayNanoWriter

writeIntervalMonthDayNano

public void writeIntervalMonthDayNano(int months,
 int days,
 long nanoseconds)

Specified by:

writeIntervalMonthDayNano in interface IntervalMonthDayNanoWriter

write

public void write(Decimal256Holder holder)

Specified by:

write in interface Decimal256Writer

writeDecimal256

public void writeDecimal256(long start,
 ArrowBuf buffer)

Specified by:

writeDecimal256 in interface Decimal256Writer

See Also:

• Decimal256Writer.write(Decimal256Holder)

writeDecimal256

public void writeDecimal256(BigDecimal value)

Specified by:

writeDecimal256 in interface Decimal256Writer

writeDecimal256

public void writeDecimal256(long start,
 ArrowBuf buffer,
 ArrowType arrowType)

Specified by:

writeDecimal256 in interface Decimal256Writer

writeBigEndianBytesToDecimal256

public void writeBigEndianBytesToDecimal256(byte[] value)

Specified by:

writeBigEndianBytesToDecimal256 in interface Decimal256Writer

See Also:

• Decimal256Writer.writeBigEndianBytesToDecimal256(byte[], ArrowType)
• Decimal256Writer.write(Decimal256Holder)

writeBigEndianBytesToDecimal256

public void writeBigEndianBytesToDecimal256(byte[] value,
 ArrowType arrowType)

Specified by:

writeBigEndianBytesToDecimal256 in interface Decimal256Writer

write

public void write(DecimalHolder holder)

Specified by:

write in interface DecimalWriter

writeDecimal

public void writeDecimal(long start,
 ArrowBuf buffer)

Specified by:

writeDecimal in interface DecimalWriter

See Also:

• DecimalWriter.write(DecimalHolder)

writeDecimal

public void writeDecimal(BigDecimal value)

Specified by:

writeDecimal in interface DecimalWriter

writeDecimal

public void writeDecimal(long start,
 ArrowBuf buffer,
 ArrowType arrowType)

Specified by:

writeDecimal in interface DecimalWriter

writeBigEndianBytesToDecimal

public void writeBigEndianBytesToDecimal(byte[] value)

Specified by:

writeBigEndianBytesToDecimal in interface DecimalWriter

See Also:

• DecimalWriter.writeBigEndianBytesToDecimal(byte[], ArrowType)
• DecimalWriter.write(DecimalHolder)

writeBigEndianBytesToDecimal

public void writeBigEndianBytesToDecimal(byte[] value,
 ArrowType arrowType)

Specified by:

writeBigEndianBytesToDecimal in interface DecimalWriter

write

public void write(FixedSizeBinaryHolder holder)

Specified by:

write in interface FixedSizeBinaryWriter

writeFixedSizeBinary

public void writeFixedSizeBinary(ArrowBuf buffer)

Specified by:

writeFixedSizeBinary in interface FixedSizeBinaryWriter

See Also:

• FixedSizeBinaryWriter.write(FixedSizeBinaryHolder)

write

public void write(VarBinaryHolder holder)

Specified by:

write in interface VarBinaryWriter

writeVarBinary

public void writeVarBinary(int start,
 int end,
 ArrowBuf buffer)

Specified by:

writeVarBinary in interface VarBinaryWriter

writeVarBinary

public void writeVarBinary(byte[] value)

Specified by:

writeVarBinary in interface VarBinaryWriter

writeVarBinary

public void writeVarBinary(byte[] value,
 int offset,
 int length)

Specified by:

writeVarBinary in interface VarBinaryWriter

writeVarBinary

public void writeVarBinary(ByteBuffer value)

Specified by:

writeVarBinary in interface VarBinaryWriter

writeVarBinary

public void writeVarBinary(ByteBuffer value,
 int offset,
 int length)

Specified by:

writeVarBinary in interface VarBinaryWriter

write

public void write(VarCharHolder holder)

Specified by:

write in interface VarCharWriter

writeVarChar

public void writeVarChar(int start,
 int end,
 ArrowBuf buffer)

Specified by:

writeVarChar in interface VarCharWriter

writeVarChar

public void writeVarChar(Text value)

Specified by:

writeVarChar in interface VarCharWriter

writeVarChar

public void writeVarChar(String value)

Specified by:

writeVarChar in interface VarCharWriter

write

public void write(ViewVarBinaryHolder holder)

Specified by:

write in interface ViewVarBinaryWriter

writeViewVarBinary

public void writeViewVarBinary(int start,
 int end,
 ArrowBuf buffer)

Specified by:

writeViewVarBinary in interface ViewVarBinaryWriter

writeViewVarBinary

public void writeViewVarBinary(byte[] value)

Specified by:

writeViewVarBinary in interface ViewVarBinaryWriter

writeViewVarBinary

public void writeViewVarBinary(byte[] value,
 int offset,
 int length)

Specified by:

writeViewVarBinary in interface ViewVarBinaryWriter

writeViewVarBinary

public void writeViewVarBinary(ByteBuffer value)

Specified by:

writeViewVarBinary in interface ViewVarBinaryWriter

writeViewVarBinary

public void writeViewVarBinary(ByteBuffer value,
 int offset,
 int length)

Specified by:

writeViewVarBinary in interface ViewVarBinaryWriter

write

public void write(ViewVarCharHolder holder)

Specified by:

write in interface ViewVarCharWriter

writeViewVarChar

public void writeViewVarChar(int start,
 int end,
 ArrowBuf buffer)

Specified by:

writeViewVarChar in interface ViewVarCharWriter

writeViewVarChar

public void writeViewVarChar(Text value)

Specified by:

writeViewVarChar in interface ViewVarCharWriter

writeViewVarChar

public void writeViewVarChar(String value)

Specified by:

writeViewVarChar in interface ViewVarCharWriter

write

public void write(LargeVarCharHolder holder)

Specified by:

write in interface LargeVarCharWriter

writeLargeVarChar

public void writeLargeVarChar(long start,
 long end,
 ArrowBuf buffer)

Specified by:

writeLargeVarChar in interface LargeVarCharWriter

writeLargeVarChar

public void writeLargeVarChar(Text value)

Specified by:

writeLargeVarChar in interface LargeVarCharWriter

writeLargeVarChar

public void writeLargeVarChar(String value)

Specified by:

writeLargeVarChar in interface LargeVarCharWriter

write

public void write(LargeVarBinaryHolder holder)

Specified by:

write in interface LargeVarBinaryWriter

writeLargeVarBinary

public void writeLargeVarBinary(long start,
 long end,
 ArrowBuf buffer)

Specified by:

writeLargeVarBinary in interface LargeVarBinaryWriter

writeLargeVarBinary

public void writeLargeVarBinary(byte[] value)

Specified by:

writeLargeVarBinary in interface LargeVarBinaryWriter

writeLargeVarBinary

public void writeLargeVarBinary(byte[] value,
 int offset,
 int length)

Specified by:

writeLargeVarBinary in interface LargeVarBinaryWriter

writeLargeVarBinary

public void writeLargeVarBinary(ByteBuffer value)

Specified by:

writeLargeVarBinary in interface LargeVarBinaryWriter

writeLargeVarBinary

public void writeLargeVarBinary(ByteBuffer value,
 int offset,
 int length)

Specified by:

writeLargeVarBinary in interface LargeVarBinaryWriter

write

public void write(BitHolder holder)

Specified by:

write in interface BitWriter

writeBit

public void writeBit(int value)

Specified by:

writeBit in interface BitWriter

isEmptyStruct

public boolean isEmptyStruct()

This implementation returns false.

Must be overridden by struct writers.

Specified by:

isEmptyStruct in interface BaseWriter.StructWriter

Returns:

whether the struct is empty

struct

public BaseWriter.StructWriter struct()

Specified by:

struct in interface BaseWriter.ListWriter

list

public BaseWriter.ListWriter list()

Specified by:

list in interface BaseWriter.ListWriter

listView

public BaseWriter.ListWriter listView()

Specified by:

listView in interface BaseWriter.ListWriter

map

public BaseWriter.MapWriter map()

Specified by:

map in interface BaseWriter.ListWriter

struct

public BaseWriter.StructWriter struct(String name)

Specified by:

struct in interface BaseWriter.StructWriter

list

public BaseWriter.ListWriter list(String name)

Specified by:

list in interface BaseWriter.StructWriter

listView

public BaseWriter.ListWriter listView(String name)

Specified by:

listView in interface BaseWriter.StructWriter

map

public BaseWriter.MapWriter map(String name)

Specified by:

map in interface BaseWriter.StructWriter

map

public BaseWriter.MapWriter map(boolean keysSorted)

Specified by:

map in interface BaseWriter.ListWriter

map

public BaseWriter.MapWriter map(String name,
 boolean keysSorted)

Specified by:

map in interface BaseWriter.StructWriter

extension

public BaseWriter.ExtensionWriter extension(String name,
 ArrowType arrowType)

Specified by:

extension in interface BaseWriter.StructWriter

extension

public BaseWriter.ExtensionWriter extension(ArrowType arrowType)

Specified by:

extension in interface BaseWriter.ListWriter

tinyInt

public TinyIntWriter tinyInt(String name)

Specified by:

tinyInt in interface BaseWriter.StructWriter

tinyInt

public TinyIntWriter tinyInt()

Specified by:

tinyInt in interface BaseWriter.ListWriter

uInt1

public UInt1Writer uInt1(String name)

Specified by:

uInt1 in interface BaseWriter.StructWriter

uInt1

public UInt1Writer uInt1()

Specified by:

uInt1 in interface BaseWriter.ListWriter

uInt2

public UInt2Writer uInt2(String name)

Specified by:

uInt2 in interface BaseWriter.StructWriter

uInt2

public UInt2Writer uInt2()

Specified by:

uInt2 in interface BaseWriter.ListWriter

smallInt

public SmallIntWriter smallInt(String name)

Specified by:

smallInt in interface BaseWriter.StructWriter

smallInt

public SmallIntWriter smallInt()

Specified by:

smallInt in interface BaseWriter.ListWriter

float2

public Float2Writer float2(String name)

Specified by:

float2 in interface BaseWriter.StructWriter

float2

public Float2Writer float2()

Specified by:

float2 in interface BaseWriter.ListWriter

integer

public IntWriter integer(String name)

Specified by:

integer in interface BaseWriter.StructWriter

integer

public IntWriter integer()

Specified by:

integer in interface BaseWriter.ListWriter

uInt4

public UInt4Writer uInt4(String name)

Specified by:

uInt4 in interface BaseWriter.StructWriter

uInt4

public UInt4Writer uInt4()

Specified by:

uInt4 in interface BaseWriter.ListWriter

float4

public Float4Writer float4(String name)

Specified by:

float4 in interface BaseWriter.StructWriter

float4

public Float4Writer float4()

Specified by:

float4 in interface BaseWriter.ListWriter

dateDay

public DateDayWriter dateDay(String name)

Specified by:

dateDay in interface BaseWriter.StructWriter

dateDay

public DateDayWriter dateDay()

Specified by:

dateDay in interface BaseWriter.ListWriter

intervalYear

public IntervalYearWriter intervalYear(String name)

Specified by:

intervalYear in interface BaseWriter.StructWriter

intervalYear

public IntervalYearWriter intervalYear()

Specified by:

intervalYear in interface BaseWriter.ListWriter

timeSec

public TimeSecWriter timeSec(String name)

Specified by:

timeSec in interface BaseWriter.StructWriter

timeSec

public TimeSecWriter timeSec()

Specified by:

timeSec in interface BaseWriter.ListWriter

timeMilli

public TimeMilliWriter timeMilli(String name)

Specified by:

timeMilli in interface BaseWriter.StructWriter

timeMilli

public TimeMilliWriter timeMilli()

Specified by:

timeMilli in interface BaseWriter.ListWriter

bigInt

public BigIntWriter bigInt(String name)

Specified by:

bigInt in interface BaseWriter.StructWriter

bigInt

public BigIntWriter bigInt()

Specified by:

bigInt in interface BaseWriter.ListWriter

uInt8

public UInt8Writer uInt8(String name)

Specified by:

uInt8 in interface BaseWriter.StructWriter

uInt8

public UInt8Writer uInt8()

Specified by:

uInt8 in interface BaseWriter.ListWriter

float8

public Float8Writer float8(String name)

Specified by:

float8 in interface BaseWriter.StructWriter

float8

public Float8Writer float8()

Specified by:

float8 in interface BaseWriter.ListWriter

dateMilli

public DateMilliWriter dateMilli(String name)

Specified by:

dateMilli in interface BaseWriter.StructWriter

dateMilli

public DateMilliWriter dateMilli()

Specified by:

dateMilli in interface BaseWriter.ListWriter

duration

public DurationWriter duration(String name,
 TimeUnit unit)

Specified by:

duration in interface BaseWriter.StructWriter

duration

public DurationWriter duration(String name)

Specified by:

duration in interface BaseWriter.StructWriter

duration

public DurationWriter duration()

Specified by:

duration in interface BaseWriter.ListWriter

timeStampSec

public TimeStampSecWriter timeStampSec(String name)

Specified by:

timeStampSec in interface BaseWriter.StructWriter

timeStampSec

public TimeStampSecWriter timeStampSec()

Specified by:

timeStampSec in interface BaseWriter.ListWriter

timeStampMilli

public TimeStampMilliWriter timeStampMilli(String name)

Specified by:

timeStampMilli in interface BaseWriter.StructWriter

timeStampMilli

public TimeStampMilliWriter timeStampMilli()

Specified by:

timeStampMilli in interface BaseWriter.ListWriter

timeStampMicro

public TimeStampMicroWriter timeStampMicro(String name)

Specified by:

timeStampMicro in interface BaseWriter.StructWriter

timeStampMicro

public TimeStampMicroWriter timeStampMicro()

Specified by:

timeStampMicro in interface BaseWriter.ListWriter

timeStampNano

public TimeStampNanoWriter timeStampNano(String name)

Specified by:

timeStampNano in interface BaseWriter.StructWriter

timeStampNano

public TimeStampNanoWriter timeStampNano()

Specified by:

timeStampNano in interface BaseWriter.ListWriter

timeStampSecTZ

public TimeStampSecTZWriter timeStampSecTZ(String name,
 String timezone)

Specified by:

timeStampSecTZ in interface BaseWriter.StructWriter

timeStampSecTZ

public TimeStampSecTZWriter timeStampSecTZ(String name)

Specified by:

timeStampSecTZ in interface BaseWriter.StructWriter

timeStampSecTZ

public TimeStampSecTZWriter timeStampSecTZ()

Specified by:

timeStampSecTZ in interface BaseWriter.ListWriter

timeStampMilliTZ

public TimeStampMilliTZWriter timeStampMilliTZ(String name,
 String timezone)

Specified by:

timeStampMilliTZ in interface BaseWriter.StructWriter

timeStampMilliTZ

public TimeStampMilliTZWriter timeStampMilliTZ(String name)

Specified by:

timeStampMilliTZ in interface BaseWriter.StructWriter

timeStampMilliTZ

public TimeStampMilliTZWriter timeStampMilliTZ()

Specified by:

timeStampMilliTZ in interface BaseWriter.ListWriter

timeStampMicroTZ

public TimeStampMicroTZWriter timeStampMicroTZ(String name,
 String timezone)

Specified by:

timeStampMicroTZ in interface BaseWriter.StructWriter

timeStampMicroTZ

public TimeStampMicroTZWriter timeStampMicroTZ(String name)

Specified by:

timeStampMicroTZ in interface BaseWriter.StructWriter

timeStampMicroTZ

public TimeStampMicroTZWriter timeStampMicroTZ()

Specified by:

timeStampMicroTZ in interface BaseWriter.ListWriter

timeStampNanoTZ

public TimeStampNanoTZWriter timeStampNanoTZ(String name,
 String timezone)

Specified by:

timeStampNanoTZ in interface BaseWriter.StructWriter

timeStampNanoTZ

public TimeStampNanoTZWriter timeStampNanoTZ(String name)

Specified by:

timeStampNanoTZ in interface BaseWriter.StructWriter

timeStampNanoTZ

public TimeStampNanoTZWriter timeStampNanoTZ()

Specified by:

timeStampNanoTZ in interface BaseWriter.ListWriter

timeMicro

public TimeMicroWriter timeMicro(String name)

Specified by:

timeMicro in interface BaseWriter.StructWriter

timeMicro

public TimeMicroWriter timeMicro()

Specified by:

timeMicro in interface BaseWriter.ListWriter

timeNano

public TimeNanoWriter timeNano(String name)

Specified by:

timeNano in interface BaseWriter.StructWriter

timeNano

public TimeNanoWriter timeNano()

Specified by:

timeNano in interface BaseWriter.ListWriter

intervalDay

public IntervalDayWriter intervalDay(String name)

Specified by:

intervalDay in interface BaseWriter.StructWriter

intervalDay

public IntervalDayWriter intervalDay()

Specified by:

intervalDay in interface BaseWriter.ListWriter

intervalMonthDayNano

public IntervalMonthDayNanoWriter intervalMonthDayNano(String name)

Specified by:

intervalMonthDayNano in interface BaseWriter.StructWriter

intervalMonthDayNano

public IntervalMonthDayNanoWriter intervalMonthDayNano()

Specified by:

intervalMonthDayNano in interface BaseWriter.ListWriter

decimal256

public Decimal256Writer decimal256(String name,
 int scale,
 int precision)

Specified by:

decimal256 in interface BaseWriter.StructWriter

decimal256

public Decimal256Writer decimal256(String name)

Specified by:

decimal256 in interface BaseWriter.StructWriter

decimal256

public Decimal256Writer decimal256()

Specified by:

decimal256 in interface BaseWriter.ListWriter

decimal

public DecimalWriter decimal(String name,
 int scale,
 int precision)

Specified by:

decimal in interface BaseWriter.StructWriter

decimal

public DecimalWriter decimal(String name)

Specified by:

decimal in interface BaseWriter.StructWriter

decimal

public DecimalWriter decimal()

Specified by:

decimal in interface BaseWriter.ListWriter

fixedSizeBinary

public FixedSizeBinaryWriter fixedSizeBinary(String name,
 int byteWidth)

Specified by:

fixedSizeBinary in interface BaseWriter.StructWriter

fixedSizeBinary

public FixedSizeBinaryWriter fixedSizeBinary(String name)

Specified by:

fixedSizeBinary in interface BaseWriter.StructWriter

fixedSizeBinary

public FixedSizeBinaryWriter fixedSizeBinary()

Specified by:

fixedSizeBinary in interface BaseWriter.ListWriter

varBinary

public VarBinaryWriter varBinary(String name)

Specified by:

varBinary in interface BaseWriter.StructWriter

varBinary

public VarBinaryWriter varBinary()

Specified by:

varBinary in interface BaseWriter.ListWriter

varChar

public VarCharWriter varChar(String name)

Specified by:

varChar in interface BaseWriter.StructWriter

varChar

public VarCharWriter varChar()

Specified by:

varChar in interface BaseWriter.ListWriter

viewVarBinary

public ViewVarBinaryWriter viewVarBinary(String name)

Specified by:

viewVarBinary in interface BaseWriter.StructWriter

viewVarBinary

public ViewVarBinaryWriter viewVarBinary()

Specified by:

viewVarBinary in interface BaseWriter.ListWriter

viewVarChar

public ViewVarCharWriter viewVarChar(String name)

Specified by:

viewVarChar in interface BaseWriter.StructWriter

viewVarChar

public ViewVarCharWriter viewVarChar()

Specified by:

viewVarChar in interface BaseWriter.ListWriter

largeVarChar

public LargeVarCharWriter largeVarChar(String name)

Specified by:

largeVarChar in interface BaseWriter.StructWriter

largeVarChar

public LargeVarCharWriter largeVarChar()

Specified by:

largeVarChar in interface BaseWriter.ListWriter

largeVarBinary

public LargeVarBinaryWriter largeVarBinary(String name)

Specified by:

largeVarBinary in interface BaseWriter.StructWriter

largeVarBinary

public LargeVarBinaryWriter largeVarBinary()

Specified by:

largeVarBinary in interface BaseWriter.ListWriter

bit

public BitWriter bit(String name)

Specified by:

bit in interface BaseWriter.StructWriter

bit

public BitWriter bit()

Specified by:

bit in interface BaseWriter.ListWriter

copyReader

public void copyReader(FieldReader reader)

Specified by:

copyReader in interface BaseWriter.ListWriter

copyReaderToField

public void copyReaderToField(String name,
 FieldReader reader)

Specified by:

copyReaderToField in interface BaseWriter.StructWriter

toString

public String toString()

Overrides:

toString in class Object

getPosition

public int getPosition()

Specified by:

getPosition in interface Positionable

setPosition

public void setPosition(int index)

Specified by:

setPosition in interface Positionable