Type Alias ContinuousAggregateSource 

pub type ContinuousAggregateSource = Arc<dyn Fn(&str, u64, u64) -> Vec<RefreshPoint> + Send + Sync>;

Source-scan callback the engine uses to stream rows from the parent during refresh. Receiving the [start, end) window lets the callback restrict its scan — the core optimisation that makes refreshes incremental rather than full.

Aliased Type

pub struct ContinuousAggregateSource { /* private fields */ }