DFP Rolling Window Module

This module is responsible for maintaining a rolling window of historical data, acting as a streaming caching and batching system.

Configurable Parameters

Parameter	Type	Description	Example Value	Default Value
cache_mode	string	Mode for managing user cache. Setting to batch flushes cache once trigger conditions are met. Otherwise, continue to aggregate user’s history.	"batch"	"batch"
trigger_on_min_history	integer	Minimum history to trigger a new training event	1	1
trigger_on_min_increment	integer	Minimum increment from the last trained to new training event	0	0
timestamp_column_name	string	Name of the column containing timestamps	"timestamp"	"timestamp"
aggregation_span	string	Look back time span for training data in a new training event	"60d"	"60d"
cache_to_disk	boolean	Whether or not to cache streaming data to disk	false	false
cache_dir	string	Directory to use for caching streaming data	"./.cache"	"./.cache"

Example JSON Configuration

{
  "cache_mode": "batch",
  "trigger_on_min_history": 1,
  "trigger_on_min_increment": 0,
  "timestamp_column_name": "timestamp",
  "aggregation_span": "60d",
  "cache_to_disk": false,
  "cache_dir": "./.cache"
}