Trait datafusion::physical_plan::metrics::RecordOutput
source · pub trait RecordOutput {
// Required method
fn record_output(self, bm: &BaselineMetrics) -> Self;
}Expand description
Trait for things that produce output rows as a result of execution.
Required Methods§
sourcefn record_output(self, bm: &BaselineMetrics) -> Self
fn record_output(self, bm: &BaselineMetrics) -> Self
Record that some number of output rows have been produced
Meant to be composable so that instead of returning batch
the operator can return batch.record_output(baseline_metrics)