Enum CpuPreparedDataset 

pub enum CpuPreparedDataset {
    Resident {
        dataset: Arc<CpuCachedDataset>,
        stats: PreparedDatasetStats,
        memory_lease: MemoryLease,
    },
    Streaming {
        dataset: Dataset,
        read_plan: ReadPlan,
        stats: PreparedDatasetStats,
        transient_bytes: u64,
    },
}

A dataset prepared according to its CacheStorage policy.

Resident datasets own all event-dependent cache values. Streaming datasets retain the source and read plan and rebuild transient batch caches on every reduction.

Variants

Resident

A dataset whose event caches are resident in memory.

Fields

dataset: Arc<CpuCachedDataset>

Fully cached dataset.

stats: PreparedDatasetStats

Preparation statistics.

memory_lease: MemoryLease

Persistent host-memory reservation shared by clones.

Streaming

A dataset whose event caches are rebuilt while streaming.

Fields

dataset: Dataset

Source dataset.

read_plan: ReadPlan

Read plan used for each pass.

stats: PreparedDatasetStats

Preparation statistics.

transient_bytes: u64

Peak transient bytes reserved during each reduction.

Implementations

impl CpuPreparedDataset

pub fn stats(&self) -> &PreparedDatasetStats

Returns statistics collected while preparing the dataset.

Trait Implementations

impl Clone for CpuPreparedDataset

fn clone(&self) -> CpuPreparedDataset

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CpuPreparedDataset

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

Formats the value using the given formatter.