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

aggre-avg clj

(aggre-avg seq groupby-keys keys new-keys key-index)

get the average of some keys

aggre-max clj

(aggre-max seq groupby-keys keys new-keys key-index)

get the max of some keys

aggre-min clj

(aggre-min seq groupby-keys keys new-keys key-index)

get the min of some keys

aggre-sd clj

(aggre-sd seq groupby-keys keys new-keys key-index)

get the standard deviation (sd) of some keys

aggre-sum clj

(aggre-sum seq groupby-keys keys new-keys key-index)

get the sum of some keys

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)

internal-aggregate clj

(internal-aggregate func out-dir key-index groupby-keys keys & [new-keys])

aggregate one group use the function

internal-aggregate-write clj

(internal-aggregate-write func out-dir groupby-keys keys file & [new-keys])

called by child thread function

mean clj

(mean a)

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

square clj

(square n)

standard-deviation clj

(standard-deviation a)

template clj

(template seq groupby-keys old-keys new-keys)

The template for aggregate functions

write-file clj

(write-file dir seq)