Skip to main content

process_batch_sql

Function process_batch_sql 

Source
pub fn process_batch_sql(
    process_id: &Uuid,
    stream_tag: &str,
    range: &TimeRange,
) -> String
Expand description

The process-variant batch query: block columns plus stream_id only – no stream-level column (streams.dependencies_metadata/objects_metadata/tags/properties/format) may be added to the SELECT list. Re-adding one would reintroduce the per-row stream-blob-copy memory hazard the lean projection removes, with no test failing except the projection guard in analytics/tests/jit_batch_windows_tests.rs. array_has("streams.tags", ...) stays in the WHERE clause: filtering needs no projection.