xtdb-api/xtdb.arrow.extensions/KeywordVector

KeywordVector

class KeywordVector(name: String, allocator: BufferAllocator, fieldType: FieldType) : XtExtensionVector<VarCharVector>

Constructors

KeywordVector

constructor(name: String, allocator: BufferAllocator, fieldType: FieldType)

Properties

allocator

open override val allocator: BufferAllocator?

bufferSize

open override val bufferSize: Int

childrenFromFields

open override val childrenFromFields: List<FieldVector?>?

dataBuffer

open override val dataBuffer: ArrowBuf?

dataBufferAddress

open override val dataBufferAddress: Long

exportedCDataBufferCount

open val exportedCDataBufferCount: Int

field

open override val field: Field

fieldBuffers

open override val fieldBuffers: List<ArrowBuf?>?

fieldInnerVectors

open override val fieldInnerVectors: List<BufferBacked?>?

minorType

open override val minorType: Types.MinorType?

name

open override val name: String?

nullCount

open override val nullCount: Int

offsetBuffer

open override val offsetBuffer: ArrowBuf?

offsetBufferAddress

open override val offsetBufferAddress: Long

reader

open override val reader: FieldReader?

underlyingVector

open override val underlyingVector: VarCharVector?

validityBuffer

open override val validityBuffer: ArrowBuf?

validityBufferAddress

open override val validityBufferAddress: Long

valueCapacity

open override val valueCapacity: Int

valueCount

open override var valueCount: Int

Functions

open fun <OUT : Any?, IN : Any?> accept(visitor: VectorVisitor<OUT?, IN?>?, value: IN?): OUT?

allocateNew

open fun allocateNew()

allocateNewSafe

open fun allocateNewSafe(): Boolean

clear

open fun clear()

open fun close()

copyFrom

open fun copyFrom(fromIndex: Int, thisIndex: Int, from: ValueVector?)

copyFromSafe

open override fun copyFromSafe(fromIndex: Int, thisIndex: Int, from: ValueVector)

exportBuffer

open fun exportBuffer(buffer: ArrowBuf?, buffers: List<ArrowBuf?>?, buffersPtr: ArrowBuf?, nullValue: Long, retain: Boolean)

exportCDataBuffers

open fun exportCDataBuffers(buffers: List<ArrowBuf?>?, buffersPtr: ArrowBuf?, nullValue: Long)

getBuffers

open fun getBuffers(clear: Boolean): Array<out ArrowBuf?>?

getBufferSizeFor

open fun getBufferSizeFor(valueCount: Int): Int

getField

open override fun getField(): Field

getObject

open override fun getObject(index: Int): Any?

getObject0

open override fun getObject0(index: Int): Keyword

getReader

open fun getReader(): FieldReader?

getTransferPair

open fun getTransferPair(ref: String?, allocator: BufferAllocator?): TransferPair?

open fun getTransferPair(ref: String?, allocator: BufferAllocator?, callBack: CallBack?): TransferPair?

open fun getTransferPair(field: Field?, allocator: BufferAllocator?, callBack: CallBack?): TransferPair?

open override fun getTransferPair(allocator: BufferAllocator): TransferPair

open override fun getTransferPair(field: Field, allocator: BufferAllocator): TransferPair

getUnderlyingVector

open fun getUnderlyingVector(): VarCharVector?

hashCode

open override fun hashCode(index: Int): Int

open override fun hashCode(index: Int, hasher: ArrowBufHasher): Int

initializeChildrenFromFields

open fun initializeChildrenFromFields(children: List<Field?>?)

isNull

open fun isNull(index: Int): Boolean

iterator

open operator fun iterator(): MutableIterator<ValueVector?>

loadFieldBuffers

open fun loadFieldBuffers(fieldNode: ArrowFieldNode?, ownBuffers: List<ArrowBuf?>?)

makeTransferPair

open override fun makeTransferPair(target: ValueVector): TransferPair

reAlloc

open fun reAlloc()

reset

open fun reset()

setInitialCapacity

open fun setInitialCapacity(numRecords: Int)

setNull

open fun setNull(index: Int)

validate

open fun validate()

validateFull

open fun validateFull()