Skip to main content

validate_metric_sink_desc

Function validate_metric_sink_desc 

Source
pub fn validate_metric_sink_desc(desc: &RelationDesc) -> Result<(), PlanError>
Expand description

Checks that desc exposes the canonical metric-sink columns, the contract mz_adapter::optimize::metric_sink’s row shaping and the compute-side operator both rely on.

Every metric-sink source has to pass this, whether it is the FROM relation of a CREATE METRIC SINK or the query behind a coordinator-installed curated sink.