Trait datafusion::dataframe::DataFrame

pub trait DataFrame {
    fn repartition(&self, n: u32) -> Result<Box<DataFrame>, DataFrameError>;
    fn select(&self, expr: Vec<Expr>) -> Result<Box<DataFrame>, DataFrameError>;
    fn filter(&self, expr: Expr) -> Result<Box<DataFrame>, DataFrameError>;
    fn sort(&self, expr: Vec<Expr>) -> Result<Box<DataFrame>, DataFrameError>;
    fn col(&self, column_name: &str) -> Result<Expr, DataFrameError>;
    fn schema(&self) -> Schema;
    fn plan(&self) -> Box<LogicalPlan>;
}

DataFrame is an abstraction of a distributed query plan

Required Methods

fn repartition(&self, n: u32) -> Result<Box<DataFrame>, DataFrameError>

Change the number of partitions

fn select(&self, expr: Vec<Expr>) -> Result<Box<DataFrame>, DataFrameError>

Projection

fn filter(&self, expr: Expr) -> Result<Box<DataFrame>, DataFrameError>

Selection

fn sort(&self, expr: Vec<Expr>) -> Result<Box<DataFrame>, DataFrameError>

Sorting

fn col(&self, column_name: &str) -> Result<Expr, DataFrameError>

Return an expression representing the specified column

fn schema(&self) -> Schema

fn plan(&self) -> Box<LogicalPlan>

Implementors

• impl DataFrame for DF