cda-group / arcon

State-first Streaming Applications in Rust
https://cda-group.github.io/arcon/
Apache License 2.0
175 stars 17 forks source link

Remove explicit key parameter on Timer #293

Closed Max-Meldrum closed 2 years ago

Max-Meldrum commented 2 years ago

Currently, it is possible to give the key to the timer. This should be set by the runtime.

One timer per (key, timestamp) data point.

pub fn schedule_at<I: Into<u64>>(
        &mut self,
        key: I,
        time: u64,
        entry: TimerState,
) -> TimerResult<TimerState> {
   self.timer.schedule_at(key.into(), time, entry)
}