Class ActivityTreePurger


  • public class ActivityTreePurger
    extends Object
    Responsible for purging detailed state of the activities, including worker and delegator tasks. This also includes: 1. Deletion of eligible subtasks. This is done here (and not elsewhere) because we need to know which subtasks to purge and which not: and the distinction is similar to distinction when purging the state itself (the state persistence). 2. Deletion of the task-level statistics. The reason is similar: we need to know which activities are "persistent" and which are not. (The distinction is only approximate, because the task statistics are common for all activities in the task. So we keep them if at least one of the activities is persistent.)