Struct mz_adapter::optimize::subscribe::Optimizer

pub struct Optimizer {
    typecheck_ctx: SharedContext,
    catalog: Arc<dyn OptimizerCatalog>,
    compute_instance: ComputeInstanceSnapshot,
    sink_id: GlobalId,
    view_id: GlobalId,
    conn_id: Option<ConnectionId>,
    with_snapshot: bool,
    up_to: Option<Timestamp>,
    debug_name: String,
    config: OptimizerConfig,
    metrics: OptimizerMetrics,
    duration: Duration,
}

Fields

typecheck_ctx: SharedContext

A typechecking context to use throughout the optimizer pipeline.

catalog: Arc<dyn OptimizerCatalog>

A snapshot of the catalog state.

compute_instance: ComputeInstanceSnapshot

A snapshot of the cluster that will run the dataflows.

sink_id: GlobalId

A transient GlobalId to be used for the exported sink.

view_id: GlobalId

A transient GlobalId to be used when constructing a dataflow for SUBSCRIBE FROM <SELECT> variants.

conn_id: Option<ConnectionId>

The id of the session connection in which the optimizer will run.

with_snapshot: bool

Should the plan produce an initial snapshot?

up_to: Option<Timestamp>

Sink timestamp.

debug_name: String

A human-readable name exposed internally (useful for debugging).

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<dyn OptimizerCatalog>, compute_instance: ComputeInstanceSnapshot, view_id: GlobalId, sink_id: GlobalId, conn_id: Option<ConnectionId>, with_snapshot: bool, up_to: Option<Timestamp>, debug_name: String, config: OptimizerConfig, metrics: OptimizerMetrics, ) -> Self

pub fn cluster_id(&self) -> ComputeInstanceId

pub fn up_to(&self) -> Option<Timestamp>

Trait Implementations

impl Debug for Optimizer

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

Formats the value using the given formatter.

impl Optimize<GlobalMirPlan<Resolved>> for Optimizer

type To = GlobalLirPlan

fn optimize( &mut self, plan: GlobalMirPlan<Resolved>, ) -> 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 Optimize<SubscribeFrom> for Optimizer

type To = GlobalMirPlan<Unresolved>

fn optimize(&mut self, plan: SubscribeFrom) -> 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.