Trait lance_datafusion::exec::SessionContextExt

source ·
pub trait SessionContextExt {
    // Required method
    fn read_one_shot(
        &self,
        data: SendableRecordBatchStream,
    ) -> Result<DataFrame>;
}

Required Methods§

source

fn read_one_shot(&self, data: SendableRecordBatchStream) -> Result<DataFrame>

Creates a DataFrame for reading a stream of data

This dataframe may only be queried once, future queries will fail

Implementations on Foreign Types§

source§

impl SessionContextExt for SessionContext

Implementors§