Trait lance_datafusion::dataframe::DataFrameExt

source · 
pub trait DataFrameExt {
    // Required method
    fn group_by_stream<'life0, 'life1, 'async_trait>(
        self,
        partition_columns: &'life0 [&'life1 str]
    ) -> Pin<Box<dyn Future<Output = DFResult<BatchStreamGrouper>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Required Methods§

source

fn group_by_stream<'life0, 'life1, 'async_trait>( self, partition_columns: &'life0 [&'life1 str] ) -> Pin<Box<dyn Future<Output = DFResult<BatchStreamGrouper>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute the query and return as a grouped stream.

The data is assumed to have already been sorted by the partition columns.

Implementations on Foreign Types§

source§

impl DataFrameExt for DataFrame

source§

fn group_by_stream<'life0, 'life1, 'async_trait>( self, partition_columns: &'life0 [&'life1 str] ) -> Pin<Box<dyn Future<Output = DFResult<BatchStreamGrouper>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementors§