pub struct AdaptiveExecutionConfig {
pub checkpoints: Vec<AdaptiveCheckpoint>,
pub config: AdaptivePipelineConfig,
pub context: AdaptiveContext,
pub event_callback: Option<AdaptiveEventCallback>,
}Expand description
Configuration for adaptive execution, built by AdaptivePipelineBuilder.
Fields§
§checkpoints: Vec<AdaptiveCheckpoint>Checkpoints for monitoring cardinality.
config: AdaptivePipelineConfigExecution configuration.
context: AdaptiveContextAdaptive context with estimates.
event_callback: Option<AdaptiveEventCallback>Optional event callback.
Implementations§
Source§impl AdaptiveExecutionConfig
impl AdaptiveExecutionConfig
Sourcepub fn summary(&self) -> AdaptiveSummary
pub fn summary(&self) -> AdaptiveSummary
Returns a summary of the adaptive execution after it completes.
Sourcepub fn record_checkpoint(&mut self, checkpoint_id: &str, actual: u64)
pub fn record_checkpoint(&mut self, checkpoint_id: &str, actual: u64)
Records actual cardinality for a checkpoint.
Sourcepub fn should_reoptimize(&self) -> Option<&AdaptiveCheckpoint>
pub fn should_reoptimize(&self) -> Option<&AdaptiveCheckpoint>
Checks if any checkpoint exceeds the deviation threshold.
Sourcepub fn mark_triggered(&mut self, checkpoint_id: &str)
pub fn mark_triggered(&mut self, checkpoint_id: &str)
Marks a checkpoint as having triggered re-optimization.
Auto Trait Implementations§
impl Freeze for AdaptiveExecutionConfig
impl !RefUnwindSafe for AdaptiveExecutionConfig
impl Send for AdaptiveExecutionConfig
impl Sync for AdaptiveExecutionConfig
impl Unpin for AdaptiveExecutionConfig
impl !UnwindSafe for AdaptiveExecutionConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more