Trait RegionScanner 

pub trait RegionScanner:
    Debug
    + DisplayAs
    + Send {
    // Required methods
    fn properties(&self) -> &ScannerProperties;
    fn schema(&self) -> SchemaRef;
    fn metadata(&self) -> RegionMetadataRef;
    fn prepare(&mut self, request: PrepareRequest) -> Result<(), BoxedError>;
    fn scan_partition(
        &self,
        ctx: &QueryScanContext,
        metrics_set: &ExecutionPlanMetricsSet,
        partition: usize,
    ) -> Result<SendableRecordBatchStream, BoxedError>;
    fn has_predicate_without_region(&self) -> bool;
    fn set_logical_region(&mut self, logical_region: bool);
}

A scanner that provides a way to scan the region concurrently.

The scanner splits the region into partitions so that each partition can be scanned concurrently. You can use this trait to implement an ExecutionPlan.

Required Methods

fn properties(&self) -> &ScannerProperties

Returns the properties of the scanner.

fn schema(&self) -> SchemaRef

Returns the schema of the record batches.

fn metadata(&self) -> RegionMetadataRef

Returns the metadata of the region.

fn prepare(&mut self, request: PrepareRequest) -> Result<(), BoxedError>

Prepares the scanner with the given partition ranges.

This method is for the planner to adjust the scanner’s behavior based on the partition ranges.

fn scan_partition( &self, ctx: &QueryScanContext, metrics_set: &ExecutionPlanMetricsSet, partition: usize, ) -> Result<SendableRecordBatchStream, BoxedError>

Scans the partition and returns a stream of record batches.

Panics

Panics if the partition is out of bound.

fn has_predicate_without_region(&self) -> bool

Check if there is any predicate exclude region partition exprs that may be executed in this scanner.

fn set_logical_region(&mut self, logical_region: bool)

Sets whether the scanner is reading a logical region.

Implementors

impl RegionScanner for SinglePartitionScanner