Skip to main content

OxideSessionExt

oxidelake_api

Trait OxideSessionExt 

Source 
pub trait OxideSessionExt {
    // Required methods
    fn read_parquet(
        &self,
        path: &str,
    ) -> impl Future<Output = Result<OxideFrame, EngineError>> + Send;
    fn table(
        &self,
        name: &str,
    ) -> impl Future<Output = Result<OxideFrame, EngineError>> + Send;
    fn sql_frame(
        &self,
        query: &str,
    ) -> impl Future<Output = Result<OxideFrame, EngineError>> + Send;
}
Expand description

Frame-producing entry points on OxideSession.

Required Methods§

Source

fn read_parquet( &self, path: &str, ) -> impl Future<Output = Result<OxideFrame, EngineError>> + Send

Reads a Parquet file or directory as a frame.

Source

fn table( &self, name: &str, ) -> impl Future<Output = Result<OxideFrame, EngineError>> + Send

A frame over a registered table.

Source

fn sql_frame( &self, query: &str, ) -> impl Future<Output = Result<OxideFrame, EngineError>> + Send

Plans a SQL statement as a frame.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§