Skip to content

Instantly share code, notes, and snippets.

Last active Aug 29, 2015
What would you like to do?
cascalog ambrose integration
(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)
server (EmbeddedAmbroseCascadingNotifier.)]
(.addListener flow server)
(.addStepListener flow server)
(.complete flow)))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment