Package | Description |
---|---|
org.apache.arrow.vector.ipc.message |
Modifier and Type | Class and Description |
---|---|
class |
ArrowDictionaryBatch
POJO wrapper around a Dictionary Batch IPC messages
(https://arrow.apache.org/docs/format/IPC.html#dictionary-batches)
|
class |
ArrowRecordBatch
POJO representation of a RecordBatch IPC message (https://arrow.apache.org/docs/format/Columnar.html#recordbatch-message).
|
Modifier and Type | Method and Description |
---|---|
static ArrowMessage |
MessageSerializer.deserializeMessageBatch(MessageChannelReader reader)
Deserialize a message that is either an ArrowDictionaryBatch or ArrowRecordBatch.
|
static ArrowMessage |
MessageSerializer.deserializeMessageBatch(ReadChannel in,
BufferAllocator alloc)
Deserialize a message that is either an ArrowDictionaryBatch or ArrowRecordBatch.
|
Modifier and Type | Method and Description |
---|---|
static ByteBuffer |
MessageSerializer.serializeMetadata(ArrowMessage message)
Deprecated.
|
static ByteBuffer |
MessageSerializer.serializeMetadata(ArrowMessage message,
IpcOption writeOption)
Returns the serialized form of
RecordBatch wrapped in a Message . |
Copyright © 2024 The Apache Software Foundation. All rights reserved.