journey_query

Function journey_query 

Source
pub fn journey_query(
    conn: &Connection,
    correlation_id: &str,
    from_ms: Option<i64>,
    to_ms: Option<i64>,
) -> Result<Vec<JourneyRow>>
Expand description

Execute a journey/funnel query (DW-093): return all raw records matching a correlation id, ordered by time ascending. Optional time range filter narrows the scan. Reads the RAW raw table directly (journey analysis is per-request, not rolled up). The correlation_id index keeps the scan bounded.