     (reduce *)))
 
 (defn dstream-iterations [state raw-data]
-  (my-log [state raw-data] ::dstream-iterations.starting {:raw-data-count   (count raw-data)
+  (log-it [state raw-data] ::dstream-iterations.starting {:raw-data-count   (count raw-data)
                                                           :state-properties (::state (::properties state))})
   (let [time*      (atom 0)
         the-state* (atom state)]

(defn adjust-clustering [state t]
  (let [updated-state* (atom (update-grid-cells state t))]
    (doseq [[pos-idx char-vec] (::grid-cells @updated-state*)]
      (my-log pos-idx ::adjust-clustering char-vec)
      (when (= t (::last-time-label-changed char-vec))
        (do
          (my-log pos-idx ::label-changed-this-iteration char-vec)
          ;;4
          (when (= ::sparse (::label char-vec))
            (do
              (my-log pos-idx ::sparse-label char-vec)
              (let [old-cluster (::cluster char-vec)]
                (swap! updated-state* assoc-in [::grid-cells pos-idx]
                       (assoc char-vec ::cluster "NO_CLASS"))

    (doseq [[pos-idx char-vec] (::grid-cells @state*)]
      (if (= ::dense (::label char-vec))
        (do
          (log-it state ::dense-grid-creating-cluster {:char-vec char-vec})
          (swap! state* assoc-in
                 [::grid-cells pos-idx ::cluster]
                 (str (java.util.UUID/randomUUID))))
        (do (log-it state ::not-dense-grid {:char-vec char-vec})
            (swap! state* assoc-in
                   [::grid-cells pos-idx ::cluster]
                   "NO_CLASS"))))
