                            (get window)
                            handle-sys-components-fn)}))}))
 
-(defmethod agg-pre-merge [:topology-page :bolt]
-  [_ _
-   {comp-id :comp-id
+(defn agg-pre-merge-topo-page-bolt
+  [{comp-id :comp-id
     num-tasks :num-tasks
     statk->w->sid->num :stats
     uptime :uptime}

(defmethod agg-comp-exec-stats :bolt
  [window include-sys? acc-stats new-data]
  (assoc (agg-bolt-exec-win-stats acc-stats (:stats new-data) include-sys?)
         :stats
         (merge-agg-comp-stats :component-page
                               :bolt
                               (:stats acc-stats)
                               (agg-pre-merge :component-page
                                              :bolt
                                              new-data
                                              window
                                              include-sys?))
         :type :bolt))

(defmethod agg-comp-exec-stats :spout
  [window include-sys? acc-stats new-data]
  (assoc (agg-spout-exec-win-stats acc-stats (:stats new-data) include-sys?)
         :stats
         (merge-agg-comp-stats :component-page
                               :spout
                               (:stats acc-stats)
                               (agg-pre-merge :component-page
                                              :spout
                                              new-data
                                              window
                                              include-sys?))
         :type :spout))

(defn- aggregate-comp-stats*

      ((fn [[weighted-avg cnt]]
        (div weighted-avg (* 1000 (min uptime 600))))))))

(defn agg-pre-merge-comp-page-bolt
  [{exec-id :exec-id
    host :host
    port :port
    uptime :uptime
