Struct StreamingVoxelSource 

pub struct StreamingVoxelSource { /* private fields */ }

Bounded source of globally aggregated voxel centroids.

Construction consumes the upstream stream into sorted fixed-width runs. Output is then produced by a deterministic k-way merge ordered by (voxel key, source point offset).

Implementations

impl StreamingVoxelSource

pub fn try_build<S>( source: S, config: StreamingVoxelConfig, ) -> Result<StreamingVoxelSource, RecordsError>

where S: BoundedSpatialRecordSource,

Builds sorted runs from source under shared memory and disk budgets.

pub const fn spool_bytes(&self) -> u64

Returns the fixed-width temporary spill extent.

pub fn run_count(&self) -> usize

Returns the number of sorted runs participating in the merge.

Trait Implementations

impl BoundedSpatialRecordSource for StreamingVoxelSource

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<Result<SpatialRecordChunk, RecordsError>>

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