Uses of Class
org.apache.arrow.vector.ipc.ReadChannel
-
Uses of ReadChannel in org.apache.arrow.vector.ipc
Modifier and TypeClassDescriptionclass
AnReadChannel
that supports seeking to a random position. -
Uses of ReadChannel in org.apache.arrow.vector.ipc.message
Modifier and TypeMethodDescriptionstatic ArrowDictionaryBatch
MessageSerializer.deserializeDictionaryBatch
(ReadChannel in, BufferAllocator allocator) Deserializes an ArrowDictionaryBatch read from the input channel.static ArrowDictionaryBatch
MessageSerializer.deserializeDictionaryBatch
(ReadChannel in, ArrowBlock block, BufferAllocator alloc) Deserializes a DictionaryBatch knowing the size of the entire message up front.static ArrowMessage
MessageSerializer.deserializeMessageBatch
(ReadChannel in, BufferAllocator alloc) Deserialize a message that is either an ArrowDictionaryBatch or ArrowRecordBatch.static ArrowRecordBatch
MessageSerializer.deserializeRecordBatch
(ReadChannel in, BufferAllocator allocator) Deserializes an ArrowRecordBatch read from the input channel.static ArrowRecordBatch
MessageSerializer.deserializeRecordBatch
(ReadChannel in, ArrowBlock block, BufferAllocator alloc) Deserializes an ArrowRecordBatch knowing the size of the entire message up front.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.ModifierConstructorDescriptionMessageChannelReader
(ReadChannel in, BufferAllocator allocator) Construct a MessageReader to read streaming messages from an existing ReadChannel.