oxigdal-streaming 0.1.4

Real-time data processing and streaming pipelines for OxiGDAL
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

//! Windowing and watermarking for event-time processing.

mod session;
mod sliding;
mod tumbling;
mod watermark;
mod window;

pub use session::{SessionAssigner, SessionWindow, SessionWindowConfig};
pub use sliding::{SlidingAssigner, SlidingWindow, SlidingWindowConfig};
pub use tumbling::{TumblingAssigner, TumblingWindow, TumblingWindowConfig};
pub use watermark::{
    MultiSourceWatermarkManager, PeriodicWatermarkGenerator, PunctuatedWatermarkGenerator,
    Watermark, WatermarkConfig, WatermarkGenerator, WatermarkStrategy,
};
pub use window::{
    CountTrigger, EventTimeSessionWindows, EventTimeTrigger, ProcessingTimeSessionWindows,
    TriggerResult, Window, WindowAssigner, WindowState, WindowTrigger,
};