Struct RemoteTable 

pub struct RemoteTable { /* private fields */ }

Represents a remote table with a reference and schema.

Implementations

impl RemoteTable

pub fn new(table_ref: RemoteTableRef, schema: SchemaRef) -> Self

Creates a new RemoteTable instance.

Examples:

use datafusion::sql::TableReference;

RemoteTable::new("myschema.table".try_into()?, schema);
RemoteTable::new(r#"myschema."Table""#.try_into()?, schema);
RemoteTable::new(TableReference::partial("myschema", "table").into(), schema);
RemoteTable::new("myschema.view('obj')".try_into()?, schema);
RemoteTable::new("myschema.view(name => 'obj')".try_into()?, schema);
RemoteTable::new("myschema.view(name = 'obj')".try_into()?, schema);

pub fn table_reference(&self) -> &TableReference

Return table reference of this remote table. Only returns the object name, ignoring functional params if any

pub fn schema(&self) -> &SchemaRef

Trait Implementations

impl Clone for RemoteTable

fn clone(&self) -> RemoteTable

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RemoteTable

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

Formats the value using the given formatter.

impl Hash for RemoteTable

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for RemoteTable

fn eq(&self, other: &RemoteTable) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl SQLTable for RemoteTable

fn ast_analyzer(&self) -> Option<AstAnalyzer>

Returns ast analyzer that modifies table that contains functional args after table ident

fn as_any(&self) -> &dyn Any

Returns a reference as a trait object.

fn table_reference(&self) -> TableReference

Provides the TableReference used to identify the table in SQL queries. This TableReference is used for registering the table with the SQLSchemaProvider. If the table provider is registered in the Datafusion context under a different name, the logical plan will be rewritten to use this table reference during execution. Therefore, any AST analyzer should match against this table reference.

fn schema(&self) -> SchemaRef

Schema of the remote table

fn logical_optimizer(&self) -> Option<LogicalOptimizer>

Returns a logical optimizer specific to this table, will be used to modify the logical plan before execution

impl Eq for RemoteTable

impl StructuralPartialEq for RemoteTable