[−][src]Struct datafusion::execution::table_impl::TableImpl
Implementation of Table API
Methods
impl TableImpl
[src]
pub fn new(plan: Arc<LogicalPlan>) -> Self
[src]
Create a new Table based on an existing logical plan
Trait Implementations
impl Table for TableImpl
[src]
fn select_columns(&self, columns: Vec<&str>) -> Result<Arc<dyn Table>>
[src]
Apply a projection based on a list of column names
fn select(&self, expr_list: Vec<Expr>) -> Result<Arc<dyn Table>>
[src]
Create a projection based on arbitrary expressions
fn filter(&self, expr: Expr) -> Result<Arc<dyn Table>>
[src]
Create a selection based on a filter expression
fn aggregate(
&self,
group_expr: Vec<Expr>,
aggr_expr: Vec<Expr>
) -> Result<Arc<dyn Table>>
[src]
&self,
group_expr: Vec<Expr>,
aggr_expr: Vec<Expr>
) -> Result<Arc<dyn Table>>
Perform an aggregate query
fn limit(&self, n: usize) -> Result<Arc<dyn Table>>
[src]
Limit the number of rows
fn col(&self, name: &str) -> Result<Expr>
[src]
Return an expression representing a column within this table
fn column_index(&self, name: &str) -> Result<usize>
[src]
Return the index of a column within this table's schema
fn min(&self, expr: &Expr) -> Result<Expr>
[src]
Create an expression to represent the min() aggregate function
fn max(&self, expr: &Expr) -> Result<Expr>
[src]
Create an expression to represent the max() aggregate function
fn sum(&self, expr: &Expr) -> Result<Expr>
[src]
Create an expression to represent the sum() aggregate function
fn avg(&self, expr: &Expr) -> Result<Expr>
[src]
Create an expression to represent the avg() aggregate function
fn count(&self, expr: &Expr) -> Result<Expr>
[src]
Create an expression to represent the count() aggregate function
fn to_logical_plan(&self) -> Arc<LogicalPlan>
[src]
Convert to logical plan
Auto Trait Implementations
impl Send for TableImpl
impl Sync for TableImpl
impl Unpin for TableImpl
impl UnwindSafe for TableImpl
impl RefUnwindSafe for TableImpl
Blanket Implementations
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> From<T> for T
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> FromCast<T> for T
fn from_cast(t: T) -> T
impl<T, U> Cast<U> for T where
U: FromCast<T>,
U: FromCast<T>,
fn cast(self) -> U
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
U: TryFrom<T>,