Struct RemoteTable 

pub struct RemoteTable { /* private fields */ }

Implementations

impl RemoteTable

pub async fn try_new( conn_options: impl Into<ConnectionOptions>, source: impl Into<TableSource>, ) -> Result<Self>

Examples found in repository

examples/postgres.rs (line 8)

pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let options = PostgresConnectionOptions::new("localhost", 5432, "user", "password");
    let remote_table = RemoteTable::try_new(options, "select * from supported_data_types").await?;

    let ctx = SessionContext::new();
    ctx.register_table("remote_table", Arc::new(remote_table))?;

    ctx.sql("select * from remote_table").await?.show().await?;

    Ok(())
}

pub async fn try_new_with_schema( conn_options: impl Into<ConnectionOptions>, source: impl Into<TableSource>, table_schema: SchemaRef, ) -> Result<Self>

pub async fn try_new_with_remote_schema( conn_options: impl Into<ConnectionOptions>, source: impl Into<TableSource>, remote_schema: RemoteSchemaRef, ) -> Result<Self>

pub async fn try_new_with_transform( conn_options: impl Into<ConnectionOptions>, source: impl Into<TableSource>, transform: Arc<dyn Transform>, ) -> Result<Self>

pub async fn try_new_with_schema_transform_unparser( conn_options: impl Into<ConnectionOptions>, source: impl Into<TableSource>, table_schema: Option<SchemaRef>, remote_schema: Option<RemoteSchemaRef>, transform: Arc<dyn Transform>, unparser: Arc<dyn Unparse>, ) -> Result<Self>

pub fn remote_schema(&self) -> Option<RemoteSchemaRef>

Trait Implementations

impl Debug for RemoteTable

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

Formats the value using the given formatter.

impl TableProvider for RemoteTable

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 scan<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _state: &'life1 dyn Session, projection: Option<&'life2 Vec<usize>>, filters: &'life3 [Expr], limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<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 for scanning the table with optionally specified projection, filter and limit, described below.

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

Specify if DataFusion should provide filter expressions to the TableProvider to apply during the scan.

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

Get statistics for this table, if available Although not presently used in mainline DataFusion, this allows implementation specific behavior for downstream repositories, in conjunction with specialized optimizer rules to perform operations such as re-ordering of joins.

fn insert_into<'life0, 'life1, 'async_trait>( &'life0 self, _state: &'life1 dyn Session, input: Arc<dyn ExecutionPlan>, insert_op: InsertOp, ) -> Pin<Box<dyn Future<Output = Result<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 constraints(&self) -> Option<&Constraints>

Get a reference to the constraints of the table. Returns:

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

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

fn get_logical_plan(&self) -> Option<Cow<'_, LogicalPlan>>

Get the LogicalPlan of this table, if available.

fn get_column_default(&self, _column: &str) -> Option<&Expr>

Get the default value for a column, if available.