Skip to main content

scan_metrics

risingwave_stream::executor::source::iceberg_update

Function scan_metrics 

Source 
fn scan_metrics(
    core: &StreamSourceCore<impl StateStore>,
    properties: &IcebergProperties,
) -> IcebergScanMetricsLabels