clojask.join.outer-onyx-comps — com.github.clojure-finance/clojask 2.0.3

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-outer clj

(start-onyx-outer num-work
                  batch-size
                  a
                  b
                  mgroup-a
                  mgroup-b
                  dist
                  exception
                  a-index
                  b-index
                  a-format
                  b-format
                  write-index
                  output)

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 a
                 b
                 mgroup-a
                 mgroup-b
                 exception
                 a-index
                 b-index
                 a-format
                 b-format
                 write-index)

worker-func-gen2 clj

(worker-func-gen2 a
                  b
                  mgroup-a
                  mgroup-b
                  exception
                  a-index
                  b-index
                  a-format
                  b-format
                  write-index)

workflow clj

workflow-gen clj

(workflow-gen num-work)

Generate workflow for running Onyx