Struct GenAIEvalDataFrame 

pub struct GenAIEvalDataFrame {
    pub object_store: ObjectStore,
    /* private fields */
}

Fields

object_store: ObjectStore

Implementations

impl GenAIEvalDataFrame

pub fn new( storage_settings: &ObjectStorageSettings, ) -> Result<Self, DataFrameError>

Trait Implementations

impl ParquetFrame for GenAIEvalDataFrame

fn new(storage_settings: &ObjectStorageSettings) -> Result<Self, DataFrameError>

fn get_dataframe<'life0, 'async_trait>( &'life0 self, records: ServerRecords, ) -> Pin<Box<dyn Future<Output = Result<DataFrame, DataFrameError>> + Send + 'async_trait>>

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

fn storage_root(&self) -> String

Get the storage root path

fn storage_type(&self) -> StorageType

fn get_session_context(&self) -> Result<SessionContext, DataFrameError>

fn get_binned_sql( &self, _bin: &f64, _start_time: &DateTime<Utc>, _end_time: &DateTime<Utc>, _entity_id: &i32, ) -> String

fn table_name(&self) -> String

fn write_parquet<'life0, 'life1, 'async_trait>( &'life0 self, rpath: &'life1 str, records: ServerRecords, ) -> Pin<Box<dyn Future<Output = Result<(), DataFrameError>> + Send + 'async_trait>>

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

Write the records to a parquet file at the given path.

fn register_table<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 str, table_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<SessionContext, DataFrameError>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Load storage files into parquet table for querying

fn get_binned_metrics<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, path: &'life1 str, bin: &'life2 f64, start_time: &'life3 DateTime<Utc>, end_time: &'life4 DateTime<Utc>, entity_id: &'life5 i32, ) -> Pin<Box<dyn Future<Output = Result<DataFrame, DataFrameError>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

Get binned metrics from the parquet file