Struct mz_adapter::optimize::copy_to::Optimizer

pub struct Optimizer {
    typecheck_ctx: SharedContext,
    catalog: Arc<Catalog>,
    compute_instance: ComputeInstanceSnapshot,
    select_id: GlobalId,
    copy_to_context: CopyToContext,
    config: OptimizerConfig,
    metrics: OptimizerMetrics,
    duration: Duration,
}

Fields

typecheck_ctx: SharedContext

A typechecking context to use throughout the optimizer pipeline.

catalog: Arc<Catalog>

A snapshot of the catalog state.

compute_instance: ComputeInstanceSnapshot

A snapshot of the cluster that will run the dataflows.

select_id: GlobalId

A transient GlobalId to be used when constructing the dataflow.

copy_to_context: CopyToContext

Data required to do a COPY TO query.

config: OptimizerConfig

Optimizer config.

metrics: OptimizerMetrics

Optimizer metrics.

duration: Duration

The time spent performing optimization so far.

Implementations

impl Optimizer

pub fn new( catalog: Arc<Catalog>, compute_instance: ComputeInstanceSnapshot, select_id: GlobalId, copy_to_context: CopyToContext, config: OptimizerConfig, metrics: OptimizerMetrics, ) -> Self

pub fn cluster_id(&self) -> ComputeInstanceId

Trait Implementations

impl Debug for Optimizer

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

Formats the value using the given formatter.

impl Optimize<HirRelationExpr> for Optimizer

type To = LocalMirPlan

fn optimize( &mut self, expr: HirRelationExpr, ) -> Result<Self::To, OptimizerError>

Execute the optimization stage, transforming the input plan of type From to an output plan of type To.

fn catch_unwind_optimize( &mut self, plan: From, ) -> Result<Self::To, OptimizerError>

Like Self::optimize, but additionally ensures that panics occurring in the Self::optimize call are caught and demoted to an OptimizerError::Internal error.

fn must_optimize(&mut self, expr: From) -> Self::To

Execute the optimization stage and panic if an error occurs.

impl<'s> Optimize<LocalMirPlan<Resolved<'s>>> for Optimizer

type To = GlobalLirPlan

fn optimize( &mut self, plan: LocalMirPlan<Resolved<'s>>, ) -> Result<Self::To, OptimizerError>

Execute the optimization stage, transforming the input plan of type From to an output plan of type To.

fn catch_unwind_optimize( &mut self, plan: From, ) -> Result<Self::To, OptimizerError>

Like Self::optimize, but additionally ensures that panics occurring in the Self::optimize call are caught and demoted to an OptimizerError::Internal error.

fn must_optimize(&mut self, expr: From) -> Self::To

Execute the optimization stage and panic if an error occurs.