Struct SqlDataFrame

pub struct SqlDataFrame { /* private fields */ }

Implementations

impl SqlDataFrame

pub async fn try_new( conn: Arc<dyn SqlConnection>, table: &str, fallback_conns: Vec<Arc<dyn SqlConnection>>, ) -> Result<Self>

pub fn from_values( values: &VegaFusionTable, conn: Arc<dyn SqlConnection>, fallback_conns: Vec<Arc<dyn SqlConnection>>, ) -> Result<Arc<dyn DataFrame>>

pub fn dialect(&self) -> &Dialect

pub fn parent_name(&self) -> String

pub fn as_query(&self) -> Query

Trait Implementations

impl Clone for SqlDataFrame

fn clone(&self) -> SqlDataFrame

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl DataFrame for SqlDataFrame

fn as_any(&self) -> &dyn Any

fn schema(&self) -> Schema

fn connection(&self) -> Arc<dyn Connection>

fn fingerprint(&self) -> u64

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

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

fn sort<'life0, 'async_trait>( &'life0 self, exprs: Vec<Expr>, limit: Option<i32>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn DataFrame>>> + Send + 'async_trait>>

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

fn select<'life0, 'async_trait>( &'life0 self, exprs: Vec<Expr>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn DataFrame>>> + Send + 'async_trait>>

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

fn aggregate<'life0, 'async_trait>( &'life0 self, group_exprs: Vec<Expr>, aggr_exprs: Vec<Expr>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn DataFrame>>> + Send + 'async_trait>>

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

fn joinaggregate<'life0, 'async_trait>( &'life0 self, group_expr: Vec<Expr>, aggr_expr: Vec<Expr>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn DataFrame>>> + Send + 'async_trait>>

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

fn filter<'life0, 'async_trait>( &'life0 self, predicate: Expr, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn DataFrame>>> + Send + 'async_trait>>

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

fn limit<'life0, 'async_trait>( &'life0 self, limit: i32, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn DataFrame>>> + Send + 'async_trait>>

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

fn fold<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, fields: &'life1 [String], value_col: &'life2 str, key_col: &'life3 str, order_field: Option<&'life4 str>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn DataFrame>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

fn stack<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, field: &'life1 str, orderby: Vec<Expr>, groupby: &'life2 [String], start_field: &'life3 str, stop_field: &'life4 str, mode: StackMode, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn DataFrame>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

fn impute<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, field: &'life1 str, value: ScalarValue, key: &'life2 str, groupby: &'life3 [String], order_field: Option<&'life4 str>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn DataFrame>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

fn schema_df(&self) -> Result<DFSchema, VegaFusionError>

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

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

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

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