Struct DataFrame 

pub struct DataFrame { /* private fields */ }

An eager table backed by one or more Arrow RecordBatch values.

Implementations

impl DataFrame

pub fn new(columns: Vec<Series>) -> Result<DataFrame, DataFrameError>

Construct a DataFrame from a list of Series.

Chunk boundaries do not need to align across series as long as total lengths match.

pub fn from_batches( batches: Vec<RecordBatch>, ) -> Result<DataFrame, DataFrameError>

Construct a DataFrame from Arrow record batches (all batches must share the same schema).

pub fn from_series(series: Vec<Series>) -> Result<DataFrame, DataFrameError>

Alias for DataFrame::new.

pub fn empty() -> DataFrame

Return an empty DataFrame (no columns, no rows).

pub fn height(&self) -> usize

Return the number of rows.

pub fn width(&self) -> usize

Return the number of columns.

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

Return the Arrow schema.

pub fn column(&self, name: &str) -> Result<Series, DataFrameError>

Get a column by name (case-sensitive).

pub fn columns(&self) -> Vec<Series>

Return all columns in construction order.

pub fn to_arrow(&self) -> Vec<RecordBatch>

Return the underlying Arrow batches.

pub fn lazy(&self) -> LazyFrame

Convert this eager DataFrame to a LazyFrame for query planning/execution.

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

Eager select, implemented by delegating to LazyFrame.

pub fn filter(&self, predicate: Expr) -> Result<DataFrame, DataFrameError>

Eager filter, implemented by delegating to LazyFrame.

pub fn with_columns( &self, exprs: Vec<Expr>, ) -> Result<DataFrame, DataFrameError>

Eager with_columns, implemented by delegating to LazyFrame.

pub fn group_by(&self, by: Vec<Expr>) -> GroupBy

Start a group-by aggregation (eager API).

pub fn join<K>( &self, other: &DataFrame, keys: K, how: JoinType, ) -> Result<DataFrame, DataFrameError>

where K: Into<JoinKeys>,

Join with another DataFrame using provided join keys.

pub fn sort( &self, by: Vec<String>, descending: Vec<bool>, ) -> Result<DataFrame, DataFrameError>

Sort by one or more columns.

pub fn head(&self, n: usize) -> Result<DataFrame, DataFrameError>

Return the first n rows.

pub fn tail(&self, n: usize) -> Result<DataFrame, DataFrameError>

Return the last n rows.

pub fn unique( &self, subset: Option<Vec<String>>, ) -> Result<DataFrame, DataFrameError>

Remove duplicate rows.

pub fn fill_null<T>(&self, fill: T) -> Result<DataFrame, DataFrameError>

where T: Into<FillNull>,

Fill null values using a scalar or strategy.

pub fn drop_nulls( &self, subset: Option<Vec<String>>, ) -> Result<DataFrame, DataFrameError>

Drop rows containing null values.

pub fn null_count(&self) -> Result<DataFrame, DataFrameError>

Count null values per column.

Trait Implementations

impl Clone for DataFrame

fn clone(&self) -> DataFrame

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DataFrame

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

Formats the value using the given formatter.