ExecutorMetricsCollector

kapot_executor::metrics

Trait ExecutorMetricsCollector 

Source 
pub trait ExecutorMetricsCollector: Send + Sync {
    // Required method
    fn record_stage(
        &self,
        job_id: &str,
        stage_id: usize,
        partition: usize,
        plan: Arc<dyn QueryStageExecutor>,
    );
}
Expand description

ExecutorMetricsCollector records metrics for ShuffleWriteExec after they are executed.

After each stage completes, ShuffleWriteExec::record_stage will be called.

Required Methods§

Source

fn record_stage( &self, job_id: &str, stage_id: usize, partition: usize, plan: Arc<dyn QueryStageExecutor>, )

Record metrics for stage after it is executed

Implementors§