clojask.groupby — com.github.clojure-finance/clojask 2.0.0

compute-aggregate clj

(compute-aggregate dateframe output-dir exp)

aggregate the output files to the final destination

compute-groupby clj

(compute-groupby dataframe num-worker output-dir exception)

map the result to different files

gen-groupby-filenames clj

(gen-groupby-filenames dist msg groupby-keys key-index formatters)

internal function to generate files csv line with groupby key(s)

output-groupby clj

(output-groupby dist msg groupby-keys key-index formatter write-index)

internal function called by output when aggregation is applied

read-csv-seq clj

(read-csv-seq filename)

takes file name and reads data