clojask.aggregate.aggre-onyx-comps — com.github.clojure-finance/clojask 2.0.0

catalog clj

catalog-gen clj

(catalog-gen num-work batch-size)

Generate the catalog for running Onyx

config-env clj

(config-env)

dataframe clj

env clj

env-config clj

flow-cond-gen clj

(flow-cond-gen num-work)

Generate the flow conditions for running Onyx

flow-conditions clj

id clj

in-calls clj

inject-in-reader clj

(inject-in-reader event lifecycle)

lifecycle-gen clj

(lifecycle-gen source dist)

lifecycles clj

n-peers clj

num-workers clj

peer-config clj

peer-group clj

shutdown clj

(shutdown)

start-onyx-aggre clj

(start-onyx-aggre num-work
                  batch-size
                  dataframe
                  dist
                  exception
                  aggre-func
                  index
                  formatter
                  out)

start the onyx cluster with the specification inside dataframe

v-peers clj

worker-func clj

(worker-func seq)

worker-func-gen clj

(worker-func-gen df exception aggre-funcs index formatter)

workflow clj

workflow-gen clj

(workflow-gen num-work)

Generate workflow for running Onyx