Struct ParquetStore 

pub struct ParquetStore { /* private fields */ }

Parquet storage for Garmin data

Supports concurrent writes to different partitions. Each partition has its own lock to prevent lost updates when multiple workers write to the same partition.

Implementations

impl ParquetStore

pub fn new(base_path: impl Into<PathBuf>) -> Self

Create a new ParquetStore at the given base path

pub fn has_daily_health(&self, profile_id: i32, date: NaiveDate) -> Result<bool>

Check if daily health data exists for a profile/date

pub fn has_performance_metrics( &self, profile_id: i32, date: NaiveDate, ) -> Result<bool>

Check if performance metrics exist for a profile/date

pub fn has_track_points( &self, activity_id: i64, date: NaiveDate, ) -> Result<bool>

Check if track points exist for an activity/date partition

pub fn partition_path(&self, entity: EntityType, partition_key: &str) -> PathBuf

Get the full path for a partition file

pub fn write_activities(&self, activities: &[Activity]) -> Result<()>

Write activities to weekly partitions

pub fn upsert_activities(&self, activities: &[Activity]) -> Result<()>

Upsert activities (read existing, merge, write)

pub async fn upsert_activities_async( &self, activities: &[Activity], ) -> Result<()>

Upsert activities with partition-level locking for concurrent writes

pub fn upsert_daily_health(&self, records: &[DailyHealth]) -> Result<()>

Upsert daily health records

pub async fn upsert_daily_health_async( &self, records: &[DailyHealth], ) -> Result<()>

Upsert daily health records with partition-level locking for concurrent writes

pub fn write_track_points( &self, activity_date: NaiveDate, points: &[TrackPoint], ) -> Result<()>

Write track points for an activity

pub async fn write_track_points_async( &self, activity_date: NaiveDate, points: &[TrackPoint], ) -> Result<()>

Write track points with partition-level locking for concurrent writes

pub fn upsert_performance_metrics( &self, records: &[PerformanceMetrics], ) -> Result<()>

Upsert performance metrics records

pub async fn upsert_performance_metrics_async( &self, records: &[PerformanceMetrics], ) -> Result<()>

Upsert performance metrics records with partition-level locking for concurrent writes

pub fn upsert_weight(&self, records: &[WeightEntry]) -> Result<()>

Upsert weight entries

pub fn write_profiles(&self, profiles: &[Profile]) -> Result<()>

Write profiles (overwrites entire file)

pub fn read_profiles(&self) -> Result<Vec<Profile>>

Read all profiles

pub fn base_path(&self) -> &Path

Get the base path for external readers to use with DuckDB glob queries

Trait Implementations

impl Clone for ParquetStore

fn clone(&self) -> ParquetStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.