Liking cljdoc? Tell your friends :D

thurber


*bag-stateclj

(*bag-state)
source

*custom-configclj

(*custom-config)
source

*element-windowclj

(*element-window)
source

*event-timerclj

(*event-timer)
source

*pipeline-optionsclj

(*pipeline-options)
source

*process-contextclj

(*process-context)
source

*proxy-argsclj

(*proxy-args)
source

*restriction-trackerclj

(*restriction-tracker)
source

*timer-contextclj

(*timer-context)
source

*value-stateclj

(*value-state)
source

->beam-argsclj

(->beam-args m)
source

->kvclj

(->kv seg)
(->kv key-fn seg)
(->kv key-fn val-fn seg)
source

apply!clj

(apply! input xf-or-prefix & xfs)

Apply transforms to an input (Pipeline, PCollection, PBegin ...); Answers a PCollection, PCollectionView, or so on ...

Apply transforms to an input (Pipeline, PCollection, PBegin ...);
Answers a PCollection, PCollectionView, or so on ...
sourceraw docstring

clj->kvclj

(clj->kv [k v])
source

co-gbk-result->cljclj

(co-gbk-result->clj r)
source

combinerclj

(combiner reducef)
(combiner combinef reducef)
(combiner extractf combinef reducef)
source

composeclj

(compose & [xf-or-name :as xfs])
source

createclj

(create coll)
(create name coll)
source

create-optionsclj

(create-options)
(create-options opts)
(create-options opts as)
source

create-pipelineclj

(create-pipeline)
(create-pipeline opts)
source

filterclj

(filter pred-var-ser-fn-or-name & args)
source

fn*cljmacro

(fn* & body)
source

get-custom-configclj

(get-custom-config obj)
source

inlinecljmacro

(inline fn-form)
source

kv->cljclj

(kv->clj kv)
source

kv->clj*clj

(kv->clj* kv)

Convert a Beam KV result to Clojure vector: the result is not serializable and rather may contain result/s as lazy sequences backed by Beam lazy Iterable results; therefore not for use as DoFn.

Convert a Beam KV *result* to Clojure vector: the result is not serializable and
rather may contain result/s as lazy sequences backed by Beam lazy Iterable results;
therefore not for use as DoFn.
sourceraw docstring

logclj

(log elem)
(log level elem)
source

log-verboseclj

(log-verbose elem)
(log-verbose level elem)
source

nippyclj

source

nippy-kvclj

source

partialclj

(partial fn-var-or-name & args)
source

proxy*clj

(proxy* proxy-var & args)
source

proxy-with-signature*clj

(proxy-with-signature* proxy-var sig & args)
source

run-pipeline!clj

(run-pipeline! p)
source

ser-fnclj

(ser-fn fn-var & args)
source

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

× close