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