Trait DataFrameUtils 

pub trait DataFrameUtils {
    // Required methods
    fn collect_to_table<'async_trait>(
        self,
    ) -> Pin<Box<dyn Future<Output = Result<VegaFusionTable>> + Send + 'async_trait>>
       where Self: 'async_trait;
    fn collect_flat<'async_trait>(
        self,
    ) -> Pin<Box<dyn Future<Output = Result<RecordBatch>> + Send + 'async_trait>>
       where Self: 'async_trait;
    fn with_index<'life0, 'async_trait>(
        self,
        index_name: &'life0 str,
    ) -> Pin<Box<dyn Future<Output = Result<DataFrame>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn aggregate_mixed(
        self,
        group_expr: Vec<Expr>,
        aggr_expr: Vec<Expr>,
    ) -> Result<DataFrame>;
    fn alias(self, name: impl Into<TableReference>) -> Result<DataFrame>;
}

Required Methods

fn collect_to_table<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = Result<VegaFusionTable>> + Send + 'async_trait>>

where Self: 'async_trait,

fn collect_flat<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = Result<RecordBatch>> + Send + 'async_trait>>

where Self: 'async_trait,

fn with_index<'life0, 'async_trait>( self, index_name: &'life0 str, ) -> Pin<Box<dyn Future<Output = Result<DataFrame>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn aggregate_mixed( self, group_expr: Vec<Expr>, aggr_expr: Vec<Expr>, ) -> Result<DataFrame>

Variant of aggregate that can handle agg expressions that include projections on top of aggregations. Also includes groupby expressions in the final result

fn alias(self, name: impl Into<TableReference>) -> Result<DataFrame>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl DataFrameUtils for DataFrame

fn collect_to_table<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = Result<VegaFusionTable>> + Send + 'async_trait>>

where Self: 'async_trait,

fn collect_flat<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = Result<RecordBatch>> + Send + 'async_trait>>

where Self: 'async_trait,

fn with_index<'life0, 'async_trait>( self, index_name: &'life0 str, ) -> Pin<Box<dyn Future<Output = Result<DataFrame>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn aggregate_mixed( self, group_expr: Vec<Expr>, aggr_expr: Vec<Expr>, ) -> Result<DataFrame>

fn alias(self, name: impl Into<TableReference>) -> Result<DataFrame>

Implementors