process_frame_batch

micromegas::client::frame_budget_reporting

Function process_frame_batch 

Source 
pub async fn process_frame_batch(
    ctx: &SessionContext,
    frames_rb: RecordBatch,
    process_id: &str,
) -> Result<(Vec<RecordBatch>, Vec<RecordBatch>)>
Expand description

Processes a batch of frames, computing frame statistics and extracting top offenders.

This function first computes frame statistics using compute_frame_stats_for_batch, then aggregates these statistics, and finally extracts top offenders.