Liking cljdoc? Tell your friends :D
clj-headlights.bigquery-io
Common bigquery utilites for clojure dataflow jobs.
Common bigquery utilites for clojure dataflow jobs.
clj-headlights.clj-fn-call
Helpers to have Dataflow call Clojure functions
Helpers to have Dataflow call Clojure functions
clj-headlights.input-output
Tools for pipeline data input and output
Tools for pipeline data input and output
clj-headlights.pcollections
Helpers to manipulate PCollections in general
Helpers to manipulate PCollections in general
clj-headlights.pipeline
- apply-to-value-and-output
- apply-to-value-and-output-kv
- apply-to-value-and-output-with-timestamp
- apply-to-value-and-seq-outputs
- apply-to-value-and-seq-outputs-kv
- co-group-by-key
- composite
- context->ms
- create
- df-apply-dofn
- df-filter
- df-filter-kv
- df-map
- df-map-cat-with-side-outputs
- df-map-kv
- df-map-with-side-input
- df-map-with-timestamp
- df-mapcat
- df-mapcat-kv
- filterer
- filterer-kv
- flatten-pcollections
- get-side-output
- get-side-outputs
- group-by-key
- make-pipeline-options
- output-is-kv
- process-pcoll
- process-pcoll-kv
- side-output-function-wrapper
clj-headlights.pubsub
Helpers to use Pub/Sub in DataFlow jobs
Helpers to use Pub/Sub in DataFlow jobs
clj-headlights.system
Companion to the clj-headlights/System class.
About callbacks:
Callbacks are fixed extension points in clj-headlights. In order to use them, you need to create the namespace clj-headlights.callbacks, and implement any of the following functions in it:
- pre-namespace-require [namespace-symbol] executed right before a namespace is required for the first time.
Companion to the clj-headlights/System class.
About callbacks:
Callbacks are fixed extension points in clj-headlights. In order to use them, you need to create the namespace
clj-headlights.callbacks, and implement any of the following functions in it:
* pre-namespace-require [namespace-symbol]
executed right before a namespace is required for the first time.clj-headlights.test-helpers
Tools to test dataflow jobs
Tools to test dataflow jobs
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close