cascalog ambrose integration

ambrose.clj

(defn ambrose?-
  [& bindings]
  (let [[name bindings] (flow/parse-exec-args bindings)
        bindings (mapcat (partial apply normalize-sink-connection)
                         (partition 2 bindings))
        flow (-> (apply compile-flow name bindings)
                 flow/flow-def
                 flow/compile-hadoop)
        server (EmbeddedAmbroseCascadingNotifier.)]
    (.addListener flow server)
    (.addStepListener flow server)
    (.complete flow)))