Struct UnorderedScan

pub struct UnorderedScan {
    properties: ScannerProperties,
    stream_ctx: Arc<StreamContext>,
    metrics_list: PartitionMetricsList,
}

Scans a region without providing any output ordering guarantee.

Only an append only table should use this scanner.

Fields

properties: ScannerProperties

Properties of the scanner.

stream_ctx: Arc<StreamContext>

Context of streams.

metrics_list: PartitionMetricsList

Metrics for each partition.

Implementations

impl UnorderedScan

pub(crate) fn new(input: ScanInput) -> Self

Creates a new UnorderedScan.

pub(crate) async fn build_stream( &self, ) -> Result<SendableRecordBatchStream, BoxedError>

Scans the region and returns a stream.

fn scan_partition_range( stream_ctx: Arc<StreamContext>, part_range_id: usize, part_metrics: PartitionMetrics, range_builder_list: Arc<RangeBuilderList>, ) -> impl Stream<Item = Result<Batch>>

Scans a [PartitionRange] by its identifier and returns a stream.

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

Trait Implementations

impl Debug for UnorderedScan

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl DisplayAs for UnorderedScan

fn fmt_as(&self, t: DisplayFormatType, f: &mut Formatter<'_>) -> Result

Format according to DisplayFormatType, used when verbose representation looks different from the default one

impl RegionScanner for UnorderedScan

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.

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

Scans the partition and returns a stream of record batches.

fn has_predicate(&self) -> bool

Check if there is any predicate 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.