Struct JoinedSource 

pub struct JoinedSource { /* private fields */ }

A data source that represents the join of multiple tables

Implementations

impl JoinedSource

pub fn builder() -> JoinedSourceBuilder

Create a new builder for configuring joined sources

pub fn left_alias(&self) -> &str

Get the left table alias

pub fn right_alias(&self) -> &str

Get the right table alias

pub fn join_condition(&self) -> &JoinCondition

Get the join condition

pub fn generate_sql(&self, table_name: &str) -> String

Generate SQL query for the joined tables

Trait Implementations

impl Clone for JoinedSource

fn clone(&self) -> JoinedSource

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DataSource for JoinedSource

fn register_with_telemetry<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, table_name: &'life2 str, telemetry: Option<&'life3 Arc<TermTelemetry>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Registers this data source with telemetry support.

fn schema(&self) -> Option<&Arc<Schema>>

Returns the schema of this data source if known.

fn description(&self) -> String

Returns a human-readable description of this data source.

fn register<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, table_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Registers this data source with the given session context.

impl Debug for JoinedSource

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

Formats the value using the given formatter.