(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 ...
(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.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close