Struct MemoryChunkSource 

pub struct MemoryChunkSource { /* private fields */ }

Splits one in-memory cloud into fixed-size record chunks.

Implementations

impl MemoryChunkSource

pub fn try_new( schema: SchemaDescriptor, cloud: PointCloud, chunk_size: usize, ) -> RecordsResult<Self>

Creates a chunked source over cloud using chunk_size points per record.

pub fn try_new_with_provenance( schema: SchemaDescriptor, cloud: PointCloud, chunk_size: usize, provenance: RecordProvenance, ) -> RecordsResult<Self>

Creates a chunked source with explicit lineage copied to every chunk.

pub fn try_with_default_chunk( schema: SchemaDescriptor, cloud: PointCloud, ) -> RecordsResult<Self>

Creates a source using SpatialTensor’s default chunk size as a hint.

Trait Implementations

impl SpatialRecordSource for MemoryChunkSource

fn schema(&self) -> &SchemaDescriptor

Returns the schema contract for every emitted record.

fn next_record(&mut self) -> Option<RecordsResult<SpatialRecord>>

Returns the next record, or None when exhausted.