onyx.windowing.aggregation — org.onyxplatform/onyx 0.14.5-SNAPSHOT

average clj/s

average-aggregation-apply-fn clj/s

(average-aggregation-apply-fn window state v)

average-aggregation-create-fn clj/s

(average-aggregation-create-fn window segment)

average-aggregation-fn-init clj/s

(average-aggregation-fn-init window)

average-super-aggregation clj/s

(average-super-aggregation window state-1 state-2)

collect-by-key clj/s

collect-by-key-aggregation-apply-log clj/s

(collect-by-key-aggregation-apply-log window state segment)

collect-by-key-aggregation-fn clj/s

(collect-by-key-aggregation-fn window segment)

collect-by-key-aggregation-fn-init clj/s

(collect-by-key-aggregation-fn-init window)

collect-by-key-super-aggregation clj/s

(collect-by-key-super-aggregation window state-1 state-2)

collect-key-value clj/s

collect-key-value-aggregation-apply-log clj/s

(collect-key-value-aggregation-apply-log window state v)

collect-key-value-aggregation-fn clj/s

(collect-key-value-aggregation-fn window segment)

collect-key-value-aggregation-fn-init clj/s

(collect-key-value-aggregation-fn-init window)

collect-key-value-super-aggregation clj/s

(collect-key-value-super-aggregation window state-1 state-2)

conj clj/s

conj-aggregation-apply-log clj/s

(conj-aggregation-apply-log window state v)

conj-aggregation-fn clj/s

(conj-aggregation-fn window segment)

conj-aggregation-fn-init clj/s

(conj-aggregation-fn-init window)

conj-super-aggregation clj/s

(conj-super-aggregation window state-1 state-2)

count clj/s

count-aggregation-apply-fn clj/s

(count-aggregation-apply-fn window state _)

count-aggregation-create-state-update clj/s

(count-aggregation-create-state-update _ _)

count-aggregation-fn-init clj/s

(count-aggregation-fn-init window)

count-super-aggregation clj/s

(count-super-aggregation window state-1 state-2)

max clj/s

max-aggregation-fn clj/s

(max-aggregation-fn window segment)

max-create-aggregation-apply-fn clj/s

(max-create-aggregation-apply-fn window state v)

max-super-aggregation clj/s

(max-super-aggregation window state-1 state-2)

min clj/s

min-aggregation-apply-fn clj/s

(min-aggregation-apply-fn window state v)

min-aggregation-create-fn clj/s

(min-aggregation-create-fn window segment)

min-super-aggregation clj/s

(min-super-aggregation window state-1 state-2)

set-value-aggregation-apply-log clj/s

(set-value-aggregation-apply-log window state v)

sum clj/s

sum-aggregation-fn-init clj/s

(sum-aggregation-fn-init window)

sum-aggregation-function clj/s

(sum-aggregation-function _ state v)

sum-create-state-update-fn clj/s

(sum-create-state-update-fn window segment)

sum-super-aggregation clj/s

(sum-super-aggregation window state-1 state-2)