Tools to test dataflow jobs
Tools to test dataflow jobs
(assign-dummy-key val)
(cat-files-like tempfile)
(create-pcoll elems)
(create-pcoll pipeline elems)
(create-pcoll-KVs elems)
(create-pcoll-KVs pipeline elems)
(create-test-pipeline)
(get-data-from-sinks sinks)
(pcoll-contains pcoll expected)
(pcoll-is expected-pcoll result-pcoll)
(pcoll-matches expected-f pcoll)
(pcoll-results-match func)
Inputs: [func :- IFn] Returns: IFn
Checker that runs a pcoll's pipeline, gather its output, and passes it to func
. If func throws or returns
false, the test failed.
Example: see pcoll-contains
Inputs: [func :- IFn] Returns: IFn Checker that runs a pcoll's pipeline, gather its output, and passes it to `func`. If func throws or returns false, the test failed. Example: see `pcoll-contains`
(pcoll-to-data pcoll)
(pipeline-to-data pcolls)
(prn-cogbkresult [id co-gbkresult])
(sink-pcoll pcoll)
(sink-pcolls pcolls)
(try-read-file file-name)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close