Struct QueryState 

pub struct QueryState<Q> {
    pub query: Arc<Q>,
    /* private fields */
}

State for a query-only service.

Fields

query: Arc<Q>

Backend used for point and range reads.

Implementations

impl<Q> QueryState<Q>

where Q: Query,

pub fn new(query: Arc<Q>) -> Self

Creates a query service with DataFusion’s shared, unbounded memory pool.

Group state must fit in memory by default. Supply a native runtime with a bounded pool through Self::with_runtime to enable native spilling. The pool excludes transient input, backend, transport, and client buffers.

pub fn with_runtime(self, runtime: Arc<RuntimeEnv>) -> Self

Supplies the worker’s shared native memory pool and spill configuration.

Trait Implementations

impl<Q> Clone for QueryState<Q>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E> From<AppState<E>> for QueryState<E>

fn from(state: AppState<E>) -> Self

Converts to this type from the input type.