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
sourceimpl 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(
&mut self,
relation: MirRelationExpr
) -> Result<OptimizedMirRelationExpr, TransformError>
pub fn optimize(
&mut 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.
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
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
sourceimpl<P, R> ProtoType<R> for P where
R: RustType<P>,
impl<P, R> ProtoType<R> for P where
R: RustType<P>,
sourcefn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See RustType::from_proto
.
sourcefn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See RustType::into_proto
.
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more