Trait datafusion::physical_plan::metrics::RecordOutput

pub trait RecordOutput {
    // Required method
    fn record_output(self, bm: &BaselineMetrics) -> Self;
}

Trait for things that produce output rows as a result of execution.

Required Methods

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)

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl RecordOutput for Option<&RecordBatch>

fn record_output(self, bm: &BaselineMetrics) -> Option<&RecordBatch>

impl RecordOutput for Option<RecordBatch>

fn record_output(self, bm: &BaselineMetrics) -> Option<RecordBatch>

impl RecordOutput for Result<RecordBatch, DataFusionError>

fn record_output( self, bm: &BaselineMetrics ) -> Result<RecordBatch, DataFusionError>

impl RecordOutput for usize

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

Implementors

impl RecordOutput for &RecordBatch

impl RecordOutput for RecordBatch