     :onyx/doc "core.async plugin base lifecycle"}])
 
 ;; <<< BEGIN FILL ME IN PART 1 >>>
-
+;; Use an :onyx.triggers/watermark trigger.
 (def windows
   [])
 


(def workflow
  [[:read-segments :bucket-page-views]])

;;; Catalogs ;;;


       :onyx/plugin :onyx.plugin.core-async/input
       :onyx/type :input
       :onyx/medium :core.async
       :onyx/assign-watermark-fn ::watermark-fn
       :onyx/batch-size batch-size
       :onyx/batch-timeout batch-timeout
       :onyx/max-peers 1
