    :zookeeper/address "127.0.0.1:2185"
    :onyx/id id})
 
+;; Connect to the coordinator. Also boots up in the in-memory services.
 (def conn (onyx.api/connect :memory coord-opts))
 
+;; Start the worker peers.
 (def v-peers (onyx.api/start-peers conn 1 peer-opts))
 
 (onyx.api/submit-job conn {:catalog catalog :workflow workflow})

            [onyx.plugin.core-async]
            [onyx.api]))

(defn split-by-spaces-impl [s]
  (clojure.string/split s #"\s+"))


(defn question-impl [s]
  (str s "?"))

;;;;; Destructuring functions ;;;;;
(defn split-by-spaces [segment]
  (map (fn [word] {:word word}) (split-by-spaces-impl (:sentence segment))))

(defn mixed-case [segment]
  {:word (mixed-case-impl (:word segment))})
