Struct ScriptsTable

pub struct ScriptsTable<E: ErrorExt + Send + Sync + 'static> {
    table: TableRef,
    grpc_handler: GrpcQueryHandlerRef<E>,
    query_engine: QueryEngineRef,
}

The scripts table that keeps the script content etc.

Fields

table: TableRef

grpc_handler: GrpcQueryHandlerRef<E>

query_engine: QueryEngineRef

Implementations

impl<E: ErrorExt + Send + Sync + 'static> ScriptsTable<E>

pub fn new( table: TableRef, grpc_handler: GrpcQueryHandlerRef<E>, query_engine: QueryEngineRef, ) -> Self

Create a new [ScriptsTable] based on the table.

fn get_str_col_by_name<'a>( record: &'a RecordBatch, name: &str, ) -> Result<&'a StringVector>

pub async fn recompile_register_udf( table: TableRef, query_engine: QueryEngineRef, ) -> Result<()>

this is used as a callback function when scripts table is created. table should be scripts table. the function will try it best to register all scripts, and ignore the error in parsing and register scripts if any, just emit a warning TODO(discord9): rethink error handling here

pub async fn insert(&self, schema: &str, name: &str, script: &str) -> Result<()>

pub async fn find_script_by_name( &self, schema: &str, name: &str, ) -> Result<String>

async fn table_full_scan( table: TableRef, query_engine: &QueryEngineRef, ) -> Result<SendableRecordBatchStream>