onyx.windowing.aggregation

average
average-aggregation-apply-fn
(average-aggregation-apply-fn window state v)
average-aggregation-create-fn
(average-aggregation-create-fn window segment)
average-aggregation-fn-init
(average-aggregation-fn-init window)
average-super-aggregation
(average-super-aggregation window state-1 state-2)
collect-by-key
collect-by-key-aggregation-apply-log
(collect-by-key-aggregation-apply-log window state segment)
collect-by-key-aggregation-fn
(collect-by-key-aggregation-fn window segment)
collect-by-key-aggregation-fn-init
(collect-by-key-aggregation-fn-init window)
collect-by-key-super-aggregation
(collect-by-key-super-aggregation window state-1 state-2)
collect-key-value
collect-key-value-aggregation-apply-log
(collect-key-value-aggregation-apply-log window state v)
collect-key-value-aggregation-fn
(collect-key-value-aggregation-fn window segment)
collect-key-value-aggregation-fn-init
(collect-key-value-aggregation-fn-init window)
collect-key-value-super-aggregation
(collect-key-value-super-aggregation window state-1 state-2)
conj
conj-aggregation-apply-log
(conj-aggregation-apply-log window state v)
conj-aggregation-fn
(conj-aggregation-fn window segment)
conj-aggregation-fn-init
(conj-aggregation-fn-init window)
conj-super-aggregation
(conj-super-aggregation window state-1 state-2)
count
count-aggregation-apply-fn
(count-aggregation-apply-fn window state _)
count-aggregation-create-state-update
(count-aggregation-create-state-update _ _)
count-aggregation-fn-init
(count-aggregation-fn-init window)
count-super-aggregation
(count-super-aggregation window state-1 state-2)
max
max-aggregation-fn
(max-aggregation-fn window segment)
max-create-aggregation-apply-fn
(max-create-aggregation-apply-fn window state v)
max-super-aggregation
(max-super-aggregation window state-1 state-2)
min
min-aggregation-apply-fn
(min-aggregation-apply-fn window state v)
min-aggregation-create-fn
(min-aggregation-create-fn window segment)
min-super-aggregation
(min-super-aggregation window state-1 state-2)
set-value-aggregation-apply-log
(set-value-aggregation-apply-log window state v)
sum
sum-aggregation-fn-init
(sum-aggregation-fn-init window)
sum-aggregation-function
(sum-aggregation-function _ state v)
sum-create-state-update-fn
(sum-create-state-update-fn window segment)
sum-super-aggregation
(sum-super-aggregation window state-1 state-2)