Skip to main content

InspectSource

datanode::region_server::catalog::inspect

Trait InspectSource 

Source 
pub(crate) trait InspectSource:
    Debug
    + Send
    + Sync {
    // Required methods
    fn schema(&self) -> SchemaRef;
    fn scan(
        &self,
        request: &InspectScan,
        ctx: Arc<TaskContext>,
    ) -> SendableRecordBatchStream;
}
Expand description

Supplies batches for an internal inspection table. Implementations may prune conservatively; DataFusion retains complete residual predicates.

Required Methods§

Source

fn schema(&self) -> SchemaRef

Source

fn scan( &self, request: &InspectScan, ctx: Arc<TaskContext>, ) -> SendableRecordBatchStream

Creates a fresh scan at execution time, including on repeated execution. Projection includes columns required by residual predicates.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§