Liking cljdoc? Tell your friends :D
datasplash.api
- ->>
- cogroup-by
- combine
- combine-by
- combine-fn
- concat
- cond->>
- context
- count-fn
- defoptions
- distinct
- distinct-by
- except-distinct
- filename-policy
- filter
- fixed-windows
- flatten
- frequencies
- frequencies-fn
- from-edn
- generate-input
- get-pipeline-configuration
- get-pipeline-options
- group-by
- group-by-key
- identity
- intersect-distinct
- join-by
- juxt
- keep
- key
- make-kv
- make-kv-coder
- make-nippy-coder
- make-partition-mapping
- make-pipeline
- map
- map-kv
- mapcat
- max-fn
- mean-fn
- min-fn
- pardo
- partition-by
- partition-fn
- pt->>
- ptransform
- read-edn-file
- read-edn-files
- read-json-file
- read-json-files
- read-text-file
- read-text-files
- run-pipeline
- safe-exec
- safe-exec-cfg
- sample
- session-windows
- sfn
- side-inputs
- side-outputs
- sliding-windows
- state
- sum-fn
- system
- to-edn
- union-distinct
- val
- view
- wait-pipeline-result
- with-keys
- with-timestamp
- write-edn-file
- write-json-file
- write-text-file
datasplash.bq
- ->clustering
- ->schema
- ->time-partitioning
- auto-parse-val
- bqize-keys
- clean-name
- clj->table-row
- clj-nested->table-row
- coerce-by-bq-val
- create-disposition-enum
- custom-output-fn
- format-fn
- get-bq-table-schema
- read-bq
- read-bq-raw
- retry-policy-enum
- schema-update-options-enum
- table-row->clj
- write-bq-table
- write-bq-table-raw
- write-bq-table-schema
- write-disposition-enum
- write-method-enum
datasplash.examples
- -main
- CombinePerKeyOptions
- count-words
- DatastoreWordCountOptions
- DeDupOptions
- FilterOptions
- format-count
- make-ancestor-key
- make-ancestor-kind-query
- MaxPerKeyOptions
- PubSubOptions
- run-combine-per-key
- run-datastore-word-count
- run-dedup
- run-filter
- run-max-per-key
- run-pub-sub
- run-standard-sql-query
- run-word-count
- StandardSQLOptions
- stream-forwarded-interactions-from-pubsub
- stream-interactions-from-pubsub
- tokenize
- WordCountOptions
datasplash.testing
Namespace of various utilities to test pipelines.
Namespace of various utilities to test pipelines.
datasplash.testing.assert
Namespace to expose PAssert based matchers to test pipelines.
Because PAssert is made to be used with JUnit, assertions will only raise AssertionError.
Namespace to expose `PAssert` based matchers to test pipelines. Because `PAssert` is made to be used with JUnit, assertions will only raise `AssertionError`.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close