Liking cljdoc? Tell your friends :D

clojask.onyx-comps


-mainclj

(-main & args)
source

catalogclj

source

catalog-aggre-genclj

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

Generate the catalog for running Onyx

Generate the catalog for running Onyx
sourceraw docstring

catalog-genclj

(catalog-gen num-work batch-size)

Generate the catalog for running Onyx

Generate the catalog for running Onyx
sourceraw docstring

catalog-groupby-genclj

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

Generate the catalog for running Onyx

Generate the catalog for running Onyx
sourceraw docstring

catalog-join-genclj

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

Generate the catalog for running Onyx

Generate the catalog for running Onyx
sourceraw docstring

close-readerclj

(close-reader event lifecycle)
source

config-envclj

(config-env)
source

dataframeclj

source

envclj

source

env-configclj

source

flow-cond-genclj

(flow-cond-gen num-work)

Generate the flow conditions for running Onyx

Generate the flow conditions for running Onyx
sourceraw docstring

flow-conditionsclj

source

idclj

source

in-callsclj

source

inject-in-readerclj

(inject-in-reader event lifecycle)
source

lifecycle-aggre-genclj

(lifecycle-aggre-gen source dist)
source

lifecycle-genclj

(lifecycle-gen source dist order)
source

lifecycle-groupby-genclj

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

lifecycle-join-genclj

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

lifecyclesclj

source

n-peersclj

source

num-workersclj

source

peer-configclj

source

peer-groupclj

source

rem0?clj

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

rem1?clj

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

rem2?clj

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

rem3?clj

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

rem4?clj

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

rem5?clj

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

rem6?clj

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

rem7?clj

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

rem8?clj

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

shutdownclj

(shutdown)
source

start-onyxclj

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

start the onyx cluster with the specification inside dataframe

start the onyx cluster with the specification inside dataframe
sourceraw docstring

start-onyx-aggre-onlyclj

(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 the onyx cluster with the specification inside dataframe
sourceraw docstring

start-onyx-groupbyclj

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

start the onyx cluster with the specification inside dataframe

start the onyx cluster with the specification inside dataframe
sourceraw docstring

start-onyx-joinclj

(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

start the onyx cluster with the specification inside dataframe
sourceraw docstring

v-peersclj

source

worker-funcclj

(worker-func seg)
source

worker-func-genclj

(worker-func-gen df exception index)
source

workflowclj

source

workflow-genclj

(workflow-gen num-work)

Generate workflow for running Onyx

Generate workflow for running Onyx
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close