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

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

rem0? clj

(rem0? event old-segment new-segment all-new-segment)

rem1? clj

(rem1? event old-segment new-segment all-new-segment)

rem2? clj

(rem2? event old-segment new-segment all-new-segment)

rem3? clj

(rem3? event old-segment new-segment all-new-segment)

rem4? clj

(rem4? event old-segment new-segment all-new-segment)

rem5? clj

(rem5? event old-segment new-segment all-new-segment)

rem6? clj

(rem6? event old-segment new-segment all-new-segment)

rem7? clj

(rem7? event old-segment new-segment all-new-segment)

rem8? clj

(rem8? event old-segment new-segment all-new-segment)

shutdown clj

(shutdown)

start-onyx-aggre clj

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

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