clojask.onyx-comps — com.github.clojure-finance/clojask 1.1.0

-main clj

(-main & args)

catalog clj

catalog-aggre-gen clj

(catalog-aggre-gen num-work batch-size)

Generate the catalog for running Onyx

catalog-gen clj

(catalog-gen num-work batch-size)

Generate the catalog for running Onyx

catalog-groupby-gen clj

(catalog-groupby-gen num-work batch-size)

Generate the catalog for running Onyx

catalog-join-gen clj

(catalog-join-gen num-work batch-size)

Generate the catalog for running Onyx

close-reader clj

(close-reader event lifecycle)

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-aggre-gen clj

(lifecycle-aggre-gen source dist)

lifecycle-gen clj

(lifecycle-gen source dist order)

lifecycle-groupby-gen clj

(lifecycle-groupby-gen source dist keys key-index)

lifecycle-join-gen clj

(lifecycle-join-gen source dist a b a-keys b-keys a-roll b-roll join-type)

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 clj

(start-onyx num-work batch-size dataframe dist exception order index)

start the onyx cluster with the specification inside dataframe

start-onyx-aggre-only clj

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

start the onyx cluster with the specification inside dataframe

start-onyx-groupby clj

(start-onyx-groupby num-work
                    batch-size
                    dataframe
                    dist
                    groupby-keys
                    groupby-index
                    exception)

start the onyx cluster with the specification inside dataframe

start-onyx-join clj

(start-onyx-join num-work
                 batch-size
                 dataframe
                 b
                 dist
                 exception
                 a-keys
                 b-keys
                 a-roll
                 b-roll
                 join-type
                 limit
                 a-index
                 b-index
                 b-format
                 write-index)

start the onyx cluster with the specification inside dataframe

v-peers clj

worker-func clj

(worker-func seg)

worker-func-gen clj

(worker-func-gen df exception index)

workflow clj

workflow-gen clj

(workflow-gen num-work)

Generate workflow for running Onyx