morpheus_dfp.stages.dfp_rolling_window_stage
Groups incomming messages into a rolling time window.
Classes
<a href="morpheus_dfp.stages.dfp_rolling_window_stage.DFPRollingWindowStage.html#morpheus_dfp.stages.dfp_rolling_window_stage.DFPRollingWindowStage">DFPRollingWindowStage</a>(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. |