Struct datafusion::exec::DF
[−]
[src]
pub struct DF { /* fields omitted */ }
Trait Implementations
impl DataFrame for DF[src]
fn select(&self, expr: Vec<Expr>) -> Result<Box<DataFrame>, DataFrameError>[src]
Projection
fn sort(&self, expr: Vec<Expr>) -> Result<Box<DataFrame>, DataFrameError>[src]
Sorting
fn filter(&self, expr: Expr) -> Result<Box<DataFrame>, DataFrameError>[src]
Selection
fn write(&self, filename: &str) -> Result<(), DataFrameError>[src]
Write to CSV ... will support other formats in the future
fn col(&self, column_name: &str) -> Result<Expr, DataFrameError>[src]
Return an expression representing the specified column
fn schema(&self) -> Schema[src]
fn repartition(&self, _n: u32) -> Result<Box<DataFrame>, DataFrameError>[src]
Change the number of partitions