Struct RuntimeLazyFrame 

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

Lazily built logical plan (thin wrapper over SelectPlan).

Implementations

impl<P> RuntimeLazyFrame<P>

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

pub fn scan(context: Arc<RuntimeContext<P>>, table: &str) -> Result<Self>

pub fn filter(self, predicate: LlkvExpr<'static, String>) -> Self

pub fn select_all(self) -> Self

pub fn select_columns<S>(self, columns: impl IntoIterator<Item = S>) -> Self

where S: AsRef<str>,

pub fn select(self, projections: Vec<SelectProjection>) -> Self

pub fn aggregate(self, aggregates: Vec<AggregateExpr>) -> Self

pub fn collect(self) -> Result<SelectExecution<P>>

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

pub fn collect_rows_vec(self) -> Result<Vec<Vec<PlanValue>>>