Struct GrpcQueryResult 

pub struct GrpcQueryResult { /* private fields */ }

Result of a gRPC query execution.

Unlike TCP-based queries that return row-at-a-time results, gRPC queries return results in Arrow IPC format, which can contain multiple record batches.

Example

use hyperdb_api_core::client::grpc::{GrpcClient, GrpcConfig};

let result = client.execute_query("SELECT * FROM users").await?;

// Get raw Arrow IPC bytes for all chunks
let all_arrow_data = result.arrow_data();

// Or process chunk by chunk
for chunk in result.chunks() {
    let arrow_bytes = chunk.arrow_data();
    // Process with arrow crate...
}

Implementations

impl GrpcQueryResult

pub fn query_id(&self) -> Option<&str>

Returns the query ID assigned by the server, if available.

pub fn column_count(&self) -> usize

Returns the number of columns in the result.

pub fn columns(&self) -> impl Iterator<Item = GrpcColumnInfo<'_>> + '_

Returns the column descriptions from the server.

pub fn has_chunks(&self) -> bool

Returns whether there are more result chunks available.

pub fn take_chunk(&mut self) -> Option<GrpcResultChunk>

Takes the next result chunk, if available.

pub fn chunks(&self) -> impl Iterator<Item = &GrpcResultChunk>

Returns an iterator over the result chunks.

pub fn arrow_data(&self) -> Bytes

Returns all Arrow IPC data concatenated.

For queries with multiple chunks, this concatenates all Arrow record batches. Note that each chunk may have its own schema message, so the result may contain multiple schema messages.

Single-chunk results are returned without any copy (refcount bump on the shared Bytes). Multi-chunk results are concatenated into a new Bytes. Prefer chunk_bytes() if you can process chunks incrementally.

pub fn into_arrow_data(self) -> Bytes

Consumes the result and returns all Arrow IPC data.

Single-chunk results are returned without any copy. Multi-chunk results are concatenated into a new Bytes.

pub fn chunk_bytes(&self) -> impl Iterator<Item = Bytes> + '_

Returns an iterator over the raw Arrow IPC byte chunks.

Each chunk is a refcount-bumped Bytes sharing the original gRPC frame allocation — no copies are performed. This is the preferred way to feed results into an incremental Arrow IPC decoder.

pub fn rows_affected(&self) -> Option<u64>

Returns the number of rows affected by a DML query.

For SELECT queries, this is None. For INSERT/UPDATE/DELETE queries, this returns the number of rows affected.

pub fn is_complete(&self) -> bool

Returns whether the query execution is complete.

Trait Implementations

impl Debug for GrpcQueryResult

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for GrpcQueryResult

fn default() -> Self

Returns the “default value” for a type.