Struct BatchMssqlQuery 

pub struct BatchMssqlQuery {
    pub base: PlanBase<Batch>,
    pub core: MssqlQuery,
}

Batch plan node for the mssql_query table function. The actual SQL Server round-trip is performed by MssqlQueryExecutor; this node only carries the connection parameters, the pre-discovered column schema (from describe_mssql_query), and the user query.

Fields

base: PlanBase<Batch>

core: MssqlQuery

Implementations

impl BatchMssqlQuery

pub fn new(core: MssqlQuery) -> Self

Build a new BatchMssqlQuery plan node. The plan runs on a single fragment (Distribution::Single) with no specific row order; the executor returns whatever order SQL Server produces.

pub fn column_names(&self) -> Vec<&str>

Names of the result columns as discovered at bind time. For unnamed columns like SELECT COUNT(*) FROM t these are the synthetic column_N names produced by describe_mssql_query.

pub fn clone_with_dist(&self) -> Self

Return a clone of this node with Distribution::Single. Used by ToLocalBatch / ToDistributedBatch because the underlying mssql_query always runs on a single fragment.

Methods from Deref<Target = PlanBase<Batch>>

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 BatchPlanNode for BatchMssqlQuery

impl Clone for BatchMssqlQuery

fn clone(&self) -> BatchMssqlQuery

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchMssqlQuery

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

Formats the value using the given formatter.

impl Deref for BatchMssqlQuery

type Target = PlanBase<Batch>

The resulting type after dereferencing.

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

Dereferences the value.

impl Distill for BatchMssqlQuery

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

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

fn distill_to_string(&self) -> String

impl Eq for BatchMssqlQuery

impl ExprRewritable<Batch> for BatchMssqlQuery

fn has_rewritable_expr(&self) -> bool

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

impl ExprVisitable for BatchMssqlQuery

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

impl Hash for BatchMssqlQuery

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 BatchMssqlQuery

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

const NODE_TYPE: BatchPlanNodeType = BatchPlanNodeType::BatchMssqlQuery

type Convention = Batch

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

Get the reference to the PlanBase with corresponding convention.

impl PlanTreeNode<Batch> for BatchMssqlQuery

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

Clone the node with a list of new inputs.

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

Get input nodes of the plan.

impl StructuralPartialEq for BatchMssqlQuery

impl ToBatchPb for BatchMssqlQuery

fn to_batch_prost_body(&self) -> NodeBody

Serialize the node into a NodeBody::MssqlQuery proto for the batch task. encrypt / trust_cert have already been parsed and validated by the binder and are carried as booleans in the plan.

impl ToDistributedBatch for BatchMssqlQuery

fn to_distributed(&self) -> Result<PlanRef>

mssql_query always runs on a single fragment; the distributed plan is a clone with the single-node distribution.

fn to_distributed_with_required( &self, required_order: &Order, required_dist: &RequiredDist, ) -> Result<BatchPlanRef>

insert the exchange in batch physical plan to satisfy the required Distribution and Order.

impl ToLocalBatch for BatchMssqlQuery

fn to_local(&self) -> Result<PlanRef>

mssql_query always runs on a single fragment; the local plan is a clone with the single-node distribution.

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

Convert the plan to batch local physical plan and satisfy the required Order