Skip to main content

Aggregate

AGGREGATE

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

No description.

This was deprecated in version 6.0.0.

use reduce(s, e0, f)


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

No description.

This was deprecated in version 6.0.0.

use reduce(v, e0, f)


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

No description.

This was deprecated in version 6.0.0.

use reduce(b, e0, f)


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

No description.

This was deprecated in version 6.0.0.

use reduce(b, e0, fn)


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

No description.

This was deprecated in version 6.0.0.

use reduce(s, e0, fn)


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

No description.

This was deprecated in version 6.0.0.

use reduce(v, e0, fn)


AGGV

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

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


AVG

avg(Bag of Number b) -> Real a
STABLE

Average of numbers in bag b


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

No description.


FORALL

forall(Bag b)
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
DEPRECATED

No description.

This was deprecated in version 6.0.0.

Use avg(b) instead


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)
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.


REDUCE

reduce(Stream s, Function f) -> Stream
STABLE

Stream of values reduced over stream s by function f with

 first element in `s` as start value 

reduce(Vector v, Function f) -> Object
STABLE

The reduced value of vector v by function f with first element in b

 as start value 

reduce(Bag b, Function f) -> Object
STABLE

The reduced value of bag b by function f with first element in b

 as start value 

RMAX

rmax(Stream s) -> Stream
STABLE

Running maximum of elements in stream s


RMIN

rmin(Stream s) -> Stream
STABLE

Running maximum of elements in stream s


SOME

some(Bag b)
STABLE

Is there some 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


sum(Vector of Number v) -> Number
STABLE

The sum of the numbers in vector v


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

No description.


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