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

*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)

*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 & xfs)

Apply transforms to an input (Pipeline, PCollection, PBegin ...)

combine-globally clj

(combine-globally xf-var)

combine-per-key clj

(combine-per-key xf-var)

CombineFn clj protocol

add-input clj

(add-input this acc input)

create-accumulator clj

(create-accumulator this)

extract-output clj

(extract-output this acc)

merge-accumulators clj

(merge-accumulators this acc-coll)

comp* clj

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

count-per-key clj

(count-per-key)

(count-per-key xf-name)

create clj

(create coll)

create-options clj

(create-options)

(create-options opts)

(create-options opts as)

create-pipeline clj

(create-pipeline)

(create-pipeline opts)

def-combiner clj macro

(def-combiner & body)

filter* clj

(filter* pred-var-or-name & args)

get-custom-config clj

(get-custom-config obj)

kv->clj clj

(kv->clj kv)

log-elem* clj

(log-elem* elem)

(log-elem* 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)

simple* clj

(simple* fn-var & args)

simple-bi* clj

(simple-bi* fn-var & args)