arcon 0.2.1

A runtime for writing streaming applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

pub mod assigner;

pub use assigner::{WindowAssigner, WindowState};

use fxhash::FxHasher;
use std::hash::{Hash, Hasher};

#[derive(prost::Message, Hash, PartialEq, Eq, Copy, Clone)]
pub struct WindowContext {
    #[prost(uint64)]
    pub key: u64,
    #[prost(uint64)]
    pub index: u64,
}

impl WindowContext {
    pub fn new(key: u64, index: u64) -> Self {
        WindowContext { key, index }
    }
}

impl From<WindowContext> for u64 {
    fn from(ctx: WindowContext) -> Self {
        let mut s = FxHasher::default();
        ctx.hash(&mut s);
        s.finish()
    }
}