pub struct GrpcResultChunk { /* private fields */ }Expand description
A single chunk of gRPC query results.
Each chunk contains Arrow IPC data (schema + record batch) and metadata
about the chunk. The data is held as Bytes, so it shares the underlying
allocation with the gRPC frame it was decoded from — cloning the chunk or
extracting the bytes is a refcount bump, not a copy.
Implementations§
Source§impl GrpcResultChunk
impl GrpcResultChunk
Sourcepub fn arrow_data(&self) -> &[u8] ⓘ
pub fn arrow_data(&self) -> &[u8] ⓘ
Returns the Arrow IPC data for this chunk.
Sourcepub fn arrow_bytes(&self) -> Bytes
pub fn arrow_bytes(&self) -> Bytes
Returns the Arrow IPC data as a shared Bytes handle.
This is a refcount bump, not a copy — the returned Bytes shares the
same allocation as the chunk.
Sourcepub fn into_arrow_data(self) -> Bytes
pub fn into_arrow_data(self) -> Bytes
Consumes the chunk and returns the Arrow IPC data.
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for GrpcResultChunk
impl RefUnwindSafe for GrpcResultChunk
impl Send for GrpcResultChunk
impl Sync for GrpcResultChunk
impl Unpin for GrpcResultChunk
impl UnsafeUnpin for GrpcResultChunk
impl UnwindSafe for GrpcResultChunk
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request