(apply! input & xfs)
Apply transforms to an input (Pipeline, PCollection, PBegin ...)
Apply transforms to an input (Pipeline, PCollection, PBegin ...)
(apply** fn options context window args-array)
(apply** fn options context window state timer args-array)
(add-input this acc input)
(create-accumulator this)
(extract-output this acc)
(merge-accumulators this acc-coll)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close