Modifier and Type | Method and Description |
---|---|
ArrowBuf |
NettyArrowBuf.arrowBuf() |
Modifier and Type | Method and Description |
---|---|
static NettyArrowBuf |
NettyArrowBuf.unwrapBuffer(ArrowBuf buf)
unwrap arrow buffer into a netty buffer.
|
Constructor and Description |
---|
NettyArrowBuf(ArrowBuf arrowBuf,
BufferAllocator bufferAllocator,
int length)
Constructs a new instance.
|
Modifier and Type | Method and Description |
---|---|
protected ArrowBuf |
ZstdCompressionCodec.doCompress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
protected ArrowBuf |
Lz4CompressionCodec.doCompress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
protected ArrowBuf |
ZstdCompressionCodec.doDecompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
protected ArrowBuf |
Lz4CompressionCodec.doDecompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
Modifier and Type | Method and Description |
---|---|
protected ArrowBuf |
ZstdCompressionCodec.doCompress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
protected ArrowBuf |
Lz4CompressionCodec.doCompress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
protected ArrowBuf |
ZstdCompressionCodec.doDecompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
protected ArrowBuf |
Lz4CompressionCodec.doDecompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
Modifier and Type | Method and Description |
---|---|
ArrowBuf |
PutResult.getApplicationMetadata()
Get the metadata in this message.
|
ArrowBuf |
FlightStream.getLatestMetadata()
Get the most recent metadata sent from the server.
|
Modifier and Type | Method and Description |
---|---|
static PutResult |
PutResult.metadata(ArrowBuf metadata)
Create a PutResult with application-specific metadata.
|
void |
OutboundStreamListener.putMetadata(ArrowBuf metadata)
Send a pure metadata message without any associated data.
|
void |
OutboundStreamListener.putNext(ArrowBuf metadata)
Send the current contents of the associated
VectorSchemaRoot alongside application-defined metadata. |
Modifier and Type | Method and Description |
---|---|
static void |
GetReadableBuffer.readIntoBuffer(InputStream stream,
ArrowBuf buf,
int size,
boolean fastPath)
Helper method to read a gRPC-provided InputStream into an ArrowBuf.
|
Modifier and Type | Method and Description |
---|---|
static NullableVarCharHolder |
SqlInfoBuilder.getHolderForUtf8(String string,
ArrowBuf buf)
|
Modifier and Type | Field and Description |
---|---|
ArrowBuf |
BufferLedger.TransferResult.buffer |
Modifier and Type | Method and Description |
---|---|
ArrowBuf |
AllocationReservation.allocateBuffer()
Allocate a buffer whose size is the total of all the add()s made.
|
ArrowBuf |
BufferAllocator.buffer(long size)
Allocate a new or reused buffer of the provided size.
|
ArrowBuf |
BufferAllocator.buffer(long size,
BufferManager manager)
Allocate a new or reused buffer of the provided size.
|
ArrowBuf |
ArrowBuf.capacity(long newCapacity)
Adjusts the capacity of this buffer.
|
ArrowBuf |
ArrowBuf.clear() |
ArrowBuf |
BufferLedger.deriveBuffer(ArrowBuf sourceBuffer,
long index,
long length)
Derive a new ArrowBuf from a given source ArrowBuf.
|
ArrowBuf |
ReferenceManager.deriveBuffer(ArrowBuf sourceBuffer,
long index,
long length)
Derive a new ArrowBuf from a given source ArrowBuf.
|
ArrowBuf |
DefaultAllocationManagerFactory.empty() |
ArrowBuf |
AllocationManager.Factory.empty() |
ArrowBuf |
BufferAllocator.getEmpty()
Get a reference to the empty buffer associated with this allocator.
|
ArrowBuf |
BufferManager.getManagedBuffer()
Get a managed buffer of indeterminate size.
|
ArrowBuf |
BufferManager.getManagedBuffer(long size)
Get a managed buffer of at least a certain size.
|
ArrowBuf |
OwnershipTransferNOOP.getTransferredBuffer() |
ArrowBuf |
BufferLedger.TransferResult.getTransferredBuffer() |
ArrowBuf |
OwnershipTransferResult.getTransferredBuffer() |
ArrowBuf |
ArrowBuf.readerIndex(long readerIndex)
Set the reader index for this ArrowBuf.
|
ArrowBuf |
ArrowBuf.reallocIfNeeded(long size)
Returns
this if size is less then capacity() , otherwise
delegates to BufferManager.replace(ArrowBuf, long) to get a new buffer. |
ArrowBuf |
BufferManager.replace(ArrowBuf old,
long newSize)
Replace an old buffer with a new version at least of the provided size.
|
ArrowBuf |
BufferLedger.retain(ArrowBuf srcBuffer,
BufferAllocator target)
Create a new ArrowBuf that is associated with an alternative allocator for the purposes of
memory ownership and accounting.
|
ArrowBuf |
ReferenceManager.retain(ArrowBuf srcBuffer,
BufferAllocator targetAllocator)
Create a new ArrowBuf that is associated with an alternative allocator for the purposes of
memory ownership and accounting.
|
ArrowBuf |
ArrowBuf.setOne(int index,
int length)
Deprecated.
use
setOne(long, long) instead. |
ArrowBuf |
ArrowBuf.setOne(long index,
long length)
Sets all bits to one in the specified range.
|
ArrowBuf |
ArrowBuf.setZero(long index,
long length)
Zero-out the bytes in this ArrowBuf starting at
the given index for the given length.
|
ArrowBuf |
ArrowBuf.slice()
Returns a slice of only the readable bytes in the buffer.
|
ArrowBuf |
ArrowBuf.slice(long index,
long length)
Returns a slice (view) starting at
index with the given length . |
default ArrowBuf |
BufferAllocator.wrapForeignAllocation(ForeignAllocation allocation)
EXPERIMENTAL: Wrap an allocation created outside this BufferAllocator.
|
ArrowBuf |
ArrowBuf.writerIndex(long writerIndex)
Set the writer index for this ArrowBuf.
|
Modifier and Type | Method and Description |
---|---|
ArrowBuf |
BufferLedger.deriveBuffer(ArrowBuf sourceBuffer,
long index,
long length)
Derive a new ArrowBuf from a given source ArrowBuf.
|
ArrowBuf |
ReferenceManager.deriveBuffer(ArrowBuf sourceBuffer,
long index,
long length)
Derive a new ArrowBuf from a given source ArrowBuf.
|
void |
ArrowBuf.getBytes(long index,
ArrowBuf dst,
long dstIndex,
int length)
Copy a given length of data from this ArrowBuf starting at a given index
into a dst ArrowBuf at dstIndex.
|
ArrowBuf |
BufferManager.replace(ArrowBuf old,
long newSize)
Replace an old buffer with a new version at least of the provided size.
|
ArrowBuf |
BufferLedger.retain(ArrowBuf srcBuffer,
BufferAllocator target)
Create a new ArrowBuf that is associated with an alternative allocator for the purposes of
memory ownership and accounting.
|
ArrowBuf |
ReferenceManager.retain(ArrowBuf srcBuffer,
BufferAllocator targetAllocator)
Create a new ArrowBuf that is associated with an alternative allocator for the purposes of
memory ownership and accounting.
|
void |
ArrowBuf.setBytes(long index,
ArrowBuf src)
Copy readableBytes() number of bytes from src ArrowBuf
starting from its readerIndex into this ArrowBuf starting
at the given index.
|
void |
ArrowBuf.setBytes(long index,
ArrowBuf src,
long srcIndex,
long length)
Copy data from src ArrowBuf starting at index srcIndex into this
ArrowBuf at given index.
|
BufferLedger.TransferResult |
BufferLedger.transferOwnership(ArrowBuf srcBuffer,
BufferAllocator target)
Transfer the memory accounting ownership of this ArrowBuf to another allocator.
|
OwnershipTransferResult |
ReferenceManager.transferOwnership(ArrowBuf sourceBuffer,
BufferAllocator targetAllocator)
Duplicate the memory accounting ownership of the backing allocation of the given ArrowBuf in another allocator.
|
Modifier and Type | Method and Description |
---|---|
ArrowBuf |
ArrowBufPointer.getBuf()
Gets the underlying buffer, or null if the underlying data is invalid or null.
|
Modifier and Type | Method and Description |
---|---|
static int |
ByteFunctionHelpers.compare(ArrowBuf left,
int lStart,
int lEnd,
byte[] right,
int rStart,
int rEnd)
Helper function to compare a set of bytes in ArrowBuf to a ByteArray.
|
static int |
ByteFunctionHelpers.compare(ArrowBuf left,
long lStart,
long lEnd,
ArrowBuf right,
long rStart,
long rEnd)
Helper function to compare a set of bytes in two ArrowBufs.
|
static int |
ByteFunctionHelpers.equal(ArrowBuf left,
long lStart,
long lEnd,
ArrowBuf right,
long rStart,
long rEnd)
Helper function to check for equality of bytes in two ArrowBufs.
|
static int |
ByteFunctionHelpers.hash(ArrowBufHasher hasher,
ArrowBuf buf,
long start,
long end)
Compute hashCode with the given
ArrowBufHasher , ArrowBuf and start/end index. |
static int |
ByteFunctionHelpers.hash(ArrowBuf buf,
long start,
long end)
Compute hashCode with the given
ArrowBuf and start/end index. |
void |
ArrowBufPointer.set(ArrowBuf buf,
long offset,
long length)
Sets this pointer.
|
Constructor and Description |
---|
ArrowBufPointer(ArrowBuf buf,
long offset,
long length)
Constructs an Arrow buffer pointer.
|
ArrowBufPointer(ArrowBuf buf,
long offset,
long length,
ArrowBufHasher hasher)
Constructs an Arrow buffer pointer.
|
Modifier and Type | Method and Description |
---|---|
int |
ArrowBufHasher.hashCode(ArrowBuf buf,
long offset,
long length)
Calculates the hash code for a memory region.
|
int |
SimpleHasher.hashCode(ArrowBuf buf,
long offset,
long length)
Calculates the hash code for a memory region.
|
int |
MurmurHasher.hashCode(ArrowBuf buf,
long offset,
long length) |
static int |
MurmurHasher.hashCode(ArrowBuf buf,
long offset,
long length,
int seed)
Calculates the hash code for a memory region.
|
Modifier and Type | Field and Description |
---|---|
protected ArrowBuf |
BaseLargeVariableWidthVector.offsetBuffer |
protected ArrowBuf |
BaseVariableWidthVector.offsetBuffer |
protected ArrowBuf |
BaseLargeVariableWidthVector.validityBuffer |
protected ArrowBuf |
BaseVariableWidthVector.validityBuffer |
protected ArrowBuf |
BaseFixedWidthVector.validityBuffer |
protected ArrowBuf |
BaseLargeVariableWidthVector.valueBuffer |
protected ArrowBuf |
BaseVariableWidthVector.valueBuffer |
protected ArrowBuf |
BaseFixedWidthVector.valueBuffer |
Modifier and Type | Method and Description |
---|---|
ArrowBuf |
IntervalMonthDayNanoVector.get(int index)
Get the element at the given index from the vector.
|
ArrowBuf |
IntervalDayVector.get(int index)
Get the element at the given index from the vector.
|
ArrowBuf |
Decimal256Vector.get(int index)
Get the element at the given index from the vector.
|
ArrowBuf |
DurationVector.get(int index)
Get the element at the given index from the vector.
|
ArrowBuf |
DecimalVector.get(int index)
Get the element at the given index from the vector.
|
ArrowBuf[] |
NullVector.getBuffers(boolean clear) |
ArrowBuf[] |
BaseLargeVariableWidthVector.getBuffers(boolean clear)
Return the underlying buffers associated with this vector.
|
ArrowBuf[] |
BaseVariableWidthVector.getBuffers(boolean clear)
Return the underlying buffers associated with this vector.
|
ArrowBuf[] |
ValueVector.getBuffers(boolean clear)
Return the underlying buffers associated with this vector.
|
ArrowBuf[] |
ExtensionTypeVector.getBuffers(boolean clear) |
ArrowBuf[] |
BaseFixedWidthVector.getBuffers(boolean clear)
Return the underlying buffers associated with this vector.
|
ArrowBuf |
NullVector.getDataBuffer() |
ArrowBuf |
BaseLargeVariableWidthVector.getDataBuffer()
Get the buffer that stores the data for elements in the vector.
|
ArrowBuf |
BaseVariableWidthVector.getDataBuffer()
Get the buffer that stores the data for elements in the vector.
|
ArrowBuf |
ValueVector.getDataBuffer()
Gets the underlying buffer associated with data vector.
|
ArrowBuf |
ExtensionTypeVector.getDataBuffer() |
ArrowBuf |
BaseFixedWidthVector.getDataBuffer()
Get the buffer that stores the data for elements in the vector.
|
ArrowBuf |
NullVector.getOffsetBuffer() |
ArrowBuf |
BaseLargeVariableWidthVector.getOffsetBuffer()
buffer that stores the offsets for elements
in the vector.
|
ArrowBuf |
BaseVariableWidthVector.getOffsetBuffer()
buffer that stores the offsets for elements
in the vector.
|
ArrowBuf |
ValueVector.getOffsetBuffer()
Gets the underlying buffer associated with offset vector.
|
ArrowBuf |
ExtensionTypeVector.getOffsetBuffer() |
ArrowBuf |
BaseFixedWidthVector.getOffsetBuffer()
buffer that stores the offsets for elements
in the vector.
|
ArrowBuf |
NullVector.getValidityBuffer() |
ArrowBuf |
BaseLargeVariableWidthVector.getValidityBuffer()
Get buffer that manages the validity (NULL or NON-NULL nature) of
elements in the vector.
|
ArrowBuf |
BaseVariableWidthVector.getValidityBuffer()
Get buffer that manages the validity (NULL or NON-NULL nature) of
elements in the vector.
|
ArrowBuf |
ValueVector.getValidityBuffer()
Gets the underlying buffer associated with validity vector.
|
ArrowBuf |
ExtensionTypeVector.getValidityBuffer() |
ArrowBuf |
BaseFixedWidthVector.getValidityBuffer()
Get buffer that manages the validity (NULL or NON-NULL nature) of
elements in the vector.
|
static ArrowBuf |
BitVectorHelper.loadValidityBuffer(ArrowFieldNode fieldNode,
ArrowBuf sourceValidityBuffer,
BufferAllocator allocator)
Returns a new buffer if the source validity buffer is either all null or all
not-null, otherwise returns a buffer pointing to the same memory as source.
|
protected ArrowBuf |
BaseValueVector.releaseBuffer(ArrowBuf buffer) |
static ArrowBuf |
BaseVariableWidthVector.set(ArrowBuf buffer,
BufferAllocator allocator,
int valueCount,
int index,
int value)
Method used by Json Reader to explicitly set the offsets of the variable
width vector data.
|
static ArrowBuf |
BaseLargeVariableWidthVector.set(ArrowBuf buffer,
BufferAllocator allocator,
int valueCount,
int index,
long value)
Method used by Json Reader to explicitly set the offsets of the variable
width vector data.
|
static ArrowBuf |
BitVectorHelper.setValidityBit(ArrowBuf validityBuffer,
BufferAllocator allocator,
int valueCount,
int index,
int value)
Set the bit at a given index to provided value (1 or 0).
|
static ArrowBuf |
BaseValueVector.transferBuffer(ArrowBuf srcBuffer,
BufferAllocator targetAllocator) |
ArrowBuf |
BufferBacked.unLoad() |
Modifier and Type | Method and Description |
---|---|
List<ArrowBuf> |
NullVector.getFieldBuffers() |
List<ArrowBuf> |
BaseLargeVariableWidthVector.getFieldBuffers()
Get the buffers belonging to this vector.
|
List<ArrowBuf> |
BaseVariableWidthVector.getFieldBuffers()
Get the buffers belonging to this vector.
|
List<ArrowBuf> |
ExtensionTypeVector.getFieldBuffers() |
List<ArrowBuf> |
BaseFixedWidthVector.getFieldBuffers()
Get the buffers belonging to this vector.
|
List<ArrowBuf> |
FieldVector.getFieldBuffers()
Get the buffers of the fields, (same size as getFieldVectors() since it is their content).
|
Modifier and Type | Method and Description |
---|---|
static boolean |
BitVectorHelper.checkAllBitsEqualTo(ArrowBuf validityBuffer,
int valueCount,
boolean checkOneBits)
Tests if all bits in a validity buffer are equal 0 or 1, according to the specified parameter.
|
static void |
BitVectorHelper.concatBits(ArrowBuf input1,
int numBits1,
ArrowBuf input2,
int numBits2,
ArrowBuf output)
Concat two validity buffers.
|
static byte[] |
BaseLargeVariableWidthVector.get(ArrowBuf data,
ArrowBuf offset,
int index)
Method used by Json Writer to read a variable width element from
the variable width vector and write to Json.
|
static byte[] |
BaseVariableWidthVector.get(ArrowBuf data,
ArrowBuf offset,
int index)
Method used by Json Writer to read a variable width element from
the variable width vector and write to Json.
|
static int |
TimeMilliVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static int |
TimeSecVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static long |
DateMilliVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static byte |
TinyIntVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static int |
DateDayVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static short |
SmallIntVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static int |
BitVectorHelper.get(ArrowBuf buffer,
int index)
Check if a bit at a given index is set or not.
|
static double |
Float8Vector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static int |
IntVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static long |
BigIntVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static long |
DurationVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static long |
TimeStampVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static long |
TimeNanoVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static long |
TimeMicroVector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static char |
UInt2Vector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static float |
Float4Vector.get(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static byte[] |
FixedSizeBinaryVector.get(ArrowBuf buffer,
int index,
int byteWidth)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static byte |
BitVectorHelper.getBitsFromCurrentByte(ArrowBuf data,
int index,
int offset)
Returns the byte at index from data right-shifted by offset.
|
static byte |
BitVectorHelper.getBitsFromNextByte(ArrowBuf data,
int index,
int offset)
Returns the byte at
index from left-shifted by (8 - offset ). |
static int |
IntervalMonthDayNanoVector.getDays(ArrowBuf buffer,
int index)
Given a data buffer, get the number of days stored at a particular position
in the vector.
|
static int |
IntervalDayVector.getDays(ArrowBuf buffer,
int index)
Given a data buffer, get the number of days stored at a particular position
in the vector.
|
static int |
IntervalDayVector.getMilliseconds(ArrowBuf buffer,
int index)
Given a data buffer, get the get the number of milliseconds stored at a particular position
in the vector.
|
static int |
IntervalMonthDayNanoVector.getMonths(ArrowBuf buffer,
int index)
Given a data buffer, get the number of months stored at a particular position
in the vector.
|
static long |
IntervalMonthDayNanoVector.getNanoseconds(ArrowBuf buffer,
int index)
Given a data buffer, get the get the number of nanoseconds stored at a particular position
in the vector.
|
static BigInteger |
UInt8Vector.getNoOverflow(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static long |
UInt4Vector.getNoOverflow(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static short |
UInt1Vector.getNoOverflow(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
static int |
BitVectorHelper.getNullCount(ArrowBuf validityBuffer,
int valueCount)
Given a validity buffer, find the number of bits that are not set.
|
static int |
IntervalYearVector.getTotalMonths(ArrowBuf buffer,
int index)
Given a data buffer, get the value stored at a particular position
in the vector.
|
void |
BufferBacked.load(ArrowFieldNode fieldNode,
ArrowBuf data) |
static ArrowBuf |
BitVectorHelper.loadValidityBuffer(ArrowFieldNode fieldNode,
ArrowBuf sourceValidityBuffer,
BufferAllocator allocator)
Returns a new buffer if the source validity buffer is either all null or all
not-null, otherwise returns a buffer pointing to the same memory as source.
|
protected ArrowBuf |
BaseValueVector.releaseBuffer(ArrowBuf buffer) |
static ArrowBuf |
BaseVariableWidthVector.set(ArrowBuf buffer,
BufferAllocator allocator,
int valueCount,
int index,
int value)
Method used by Json Reader to explicitly set the offsets of the variable
width vector data.
|
static ArrowBuf |
BaseLargeVariableWidthVector.set(ArrowBuf buffer,
BufferAllocator allocator,
int valueCount,
int index,
long value)
Method used by Json Reader to explicitly set the offsets of the variable
width vector data.
|
void |
IntervalMonthDayNanoVector.set(int index,
ArrowBuf value)
Set the element at the given index to the given value.
|
void |
IntervalDayVector.set(int index,
ArrowBuf value)
Set the element at the given index to the given value.
|
void |
Decimal256Vector.set(int index,
ArrowBuf buffer)
Set the element at the given index to the given value.
|
void |
DurationVector.set(int index,
ArrowBuf value)
Set the element at the given index to the given value.
|
void |
DecimalVector.set(int index,
ArrowBuf buffer)
Set the element at the given index to the given value.
|
void |
FixedSizeBinaryVector.set(int index,
ArrowBuf buffer)
Set the element at the given index to the given value.
|
void |
FixedSizeBinaryVector.set(int index,
int isSet,
ArrowBuf buffer)
Set the element at the given index to the given value.
|
void |
BaseVariableWidthVector.set(int index,
int start,
int length,
ArrowBuf buffer)
Store the given value at a particular position in the vector.
|
void |
BaseVariableWidthVector.set(int index,
int isSet,
int start,
int end,
ArrowBuf buffer)
Store the given value at a particular position in the vector.
|
void |
Decimal256Vector.set(int index,
int isSet,
long start,
ArrowBuf buffer)
Store the given value at a particular position in the vector.
|
void |
DecimalVector.set(int index,
int isSet,
long start,
ArrowBuf buffer)
Store the given value at a particular position in the vector.
|
void |
BaseLargeVariableWidthVector.set(int index,
int isSet,
long start,
long end,
ArrowBuf buffer)
Store the given value at a particular position in the vector.
|
void |
Decimal256Vector.set(int index,
long start,
ArrowBuf buffer)
Set the element at the given index to the given value.
|
void |
DecimalVector.set(int index,
long start,
ArrowBuf buffer)
Set the element at the given index to the given value.
|
void |
BaseLargeVariableWidthVector.set(int index,
long start,
int length,
ArrowBuf buffer)
Store the given value at a particular position in the vector.
|
void |
Decimal256Vector.setBigEndianSafe(int index,
long start,
ArrowBuf buffer,
int length)
Sets the element at given index using the buffer whose size maybe <= 32 bytes.
|
void |
DecimalVector.setBigEndianSafe(int index,
long start,
ArrowBuf buffer,
int length)
Sets the element at given index using the buffer whose size maybe <= 16 bytes.
|
static void |
BitVectorHelper.setBit(ArrowBuf validityBuffer,
long index)
Set the bit at provided index to 1.
|
void |
IntervalMonthDayNanoVector.setSafe(int index,
ArrowBuf value)
Same as
IntervalMonthDayNanoVector.set(int, ArrowBuf) except that it handles the
case when index is greater than or equal to existing
value capacity BaseFixedWidthVector.getValueCapacity() . |
void |
IntervalDayVector.setSafe(int index,
ArrowBuf value)
Same as
IntervalDayVector.set(int, ArrowBuf) except that it handles the
case when index is greater than or equal to existing
value capacity BaseFixedWidthVector.getValueCapacity() . |
void |
Decimal256Vector.setSafe(int index,
ArrowBuf buffer)
Same as
Decimal256Vector.set(int, ArrowBuf) except that it handles the
case when index is greater than or equal to existing
value capacity BaseFixedWidthVector.getValueCapacity() . |
void |
DurationVector.setSafe(int index,
ArrowBuf value)
Same as
DurationVector.set(int, ArrowBuf) except that it handles the
case when index is greater than or equal to existing
value capacity BaseFixedWidthVector.getValueCapacity() . |
void |
DecimalVector.setSafe(int index,
ArrowBuf buffer)
Same as
DecimalVector.set(int, ArrowBuf) except that it handles the
case when index is greater than or equal to existing
value capacity BaseFixedWidthVector.getValueCapacity() . |
void |
FixedSizeBinaryVector.setSafe(int index,
ArrowBuf buffer)
Same as
FixedSizeBinaryVector.set(int, ArrowBuf) except that it handles the
case when index is greater than or equal to existing
value capacity BaseFixedWidthVector.getValueCapacity() . |
void |
FixedSizeBinaryVector.setSafe(int index,
int isSet,
ArrowBuf buffer)
Same as
FixedSizeBinaryVector.set(int, ArrowBuf) except that it handles the
case when index is greater than or equal to existing
value capacity BaseFixedWidthVector.getValueCapacity() . |
void |
BaseVariableWidthVector.setSafe(int index,
int start,
int length,
ArrowBuf buffer)
Same as
BaseVariableWidthVector.set(int, int, int, int, ArrowBuf) except that it handles the case
when index is greater than or equal to current value capacity of the
vector. |
void |
BaseVariableWidthVector.setSafe(int index,
int isSet,
int start,
int end,
ArrowBuf buffer)
Same as
BaseVariableWidthVector.set(int, int, int, int, ArrowBuf) except that it handles the case
when index is greater than or equal to current value capacity of the
vector. |
void |
Decimal256Vector.setSafe(int index,
int isSet,
long start,
ArrowBuf buffer)
Same as
#setSafe(int, int, int, ArrowBuf) except that it handles
the case when the position of new value is beyond the current value
capacity of the vector. |
void |
DecimalVector.setSafe(int index,
int isSet,
long start,
ArrowBuf buffer)
Same as
DecimalVector.set(int, int, long, ArrowBuf) except that it handles
the case when the position of new value is beyond the current value
capacity of the vector. |
void |
BaseLargeVariableWidthVector.setSafe(int index,
int isSet,
long start,
long end,
ArrowBuf buffer)
Same as
BaseLargeVariableWidthVector.set(int, int, long, long, ArrowBuf) except that it handles the case
when index is greater than or equal to current value capacity of the
vector. |
void |
Decimal256Vector.setSafe(int index,
long start,
ArrowBuf buffer)
Same as
#set(int, int, ArrowBuf) except that it handles the
case when index is greater than or equal to existing
value capacity BaseFixedWidthVector.getValueCapacity() . |
void |
DecimalVector.setSafe(int index,
long start,
ArrowBuf buffer)
Same as
DecimalVector.set(int, long, ArrowBuf) except that it handles the
case when index is greater than or equal to existing
value capacity BaseFixedWidthVector.getValueCapacity() . |
void |
Decimal256Vector.setSafe(int index,
long start,
ArrowBuf buffer,
int length)
Sets the element at given index using the buffer whose size maybe <= 32 bytes.
|
void |
DecimalVector.setSafe(int index,
long start,
ArrowBuf buffer,
int length)
Sets the element at given index using the buffer whose size maybe <= 16 bytes.
|
void |
BaseLargeVariableWidthVector.setSafe(int index,
long start,
int length,
ArrowBuf buffer)
Same as
BaseLargeVariableWidthVector.set(int, int, long, long, ArrowBuf) except that it handles the case
when index is greater than or equal to current value capacity of the
vector. |
static ArrowBuf |
BitVectorHelper.setValidityBit(ArrowBuf validityBuffer,
BufferAllocator allocator,
int valueCount,
int index,
int value)
Set the bit at a given index to provided value (1 or 0).
|
static void |
BitVectorHelper.setValidityBit(ArrowBuf validityBuffer,
int index,
int value)
Set the bit at a given index to provided value (1 or 0).
|
static ArrowBuf |
BaseValueVector.transferBuffer(ArrowBuf srcBuffer,
BufferAllocator targetAllocator) |
static void |
BitVectorHelper.unsetBit(ArrowBuf validityBuffer,
int index)
Set the bit at provided index to 0.
|
Modifier and Type | Method and Description |
---|---|
void |
NullVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers) |
void |
BaseLargeVariableWidthVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers)
Load the buffers of this vector with provided source buffers.
|
void |
BaseVariableWidthVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers)
Load the buffers of this vector with provided source buffers.
|
void |
ExtensionTypeVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers) |
void |
BaseFixedWidthVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers)
Load the buffers of this vector with provided source buffers.
|
void |
FieldVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers)
Loads data in the vectors.
|
Modifier and Type | Field and Description |
---|---|
protected ArrowBuf |
BaseRepeatedValueVector.offsetBuffer |
protected ArrowBuf |
LargeListVector.offsetBuffer |
protected ArrowBuf |
UnionVector.typeBuffer |
protected ArrowBuf |
StructVector.validityBuffer |
protected ArrowBuf |
LargeListVector.validityBuffer |
protected ArrowBuf |
ListVector.validityBuffer |
Modifier and Type | Method and Description |
---|---|
ArrowBuf[] |
UnionVector.getBuffers(boolean clear) |
ArrowBuf[] |
BaseRepeatedValueVector.getBuffers(boolean clear) |
ArrowBuf[] |
StructVector.getBuffers(boolean clear)
Return the underlying buffers associated with this vector.
|
ArrowBuf[] |
LargeListVector.getBuffers(boolean clear)
Return the underlying buffers associated with this vector.
|
ArrowBuf[] |
FixedSizeListVector.getBuffers(boolean clear) |
ArrowBuf[] |
ListVector.getBuffers(boolean clear)
Return the underlying buffers associated with this vector.
|
ArrowBuf[] |
AbstractStructVector.getBuffers(boolean clear) |
ArrowBuf[] |
DenseUnionVector.getBuffers(boolean clear) |
ArrowBuf |
UnionVector.getDataBuffer() |
ArrowBuf |
NonNullableStructVector.getDataBuffer() |
ArrowBuf |
StructVector.getDataBuffer() |
ArrowBuf |
LargeListVector.getDataBuffer() |
ArrowBuf |
FixedSizeListVector.getDataBuffer() |
ArrowBuf |
ListVector.getDataBuffer() |
ArrowBuf |
DenseUnionVector.getDataBuffer() |
ArrowBuf |
UnionVector.getOffsetBuffer() |
ArrowBuf |
NonNullableStructVector.getOffsetBuffer() |
ArrowBuf |
StructVector.getOffsetBuffer() |
ArrowBuf |
LargeListVector.getOffsetBuffer() |
ArrowBuf |
FixedSizeListVector.getOffsetBuffer() |
ArrowBuf |
ListVector.getOffsetBuffer() |
ArrowBuf |
DenseUnionVector.getOffsetBuffer() |
ArrowBuf |
UnionVector.getTypeBuffer() |
ArrowBuf |
DenseUnionVector.getTypeBuffer() |
ArrowBuf |
UnionVector.getValidityBuffer() |
ArrowBuf |
NonNullableStructVector.getValidityBuffer() |
ArrowBuf |
StructVector.getValidityBuffer() |
ArrowBuf |
LargeListVector.getValidityBuffer() |
ArrowBuf |
FixedSizeListVector.getValidityBuffer() |
ArrowBuf |
ListVector.getValidityBuffer() |
ArrowBuf |
DenseUnionVector.getValidityBuffer() |
Modifier and Type | Method and Description |
---|---|
List<ArrowBuf> |
UnionVector.getFieldBuffers() |
List<ArrowBuf> |
StructVector.getFieldBuffers() |
List<ArrowBuf> |
LargeListVector.getFieldBuffers()
Get the buffers belonging to this vector.
|
List<ArrowBuf> |
FixedSizeListVector.getFieldBuffers() |
List<ArrowBuf> |
ListVector.getFieldBuffers()
Get the buffers belonging to this vector.
|
List<ArrowBuf> |
DenseUnionVector.getFieldBuffers() |
Modifier and Type | Method and Description |
---|---|
void |
UnionVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers) |
void |
StructVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers) |
void |
LargeListVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers)
Load the buffers of this vector with provided source buffers.
|
void |
FixedSizeListVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers) |
void |
ListVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers)
Load the buffers of this vector with provided source buffers.
|
void |
DenseUnionVector.loadFieldBuffers(ArrowFieldNode fieldNode,
List<ArrowBuf> ownBuffers) |
Modifier and Type | Method and Description |
---|---|
void |
UnionLargeListWriter.writeDecimal(long start,
ArrowBuf buffer) |
void |
DecimalWriterImpl.writeDecimal(long start,
ArrowBuf buffer) |
void |
UnionListWriter.writeDecimal(long start,
ArrowBuf buffer) |
void |
PromotableWriter.writeDecimal(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
UnionLargeListWriter.writeDecimal(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
DecimalWriterImpl.writeDecimal(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
UnionWriter.writeDecimal(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
UnionFixedSizeListWriter.writeDecimal(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
UnionListWriter.writeDecimal(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
DenseUnionWriter.writeDecimal(long start,
ArrowBuf buffer,
byte typeId,
ArrowType arrowType) |
void |
Decimal256WriterImpl.writeDecimal256(long start,
ArrowBuf buffer) |
void |
UnionLargeListWriter.writeDecimal256(long start,
ArrowBuf buffer) |
void |
UnionListWriter.writeDecimal256(long start,
ArrowBuf buffer) |
void |
PromotableWriter.writeDecimal256(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
Decimal256WriterImpl.writeDecimal256(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
UnionLargeListWriter.writeDecimal256(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
UnionWriter.writeDecimal256(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
UnionFixedSizeListWriter.writeDecimal256(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
UnionListWriter.writeDecimal256(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
DenseUnionWriter.writeDecimal256(long start,
ArrowBuf buffer,
byte typeId,
ArrowType arrowType) |
void |
FixedSizeBinaryWriterImpl.writeFixedSizeBinary(ArrowBuf buffer) |
void |
UnionLargeListWriter.writeFixedSizeBinary(ArrowBuf buffer) |
void |
UnionWriter.writeFixedSizeBinary(ArrowBuf buffer) |
void |
UnionListWriter.writeFixedSizeBinary(ArrowBuf buffer) |
void |
UnionLargeListWriter.writeLargeVarBinary(long start,
long end,
ArrowBuf buffer) |
void |
UnionWriter.writeLargeVarBinary(long start,
long end,
ArrowBuf buffer) |
void |
UnionFixedSizeListWriter.writeLargeVarBinary(long start,
long end,
ArrowBuf buffer) |
void |
LargeVarBinaryWriterImpl.writeLargeVarBinary(long start,
long end,
ArrowBuf buffer) |
void |
UnionListWriter.writeLargeVarBinary(long start,
long end,
ArrowBuf buffer) |
void |
DenseUnionWriter.writeLargeVarBinary(long start,
long end,
ArrowBuf buffer,
byte typeId) |
void |
UnionLargeListWriter.writeLargeVarChar(long start,
long end,
ArrowBuf buffer) |
void |
LargeVarCharWriterImpl.writeLargeVarChar(long start,
long end,
ArrowBuf buffer) |
void |
UnionWriter.writeLargeVarChar(long start,
long end,
ArrowBuf buffer) |
void |
UnionFixedSizeListWriter.writeLargeVarChar(long start,
long end,
ArrowBuf buffer) |
void |
UnionListWriter.writeLargeVarChar(long start,
long end,
ArrowBuf buffer) |
void |
DenseUnionWriter.writeLargeVarChar(long start,
long end,
ArrowBuf buffer,
byte typeId) |
void |
VarBinaryWriterImpl.writeVarBinary(int start,
int end,
ArrowBuf buffer) |
void |
UnionLargeListWriter.writeVarBinary(int start,
int end,
ArrowBuf buffer) |
void |
UnionWriter.writeVarBinary(int start,
int end,
ArrowBuf buffer) |
void |
UnionFixedSizeListWriter.writeVarBinary(int start,
int end,
ArrowBuf buffer) |
void |
UnionListWriter.writeVarBinary(int start,
int end,
ArrowBuf buffer) |
void |
DenseUnionWriter.writeVarBinary(int start,
int end,
ArrowBuf buffer,
byte typeId) |
void |
VarCharWriterImpl.writeVarChar(int start,
int end,
ArrowBuf buffer) |
void |
UnionLargeListWriter.writeVarChar(int start,
int end,
ArrowBuf buffer) |
void |
UnionWriter.writeVarChar(int start,
int end,
ArrowBuf buffer) |
void |
UnionFixedSizeListWriter.writeVarChar(int start,
int end,
ArrowBuf buffer) |
void |
UnionListWriter.writeVarChar(int start,
int end,
ArrowBuf buffer) |
void |
DenseUnionWriter.writeVarChar(int start,
int end,
ArrowBuf buffer,
byte typeId) |
Modifier and Type | Method and Description |
---|---|
void |
DecimalWriter.writeDecimal(long start,
ArrowBuf buffer)
Deprecated.
The holder version should be used instead because the plain value version does not contain enough information
to fully specify this field type.
|
void |
DecimalWriter.writeDecimal(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
Decimal256Writer.writeDecimal256(long start,
ArrowBuf buffer)
Deprecated.
The holder version should be used instead because the plain value version does not contain enough information
to fully specify this field type.
|
void |
Decimal256Writer.writeDecimal256(long start,
ArrowBuf buffer,
ArrowType arrowType) |
void |
FixedSizeBinaryWriter.writeFixedSizeBinary(ArrowBuf buffer)
Deprecated.
The holder version should be used instead because the plain value version does not contain enough information
to fully specify this field type.
|
void |
LargeVarBinaryWriter.writeLargeVarBinary(long start,
long end,
ArrowBuf buffer) |
void |
LargeVarCharWriter.writeLargeVarChar(long start,
long end,
ArrowBuf buffer) |
void |
VarBinaryWriter.writeVarBinary(int start,
int end,
ArrowBuf buffer) |
void |
VarCharWriter.writeVarChar(int start,
int end,
ArrowBuf buffer) |
Modifier and Type | Method and Description |
---|---|
ArrowBuf |
CompressionCodec.compress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer)
Compress a buffer.
|
ArrowBuf |
NoCompressionCodec.compress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
ArrowBuf |
AbstractCompressionCodec.compress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
ArrowBuf |
CompressionCodec.decompress(BufferAllocator allocator,
ArrowBuf compressedBuffer)
Decompress a buffer.
|
ArrowBuf |
NoCompressionCodec.decompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
ArrowBuf |
AbstractCompressionCodec.decompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
protected abstract ArrowBuf |
AbstractCompressionCodec.doCompress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer)
The method that actually performs the data compression.
|
protected abstract ArrowBuf |
AbstractCompressionCodec.doDecompress(BufferAllocator allocator,
ArrowBuf compressedBuffer)
The method that actually performs the data decompression.
|
static ArrowBuf |
CompressionUtil.extractUncompressedBuffer(ArrowBuf inputBuffer)
Process decompression by slicing the buffer that contains the uncompressed bytes.
|
static ArrowBuf |
CompressionUtil.packageRawBuffer(BufferAllocator allocator,
ArrowBuf inputBuffer)
Process compression by compressing the buffer as is.
|
Modifier and Type | Method and Description |
---|---|
ArrowBuf |
CompressionCodec.compress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer)
Compress a buffer.
|
ArrowBuf |
NoCompressionCodec.compress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
ArrowBuf |
AbstractCompressionCodec.compress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
ArrowBuf |
CompressionCodec.decompress(BufferAllocator allocator,
ArrowBuf compressedBuffer)
Decompress a buffer.
|
ArrowBuf |
NoCompressionCodec.decompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
ArrowBuf |
AbstractCompressionCodec.decompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
protected abstract ArrowBuf |
AbstractCompressionCodec.doCompress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer)
The method that actually performs the data compression.
|
protected abstract ArrowBuf |
AbstractCompressionCodec.doDecompress(BufferAllocator allocator,
ArrowBuf compressedBuffer)
The method that actually performs the data decompression.
|
static ArrowBuf |
CompressionUtil.extractUncompressedBuffer(ArrowBuf inputBuffer)
Process decompression by slicing the buffer that contains the uncompressed bytes.
|
static ArrowBuf |
CompressionUtil.packageRawBuffer(BufferAllocator allocator,
ArrowBuf inputBuffer)
Process compression by compressing the buffer as is.
|
protected long |
AbstractCompressionCodec.readUncompressedLength(ArrowBuf compressedBuffer) |
protected void |
AbstractCompressionCodec.writeUncompressedLength(ArrowBuf compressedBuffer,
long uncompressedLength) |
Modifier and Type | Field and Description |
---|---|
ArrowBuf |
NullableVarCharHolder.buffer |
ArrowBuf |
Decimal256Holder.buffer |
ArrowBuf |
VarCharHolder.buffer |
ArrowBuf |
FixedSizeBinaryHolder.buffer |
ArrowBuf |
LargeVarCharHolder.buffer |
ArrowBuf |
DecimalHolder.buffer |
ArrowBuf |
NullableLargeVarBinaryHolder.buffer |
ArrowBuf |
NullableLargeVarCharHolder.buffer |
ArrowBuf |
NullableFixedSizeBinaryHolder.buffer |
ArrowBuf |
VarBinaryHolder.buffer |
ArrowBuf |
NullableDecimal256Holder.buffer |
ArrowBuf |
NullableDecimalHolder.buffer |
ArrowBuf |
LargeVarBinaryHolder.buffer |
ArrowBuf |
NullableVarBinaryHolder.buffer |
Modifier and Type | Method and Description |
---|---|
long |
ReadChannel.readFully(ArrowBuf buffer,
long length)
Reads up to len into buffer.
|
void |
WriteChannel.write(ArrowBuf buffer)
Writes the buffer to the underlying channel.
|
Modifier and Type | Method and Description |
---|---|
ArrowBuf |
MessageResult.getBodyBuffer()
Get the message body data.
|
static ArrowBuf |
MessageSerializer.readMessageBody(ReadChannel in,
long bodyLength,
BufferAllocator allocator)
Read a Message body from the in channel into an ArrowBuf.
|
Modifier and Type | Method and Description |
---|---|
List<ArrowBuf> |
ArrowRecordBatch.getBuffers()
Get the record batch buffers.
|
Modifier and Type | Method and Description |
---|---|
static ArrowDictionaryBatch |
MessageSerializer.deserializeDictionaryBatch(Message message,
ArrowBuf bodyBuffer)
Deserializes an ArrowDictionaryBatch from a dictionary batch Message and data in an ArrowBuf.
|
static ArrowDictionaryBatch |
MessageSerializer.deserializeDictionaryBatch(MessageMetadataResult message,
ArrowBuf bodyBuffer)
Deserializes an ArrowDictionaryBatch from a dictionary batch Message and data in an ArrowBuf.
|
static ArrowRecordBatch |
MessageSerializer.deserializeRecordBatch(Message recordBatchMessage,
ArrowBuf bodyBuffer)
Deserializes an ArrowRecordBatch from a record batch message and data in an ArrowBuf.
|
static ArrowRecordBatch |
MessageSerializer.deserializeRecordBatch(MessageMetadataResult serializedMessage,
ArrowBuf underlying)
Reads a record batch based on the metadata in serializedMessage and the underlying data buffer.
|
static ArrowRecordBatch |
MessageSerializer.deserializeRecordBatch(RecordBatch recordBatchFB,
ArrowBuf body)
Deserializes an ArrowRecordBatch given the Flatbuffer metadata and in-memory body.
|
Constructor and Description |
---|
ArrowRecordBatch(int length,
List<ArrowFieldNode> nodes,
List<ArrowBuf> buffers) |
ArrowRecordBatch(int length,
List<ArrowFieldNode> nodes,
List<ArrowBuf> buffers,
ArrowBodyCompression bodyCompression) |
ArrowRecordBatch(int length,
List<ArrowFieldNode> nodes,
List<ArrowBuf> buffers,
ArrowBodyCompression bodyCompression,
boolean alignBuffers)
Construct a record batch from nodes.
|
ArrowRecordBatch(int length,
List<ArrowFieldNode> nodes,
List<ArrowBuf> buffers,
ArrowBodyCompression bodyCompression,
boolean alignBuffers,
boolean retainBuffers)
Construct a record batch from nodes.
|
Modifier and Type | Method and Description |
---|---|
ArrowBuf |
Row.getDecimal(int columnIndex)
Returns an ArrowBuf from the column with the given index at the current row.
|
ArrowBuf |
Row.getDecimal(String columnName)
Returns an ArrowBuf from the column of the given name at the current row.
|
ArrowBuf |
Row.getDuration(int columnIndex)
Returns an ArrowBuf from the column with the given index at the current row.
|
ArrowBuf |
Row.getDuration(String columnName)
Returns an ArrowBuf from the column of the given name at the current row.
|
ArrowBuf |
Row.getIntervalDay(int columnIndex)
Returns an ArrowBuf from the column with the given index at the current row.
|
ArrowBuf |
Row.getIntervalDay(String columnName)
Returns an ArrowBuf from the column of the given name at the current row.
|
ArrowBuf |
Row.getIntervalMonthDayNano(int columnIndex)
Returns an ArrowBuf from the column with the given index at the current row.
|
ArrowBuf |
Row.getIntervalMonthDayNano(String columnName)
Returns an ArrowBuf from the column of the given name at the current row.
|
Modifier and Type | Method and Description |
---|---|
static BigDecimal |
DecimalUtility.getBigDecimalFromArrowBuf(ArrowBuf bytebuf,
int index,
int scale,
int byteWidth)
Read an ArrowType.Decimal at the given value index in the ArrowBuf and convert to a BigDecimal
with the given scale.
|
static byte[] |
DecimalUtility.getByteArrayFromArrowBuf(ArrowBuf bytebuf,
int index,
int byteWidth)
Read an ArrowType.Decimal from the ArrowBuf at the given value index and return it as a byte
array.
|
static void |
DecimalUtility.writeBigDecimalToArrowBuf(BigDecimal value,
ArrowBuf bytebuf,
int index,
int byteWidth)
Write the given BigDecimal to the ArrowBuf at the given value index.
|
static void |
DecimalUtility.writeByteArrayToArrowBuf(byte[] bytes,
ArrowBuf bytebuf,
int index,
int byteWidth)
Write the given byte array to the ArrowBuf at the given value index.
|
static void |
DecimalUtility.writeLongToArrowBuf(long value,
ArrowBuf bytebuf,
int index,
int byteWidth)
Write the given long to the ArrowBuf at the given value index.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.