To "restart the world", we'll run a batch job then a streaming job.
- read all profiles from the system of record and create a RDD[(String, FCProfile)] containing all profiles
- read all interactions from the system of record, compute Map[handle: String, Map[ruleset_id: String, count: Int]] for each window
- read all interactions from the system of record, "batch them" by timestamp, enumerate them
Streaming