Package | Description |
---|---|
org.apache.arrow.vector.ipc | |
org.apache.arrow.vector.ipc.message |
Modifier and Type | Class and Description |
---|---|
class |
SeekableReadChannel
An
ReadChannel that supports seeking to a
random position. |
Modifier and Type | Field and Description |
---|---|
protected ReadChannel |
MessageChannelReader.in |
Modifier and Type | Method and Description |
---|---|
static ArrowDictionaryBatch |
MessageSerializer.deserializeDictionaryBatch(ReadChannel in,
ArrowBlock block,
BufferAllocator alloc)
Deserializes a DictionaryBatch knowing the size of the entire message up front.
|
static ArrowDictionaryBatch |
MessageSerializer.deserializeDictionaryBatch(ReadChannel in,
BufferAllocator allocator)
Deserializes an ArrowDictionaryBatch read from the input channel.
|
static ArrowMessage |
MessageSerializer.deserializeMessageBatch(ReadChannel in,
BufferAllocator alloc)
Deserialize a message that is either an ArrowDictionaryBatch or ArrowRecordBatch.
|
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 Schema |
MessageSerializer.deserializeSchema(ReadChannel in)
Deserializes an Arrow Schema read from the input channel.
|
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.
|
static ArrowBuf |
MessageSerializer.readMessageBody(ReadChannel in,
long bodyLength,
BufferAllocator allocator)
Read a Message body from the in channel into an ArrowBuf.
|
Constructor and Description |
---|
MessageChannelReader(ReadChannel in,
BufferAllocator allocator)
Construct a MessageReader to read streaming messages from an existing ReadChannel.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.