datafusion_physical_plan::metrics

Trait 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§

Source

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)

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types§

Source§

impl RecordOutput for &RecordBatch

Source§

fn record_output(self, bm: &BaselineMetrics) -> Self

Source§

impl RecordOutput for Option<&RecordBatch>

Source§

fn record_output(self, bm: &BaselineMetrics) -> Self

Source§

impl RecordOutput for Option<RecordBatch>

Source§

fn record_output(self, bm: &BaselineMetrics) -> Self

Source§

impl RecordOutput for usize

Source§

fn record_output(self, bm: &BaselineMetrics) -> Self

Source§

impl RecordOutput for RecordBatch

Source§

fn record_output(self, bm: &BaselineMetrics) -> Self

Source§

impl RecordOutput for Result<RecordBatch>

Source§

fn record_output(self, bm: &BaselineMetrics) -> Self

Implementors§