Struct SelectExecution 

pub struct SelectExecution<P>
where
    P: Pager<Blob = EntryHandle> + Send + Sync,
{ /* private fields */ }

Streaming execution handle for SELECT queries.

Implementations

impl<P> SelectExecution<P>

where P: Pager<Blob = EntryHandle> + Send + Sync,

pub fn new_single_batch( table_name: String, schema: Arc<Schema>, batch: RecordBatch, ) -> SelectExecution<P>

pub fn from_batch( table_name: String, schema: Arc<Schema>, batch: RecordBatch, ) -> SelectExecution<P>

pub fn table_name(&self) -> &str

pub fn schema(&self) -> Arc<Schema>

pub fn stream( self, on_batch: impl FnMut(RecordBatch) -> Result<(), Error>, ) -> Result<(), Error>

pub fn collect(self) -> Result<Vec<RecordBatch>, Error>

pub fn collect_rows(self) -> Result<ExecutorRowBatch, Error>

pub fn into_rows(self) -> Result<Vec<Vec<PlanValue>>, Error>

Trait Implementations

impl<P> Clone for SelectExecution<P>

where P: Clone + Pager<Blob = EntryHandle> + Send + Sync,

fn clone(&self) -> SelectExecution<P>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P> Debug for SelectExecution<P>

where P: Pager<Blob = EntryHandle> + Send + Sync,

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

Formats the value using the given formatter.