Struct ScriptManager

pub struct ScriptManager<E: ErrorExt + Send + Sync + 'static> {
    compiled: RwLock<HashMap<String, Arc<PyScript>>>,
    py_engine: PyEngine,
    grpc_handler: ArcSwap<GrpcQueryHandlerRef<E>>,
    tables: RwLock<HashMap<String, ScriptsTableRef<E>>>,
    query_engine: QueryEngineRef,
}

Fields

compiled: RwLock<HashMap<String, Arc<PyScript>>>

py_engine: PyEngine

grpc_handler: ArcSwap<GrpcQueryHandlerRef<E>>

tables: RwLock<HashMap<String, ScriptsTableRef<E>>>

query_engine: QueryEngineRef

Implementations

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

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

pub fn start(&self, grpc_handler: GrpcQueryHandlerRef<E>) -> Result<()>

pub fn create_table_request(&self, catalog: &str) -> RegisterSystemTableRequest

async fn compile(&self, name: &str, script: &str) -> Result<Arc<PyScript>>

compile script, and register them to the query engine and UDF registry

async fn compile_without_cache( py_engine: &PyEngine, name: &str, script: &str, ) -> Result<PyScript>

compile script to PyScript, but not register them to the query engine and UDF registry nor caching in compiled

pub fn get_scripts_table(&self, catalog: &str) -> Option<ScriptsTableRef<E>>

Get the scripts table in the catalog

pub fn insert_scripts_table(&self, catalog: &str, table: TableRef)

Insert a scripts table.

pub async fn insert_and_compile( &self, catalog: &str, schema: &str, name: &str, script: &str, ) -> Result<Arc<PyScript>>

pub async fn execute( &self, catalog: &str, schema: &str, name: &str, params: HashMap<String, String>, ) -> Result<Output>

async fn try_find_script_and_compile( &self, catalog: &str, schema: &str, name: &str, ) -> Result<Option<Arc<PyScript>>>