Trait BoundedSpatialRecordSource 

pub trait BoundedSpatialRecordSource {
    // Required methods
    fn schema(&self) -> &SchemaDescriptor;
    fn options(&self) -> &StreamOptions;
    fn memory_tracker(&self) -> &MemoryTracker;
    fn cancellation_token(&self) -> CancellationToken;
    fn max_chunk_bytes(&self) -> u64;
    fn next_chunk(&mut self) -> Option<RecordsResult<SpatialRecordChunk>>;
}

Pull-based bounded source. Existing SpatialRecordSource remains unchanged.

Required Methods

fn schema(&self) -> &SchemaDescriptor

Schema shared by every emitted record.

fn options(&self) -> &StreamOptions

Validated execution options.

fn memory_tracker(&self) -> &MemoryTracker

Exact tracker shared by emitted chunk leases.

fn cancellation_token(&self) -> CancellationToken

Cooperative cancellation state checked at chunk boundaries.

fn max_chunk_bytes(&self) -> u64

Conservative maximum resident bytes for one emitted chunk.

fn next_chunk(&mut self) -> Option<RecordsResult<SpatialRecordChunk>>

Returns the next leased chunk, or None after an explicit end.

Implementations on Foreign Types

impl<S: BoundedSpatialRecordSource + ?Sized> BoundedSpatialRecordSource for Box<S>

fn schema(&self) -> &SchemaDescriptor

fn options(&self) -> &StreamOptions

fn memory_tracker(&self) -> &MemoryTracker

fn cancellation_token(&self) -> CancellationToken

fn max_chunk_bytes(&self) -> u64

fn next_chunk(&mut self) -> Option<RecordsResult<SpatialRecordChunk>>

Implementors

impl BoundedSpatialRecordSource for PrefetchRecordSource

impl BoundedSpatialRecordSource for RecyclingMemoryChunkSource

impl<S: SpatialRecordSource> BoundedSpatialRecordSource for LegacyBoundedSource<S>