Struct SnapshotSummaryCollector

pub struct SnapshotSummaryCollector { /* private fields */ }

SnapshotSummaryCollector collects and aggregates snapshot update metrics. It gathers metrics about added or removed data files and manifests, and tracks partition-specific updates.

Implementations

impl SnapshotSummaryCollector

pub fn set(&mut self, key: &str, value: &str)

Set properties for snapshot summary

pub fn set_partition_summary_limit(&mut self, limit: u64)

Sets the limit for including partition summaries. Summaries are not included if the number of partitions is exceeded.

pub fn add_file( &mut self, data_file: &DataFile, schema: SchemaRef, partition_spec: PartitionSpecRef, )

Adds a data file to the summary collector

pub fn remove_file( &mut self, data_file: &DataFile, schema: SchemaRef, partition_spec: PartitionSpecRef, )

Removes a data file from the summary collector

pub fn add_manifest(&mut self, manifest: &ManifestFile)

Adds a manifest to the summary collector

pub fn update_partition_metrics( &mut self, schema: SchemaRef, partition_spec: PartitionSpecRef, data_file: &DataFile, is_add_file: bool, )

Updates partition-specific metrics for a data file.

pub fn merge(&mut self, summary: SnapshotSummaryCollector)

Merges another SnapshotSummaryCollector into the current one

pub fn build(&self) -> HashMap<String, String>

Builds final map of summaries

Trait Implementations

impl Default for SnapshotSummaryCollector

fn default() -> SnapshotSummaryCollector

Returns the “default value” for a type.