thurber — com.github.atdixon/thurber 0.0.4-alpha2

*bag-state clj

(*bag-state)

*custom-config clj

(*custom-config)

*element-window clj

(*element-window)

*event-timer clj

(*event-timer)

*pipeline-options clj

(*pipeline-options)

*process-context clj

(*process-context)

*proxy-args clj

(*proxy-args)

*restriction-tracker clj

(*restriction-tracker)

*timer-context clj

(*timer-context)

*value-state clj

(*value-state)

->beam-args clj

(->beam-args m)

->kv clj

(->kv seg)

(->kv key-fn seg)

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

apply! clj

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

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

clj->kv clj

(clj->kv [k v])

co-gbk-result->clj clj

(co-gbk-result->clj r)

combiner clj

(combiner reducef)

(combiner combinef reducef)

(combiner extractf combinef reducef)

compose clj

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

create clj

(create coll)

(create name coll)

create-options clj

(create-options)

(create-options opts)

(create-options opts as)

create-pipeline clj

(create-pipeline)

(create-pipeline opts)

filter clj

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

fn* clj macro

(fn* & body)

get-custom-config clj

(get-custom-config obj)

inline clj macro

(inline fn-form)

kv->clj clj

(kv->clj kv)

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.

log clj

(log elem)

(log level elem)

log-verbose clj

(log-verbose elem)

(log-verbose level elem)

nippy clj

nippy-kv clj

partial clj

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

proxy* clj

(proxy* proxy-var & args)

proxy-with-signature* clj

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

run-pipeline! clj

(run-pipeline! p)

ser-fn clj

(ser-fn fn-var & args)