Skip to main content

capture_recovery_batch_windows

flow::batching_mode::task

Function capture_recovery_batch_windows 

Source 
fn capture_recovery_batch_windows(
    batch: &RecordBatch,
    time_window_expr: &TimeWindowExpr,
    windows: &mut BTreeSet<(Timestamp, Timestamp)>,
) -> Result<(), Error>