Struct mz_transform::Optimizer
source · Expand description
A naive optimizer for relation expressions.
The optimizer currently applies only peep-hole optimizations, from a limited set that were sufficient to get some of TPC-H up and working. It is worth a review at some point to improve the quality, coverage, and architecture of the optimizations.
Fields§
§name: &'static str
A logical name identifying this optimizer instance.
transforms: Vec<Box<dyn Transform>>
The list of transforms to apply to an input relation.
Implementations§
source§impl Optimizer
impl Optimizer
sourcepub fn logical_optimizer() -> Self
pub fn logical_optimizer() -> Self
Builds a logical optimizer that only performs logical transformations.
sourcepub fn physical_optimizer() -> Self
pub fn physical_optimizer() -> Self
Builds a physical optimizer.
Performs logical transformations followed by all physical ones. This is meant to be used for optimizing each view within a dataflow once view inlining has already happened, right before dataflow rendering.
sourcepub fn logical_cleanup_pass() -> Self
pub fn logical_cleanup_pass() -> Self
Contains the logical optimizations that should run after cross-view transformations run.
sourcepub fn optimize(
&self,
relation: MirRelationExpr
) -> Result<OptimizedMirRelationExpr, TransformError>
pub fn optimize(
&self,
relation: MirRelationExpr
) -> Result<OptimizedMirRelationExpr, TransformError>
Optimizes the supplied relation expression.
These optimizations are performed with no information about available arrangements, which makes them suitable for pre-optimization before dataflow deployment.
sourcepub(crate) fn transform(
&self,
relation: &mut MirRelationExpr,
indexes: &dyn IndexOracle
) -> Result<(), TransformError>
pub(crate) fn transform(
&self,
relation: &mut MirRelationExpr,
indexes: &dyn IndexOracle
) -> Result<(), TransformError>
Optimizes the supplied relation expression in place, using available arrangements.
This method should only be called with non-empty indexes
when optimizing a dataflow,
as the optimizations may lock in the use of arrangements that may cease to exist.
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for Optimizer
impl !Send for Optimizer
impl !Sync for Optimizer
impl Unpin for Optimizer
impl !UnwindSafe for Optimizer
Blanket Implementations§
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
RustType::into_proto
.