Package | Description |
---|---|
org.apache.arrow.vector.ipc.message |
Modifier and Type | Method and Description |
---|---|
static MessageMetadataResult |
MessageMetadataResult.create(ByteBuffer buffer,
int messageLength)
Creates a new
MessageMetadataResult by parsing it from the beginning of the buffer. |
static MessageMetadataResult |
MessageSerializer.readMessage(ReadChannel in)
Read a Message from the input channel and return a MessageMetadataResult that contains the
Message metadata, buffer containing the serialized Message metadata as read, and length of the
Message in bytes.
|
Modifier and Type | Method and Description |
---|---|
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(MessageMetadataResult serializedMessage,
ArrowBuf underlying)
Reads a record batch based on the metadata in serializedMessage and the underlying data buffer.
|
static Schema |
MessageSerializer.deserializeSchema(MessageMetadataResult message)
Deserializes an Arrow Schema object from a
MessageMetadataResult . |
Copyright © 2024 The Apache Software Foundation. All rights reserved.