Skip to main content

Module refresh_progress_table

Module refresh_progress_table 

Source
Expand description

Refresh Progress Table

This module implements a persistent table for tracking refresh operation progress. It stores the merge position of each VirtualNode during a refresh cycle. Within a cycle the merge resumes from it after every barrier; a refresh interrupted by recovery is currently abandoned by meta rather than resumed from it.

Structs§

RefreshProgressEntry
Progress information for a single VirtualNode
RefreshProgressStats
Progress statistics for monitoring
RefreshProgressTable
Schema for the refresh progress table (simplified, following backfill pattern):

Enums§

ProgressRefreshStage
Refresh stages are now tracked by MaterializeExecutor in memory This enum is kept for compatibility but no longer stored in progress table