Enum EllaTable

pub enum EllaTable {
    Topic(Arc<EllaTopic>),
    View(Arc<EllaView>),
}

Variants

Topic(Arc<EllaTopic>)

View(Arc<EllaView>)

Implementations

impl EllaTable

pub fn id(&self) -> &TableId<'static>

pub fn config(&self) -> &TableConfig

pub fn path(&self) -> &Path

pub fn info(&self) -> TableInfo

pub fn as_topic(&self) -> Option<Arc<EllaTopic>>

pub fn as_view(&self) -> Option<Arc<EllaView>>

pub fn kind(&self) -> &'static str

pub fn load(table: &TableState, state: &EllaState) -> Result<Self>

Trait Implementations

impl Debug for EllaTable

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

Formats the value using the given formatter.

impl From<Arc<EllaTopic>> for EllaTable

fn from(value: Arc<EllaTopic>) -> Self

Converts to this type from the input type.

impl From<Arc<EllaView>> for EllaTable

fn from(value: Arc<EllaView>) -> Self

Converts to this type from the input type.

impl TableProvider for EllaTable

fn as_any(&self) -> &dyn Any

Returns the table provider as Any so that it can be downcast to a specific implementation.

fn schema(&self) -> SchemaRef

Get a reference to the schema for this table

fn table_type(&self) -> TableType

Get the type of this table for metadata/catalog purposes.

fn get_table_definition(&self) -> Option<&str>

Get the create statement used to create this table, if available.

fn get_logical_plan(&self) -> Option<&LogicalPlan>

Get the Logical Plan of this table, if available.

fn statistics(&self) -> Option<Statistics>

Get statistics for this table, if available

fn supports_filters_pushdown( &self, filters: &[&Expr], ) -> DfResult<Vec<TableProviderFilterPushDown>>

Tests whether the table provider can make use of any or all filter expressions to optimise data retrieval.

fn scan<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, state: &'life1 SessionState, projection: Option<&'life2 Vec<usize>>, filters: &'life3 [Expr], limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = DfResult<Arc<dyn ExecutionPlan>>> + Send + 'async_trait>>

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

Create an ExecutionPlan that will scan the table. The table provider will be usually responsible of grouping the source data into partitions that can be efficiently parallelized or distributed.

fn insert_into<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 SessionState, input: Arc<dyn ExecutionPlan>, ) -> Pin<Box<dyn Future<Output = DfResult<Arc<dyn ExecutionPlan>>> + Send + 'async_trait>>

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

Return an ExecutionPlan to insert data into this table, if supported.

fn supports_filter_pushdown( &self, _filter: &Expr, ) -> Result<TableProviderFilterPushDown, DataFusionError>

👎Deprecated since 20.0.0: use supports_filters_pushdown instead

Tests whether the table provider can make use of a filter expression to optimise data retrieval.