Skip to main content

Aggregate

AGGREGATE​

aggregate(Stream s, Object e0, Function f) -> Stream
STABLE

Stream of values aggregated over stream s by function f with

start value e0

aggregate(Vector v, Object e0, Function f) -> Object
STABLE

The aggregated value of vector v by function f with start value e0

aggregate(Bag b, Object e0, Function f) -> Object
STABLE

The aggregated value of bag b by function f with start value e0

aggregate(Bag b, Object e0, Charstring fn) -> Object
STABLE

The aggregated value of bag b by function named fn

with start value e0

aggregate(Stream s, Object e0, Charstring fn) -> Stream
STABLE

Stream of values aggregated over stream s by function named fn

with start value e0

aggregate(Vector v, Object e0, Charstring fn) -> Object
STABLE

The aggregated value of vector v by function named fn

with start value e0

AGGV​

aggv(Bag of Vector bv, Function fn) -> Vector of Number
STABLE

Apply aggregate function fn on each position of the vectors in bv

CONCATAGG​

concatagg(Bag b) -> Charstring
STABLE

Concatenate stringified elements in bag b

COUNT​

count(Bag b) -> Integer
STABLE

The number of elements in bag b

FNOAGG​

fnoagg(Stream s, Function init, Function agg, Function emitfn) -> Stream
STABLE

Cumulative aggregation over stream s:

The aggregation is initialized using init For each incoming tuple in s, the aggregation is updated using agg For each incoming tuple in s, the aggregation is emitted using emitfn

fnoagg(Stream s, Function init, Function agg, Function emitfn, Integer size, Integer stride) -> Stream
STABLE

Window aggregation over stream s:

Windows of size and stride are formed over s. For each window,

 * the aggregation is initialized using `init`
 * for each incoming tuple in `s`, the aggregation is updated using `agg`
 * when the window is complete, its aggregation is emitted using `emitfn`

FORALL​

forall(Bag b) -> Boolean
STABLE

Iterate through b

HISTOGRAM​

histogram(Bag of Vector b, Matrix limits) -> Vector of Integer
STABLE

Calculate a histogram over a bag of tuple vectors b where each row

$ l_i $ in the limits matrix specifies the ranges and number of bins in tuple position ii as $ l_i = [min_i,max_i, bins_i] $

histogram(Bag of Number b, Vector limits) -> Vector of Integer
STABLE

Calculate a histogram over a bag b where the limits vector specifies

the ranges and number of bins as [min,max,number of bins]

histogram(Bag of Number b, Number min, Number max, Number bins) -> Vector of Integer
STABLE

Calculate a histogram over a bag b, with min, max, and bins

the range for the histogram is always $ [min,max) $

INIT_AVG​

init_avg()->(Integer, Real)
STABLE

No description.

INIT_AVGV​

init_avgv( ) -> Vector of Number
STABLE

No description.

INJECT​

inject(Bag b, Object o) -> Bag
STABLE

Inject 'o' between elements in bag 'b'

IN_RANGE​

in_range(Number x, Number low, Number up) -> Number
STABLE

x if x in interval [low,up]

MAX​

max(Bag b) -> Object
STABLE

The largest element in bag b

MEAN​

mean(Bag b) -> Real a
STABLE

Average of numbers in bag b

MEDIAN​

median(Bag of Number b) -> Number
STABLE

The median of numbers in bag b

median(Vector v) -> Number
STABLE

The median of numbers in vector v

MIN​

min(Bag b) -> Object
STABLE

The smallest element in bag b

NOTANY​

notany(Bag b) -> Boolean
STABLE

Is bag b empty?

NXT_AVG​

nxt_avg(Integer cnt, Real sum, Real this)->(Integer, Real)
STABLE

No description.

NXT_AVGV​

nxt_avgv(Vector of Number v, Real this) -> Vector of Number
STABLE

No description.

SOME​

some(Bag b) -> Boolean
STABLE

Is there any element in bag b?

STATS​

stats(Bag b)->(Real avg, Real stdev, Real min, Real max, Integer cnt)
STABLE

No description.

STDEV​

stdev(Bag b) -> Real s
STABLE

Standard deviation of numbers in bag b

SUM​

sum(Bag b) -> Number
STABLE

The sum of the numbers in bag b

THIS_AVG​

this_avg(Integer cnt, Real sum) -> Vector of Real
STABLE

No description.

THIS_AVGV​

this_avgv(Vector of Number v) -> Vector of Real
STABLE

No description.

VECTORIZE​

vectorize(Bag b) -> Vector v
STABLE

No description.

WINAGG_ACTION​

winagg_action(Integer size, Integer stride, Integer counter, Integer window, Integer cold) -> Integer
STABLE

No description.

WINSTATAGG​

winstatagg(Stream of Vector of Number sv, Vector of Integer size, Vector of Integer stride) -> Stream of Vector of Vector
STABLE

Statistics window aggregation over stream of vector sv:

Windows of size and stride are formed over sv. For each window,

 * statistics are emitted for each number series
   when the window is complete

winstatagg(Stream of Number s, Integer size, Integer stride) -> Stream of Vector
STABLE

Statistics window aggregation over stream of number s:

Windows of size and stride are formed over s. For each window,

 * statistics are emitted over the numbers in the window
   when the window is complete