window.rs

fn window_sum(buffer: &[u64]) -> u64 {
    buffer.iter().sum()
}

#[arcon::app]
fn main() {
    (0u64..100000)
        .to_stream(|conf| {
            conf.set_arcon_time(ArconTime::Event);
            conf.set_timestamp_extractor(|x: &u64| *x);
        })
        .operator(OperatorBuilder {
            operator: Arc::new(|| {
                let conf = WindowConf {
                    assigner: Assigner::Sliding {
                        length: Time::seconds(1000),
                        slide: Time::seconds(500),
                        late_arrival: Time::seconds(0),
                    },
                };
                WindowAssigner::new(conf)
            }),
            state: Arc::new(|backend| {
                let index = AppenderWindow::new(backend.clone(), &window_sum);
                WindowState::new(index, backend)
            }),
            conf: OperatorConf::default(),
        })
        .print()
}