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