Package | Description |
---|---|
org.apache.arrow.vector | |
org.apache.arrow.vector.ipc | |
org.apache.arrow.vector.ipc.message |
Modifier and Type | Method and Description |
---|---|
ArrowRecordBatch |
VectorUnloader.getRecordBatch()
Performs the depth first traversal of the Vectors to create an
ArrowRecordBatch suitable
for serialization. |
Modifier and Type | Method and Description |
---|---|
void |
VectorLoader.load(ArrowRecordBatch recordBatch)
Loads the record batch in the vectors.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ArrowReader.loadRecordBatch(ArrowRecordBatch batch)
Load an ArrowRecordBatch to the readers VectorSchemaRoot.
|
protected ArrowBlock |
ArrowWriter.writeRecordBatch(ArrowRecordBatch batch) |
protected ArrowBlock |
ArrowFileWriter.writeRecordBatch(ArrowRecordBatch batch) |
Modifier and Type | Method and Description |
---|---|
ArrowRecordBatch |
ArrowRecordBatch.cloneWithTransfer(BufferAllocator allocator)
Create a new ArrowRecordBatch which has the same information as this batch but whose buffers
are owned by that Allocator.
|
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(ReadChannel in,
ArrowBlock block,
BufferAllocator alloc)
Deserializes an ArrowRecordBatch knowing the size of the entire message up front.
|
static ArrowRecordBatch |
MessageSerializer.deserializeRecordBatch(ReadChannel in,
BufferAllocator allocator)
Deserializes an ArrowRecordBatch read from the input channel.
|
static ArrowRecordBatch |
MessageSerializer.deserializeRecordBatch(RecordBatch recordBatchFB,
ArrowBuf body)
Deserializes an ArrowRecordBatch given the Flatbuffer metadata and in-memory body.
|
ArrowRecordBatch |
ArrowDictionaryBatch.getDictionary() |
Modifier and Type | Method and Description |
---|---|
static ArrowBlock |
MessageSerializer.serialize(WriteChannel out,
ArrowRecordBatch batch)
Serializes an ArrowRecordBatch.
|
static ArrowBlock |
MessageSerializer.serialize(WriteChannel out,
ArrowRecordBatch batch,
IpcOption option)
Serializes an ArrowRecordBatch.
|
T |
ArrowMessage.ArrowMessageVisitor.visit(ArrowRecordBatch message) |
static long |
MessageSerializer.writeBatchBuffers(WriteChannel out,
ArrowRecordBatch batch)
Write the Arrow buffers of the record batch to the output channel.
|
Constructor and Description |
---|
ArrowDictionaryBatch(long dictionaryId,
ArrowRecordBatch dictionary)
Deprecated.
|
ArrowDictionaryBatch(long dictionaryId,
ArrowRecordBatch dictionary,
boolean isDelta)
Constructs new instance.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.