Struct LogicalMssqlQuery 

pub struct LogicalMssqlQuery {
    pub base: PlanBase<Logical>,
    pub core: MssqlQuery,
}

Logical plan node for the mssql_query table function. The user query is run exactly once by the batch executor; streaming mode is rejected.

Fields

base: PlanBase<Logical>

core: MssqlQuery

Implementations

impl LogicalMssqlQuery

pub fn new( ctx: OptimizerContextRef, schema: Schema, connection: MssqlConnection, query: String, ) -> Self

Build a LogicalMssqlQuery from the pre-discovered schema, the SQL Server connection parameters, the user query, and the optimizer context.

connection groups the seven inline connection parameters; the 2-arg source-reference form instead reuses connection parameters from the named source (and is rewritten by the binder, not here).

Methods from Deref<Target = PlanBase<Logical>>

pub fn clone_with_new_plan_id(&self) -> Self

pub fn clone_with_new_distribution(&self, dist: Distribution) -> Self

Clone the plan node with a new distribution.

Panics if the plan node is not physical.

Trait Implementations

impl Clone for LogicalMssqlQuery

fn clone(&self) -> LogicalMssqlQuery

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ColPrunable for LogicalMssqlQuery

fn prune_col( &self, required_cols: &[usize], _ctx: &mut ColumnPruningContext, ) -> PlanRef

Column pruning wraps the node in a LogicalProject that keeps only the requested columns. The executor always returns the full schema discovered at bind time; pruning happens in the project above.

impl Debug for LogicalMssqlQuery

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

Formats the value using the given formatter.

impl Deref for LogicalMssqlQuery

type Target = PlanBase<Logical>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Distill for LogicalMssqlQuery

fn distill<'a>(&self) -> XmlNode<'a>

Pretty-print the node as LogicalMssqlQuery { columns: [...] } for EXPLAIN output.

fn distill_to_string(&self) -> String

impl Eq for LogicalMssqlQuery

impl ExprRewritable<Logical> for LogicalMssqlQuery

fn has_rewritable_expr(&self) -> bool

fn rewrite_exprs(&self, _r: &mut dyn ExprRewriter) -> PlanRef<C>

impl ExprVisitable for LogicalMssqlQuery

fn visit_exprs(&self, _v: &mut dyn ExprVisitor)

impl Hash for LogicalMssqlQuery

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 LogicalPlanNode for LogicalMssqlQuery

impl PartialEq for LogicalMssqlQuery

fn eq(&self, other: &LogicalMssqlQuery) -> 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 PlanNodeMeta for LogicalMssqlQuery

const NODE_TYPE: LogicalPlanNodeType = LogicalPlanNodeType::LogicalMssqlQuery

type Convention = Logical

fn plan_base(&self) -> &PlanBase<Logical>

Get the reference to the PlanBase with corresponding convention.

impl PlanTreeNode<Logical> for LogicalMssqlQuery

fn clone_with_inputs(&self, inputs: &[PlanRef<Logical>]) -> PlanRef<Logical>

Clone the node with a list of new inputs.

fn inputs(&self) -> SmallVec<[PlanRef<Logical>; 2]>

Get input nodes of the plan.

impl PredicatePushdown for LogicalMssqlQuery

fn predicate_pushdown( &self, predicate: Condition, _ctx: &mut PredicatePushdownContext, ) -> PlanRef

mssql_query does not support predicate pushdown — the user query is opaque to the optimizer. Wrap with LogicalFilter so the predicate is applied to the result of the query.

impl StructuralPartialEq for LogicalMssqlQuery

impl ToBatch for LogicalMssqlQuery

fn to_batch(&self) -> Result<BatchPlanRef>

Lower to a BatchMssqlQuery plan node that the batch executor (MssqlQueryExecutor) will consume.

fn to_batch_with_order_required( &self, required_order: &Order, ) -> Result<BatchPlanRef>

convert the plan to batch physical plan and satisfy the required Order

impl ToStream for LogicalMssqlQuery

fn to_stream(&self, _ctx: &mut ToStreamContext) -> Result<StreamPlanRef>

Reject streaming conversion with a clear error — mssql_query is batch-only. Streaming CDC ingestion should use the sqlserver-cdc source instead.

fn logical_rewrite_for_stream( &self, _ctx: &mut RewriteStreamContext, ) -> Result<(PlanRef, ColIndexMapping)>

mssql_query is batch-only; refuse the streaming rewrite as well.

fn to_stream_with_dist_required( &self, required_dist: &RequiredDist, ctx: &mut ToStreamContext, ) -> Result<StreamPlanRef>

convert the plan to streaming physical plan and satisfy the required distribution

fn try_better_locality(&self, _columns: &[usize]) -> Option<LogicalPlanRef>