morpheus_dfp.stages.dfp_rolling_window_stage
Groups incomming messages into a rolling time window.
Classes
DFPRollingWindowStage(c, min_history, ...[, ...]) |
This stage groups incomming messages into a rolling time window, emitting them only when the history requirements are met specified by the min_history, min_increment and max_history parameters. |