Struct ella_engine::engine::EllaState

pub struct EllaState { /* private fields */ }

Implementations

impl EllaState

pub fn with_config(&mut self, config: EllaConfig)

pub async fn query(&self, sql: impl AsRef<str>) -> Result<Lazy>

pub async fn create_topic( &self, id: TableId<'static>, info: TopicInfo, if_not_exists: bool, or_replace: bool ) -> Result<Arc<EllaTopic>>

pub async fn create_view( &self, id: TableId<'static>, info: ViewInfo, if_not_exists: bool, or_replace: bool ) -> Result<Arc<EllaView>>

pub async fn create_table( &self, id: TableId<'static>, info: TableInfo, if_not_exists: bool, or_replace: bool ) -> Result<Arc<EllaTable>>

pub fn table(&self, table: TableId<'_>) -> Option<Arc<EllaTable>>

pub async fn create_catalog<'a>( &self, catalog: impl Into<Id<'a>>, if_not_exists: bool ) -> Result<Arc<EllaCatalog>>

pub async fn create_schema<'a>( &self, schema: impl Into<SchemaRef<'a>>, if_not_exists: bool ) -> Result<Arc<EllaSchema>>

pub fn resolve(&self, table: TableRef<'_>) -> TableId<'static>

pub fn log(&self) -> &Arc<TransactionLog>

pub fn root(&self) -> &Path

pub fn session(&self) -> &SessionState

pub fn cluster(&self) -> &Arc<EllaCluster>

pub fn store(&self) -> &Arc<dyn ObjectStore + 'static>

pub fn config(&self) -> &EllaConfig

pub fn default_catalog(&self) -> &Id<'static>

pub fn default_schema(&self) -> &Id<'static>

pub fn codec(&self) -> EllaExtensionCodec

Trait Implementations

impl Clone for EllaState

fn clone(&self) -> EllaState

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for EllaState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.