lance_datafusion::exec

Trait 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§