We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
StreamReader
Is your feature request related to a problem or challenge? Please describe what you are trying to do.
There is a Vec<u8> in IPC Streaming Format, and I want to convert it to record batches.
Vec<u8>
For now my code is like this:
use bytes::Buf; fn deserialize_stream_buf(buf: Vec<u8>) -> Vec<RecordBatch> { let buf = buf.reader(); let reader = StreamReader::try_new(buf, None).unwrap(); reader.map(|b| b.unwrap()).collect() }
But it's not zero-copy, each time next() is called, StreamReader will copy the data.
next()
Describe the solution you'd like
read a memory region in IPC Streaming Format with zero-copy.
IPC Streaming Format
Describe alternatives you've considered
Is there could be an API like FileReader? Take ownership of the memery region rather than borrowing it.
FileReader
The text was updated successfully, but these errors were encountered:
I believe #5531 is what you're after (not yet released)
Sorry, something went wrong.
Thanks, I will wait for the release :)
No branches or pull requests
Is your feature request related to a problem or challenge? Please describe what you are trying to do.
There is a
Vec<u8>
in IPC Streaming Format, and I want to convert it to record batches.For now my code is like this:
But it's not zero-copy, each time
next()
is called,StreamReader
will copy the data.Describe the solution you'd like
read a memory region in
IPC Streaming Format
with zero-copy.Describe alternatives you've considered
Is there could be an API like
FileReader
? Take ownership of the memery region rather than borrowing it.The text was updated successfully, but these errors were encountered: