Skip to main content

Stream

CHANGED​

changed(Stream of Vector s, Vector of Number indexes) -> Stream of Vector
STABLE

Stream containing the vectors of stream s whose elements in indexes

are different than their predecessor

changed(Stream s) -> Stream
STABLE

Stream containing the elements of stream s that are different

than their predecessor

CONCAT​

concat(Stream a, Stream b) -> Stream
STABLE

Add stream b after stream a

DEBOUNCE​

debounce(Stream s, Number start_s, Number debounce) -> Stream
STABLE

Skip elements in s arriving in the first start_s seconds and stop

when s has not emitted any new values in the last debounce seconds

DIOTA​

diota(Real pace, Integer l, Integer u) -> Stream of Integer
STABLE

Stream of natural numbers between l and u

with delays of pace seconds between produced stream elements

EXTRACT​

extract(Stream s) -> Bag
STABLE

Extract elements in stream s one by one as elements in a bag

FIRST​

first(Stream s) -> Object
STABLE

The first element in stream s

FIRST_N​

first_n(Stream s, Number n) -> Stream
STABLE

The stream of the first n elements in stream s

HEARTBEAT​

heartbeat(Real pace) -> Stream of Real
STABLE

Stream of seconds from start emitted at given pace in seconds

HEARTBEAT_WRAP​

heartbeat_wrap(Bag b, Number pace) -> Stream
STABLE

Convert bag b into stream with sampling frequency pace

heartbeat_wrap(Stream s, Number pace) -> Stream
STABLE

No description.

HISTOGRAM​

histogram(Stream s, Vector limits) -> Stream of Vector of Integer
STABLE

Calculate a stream of histograms over stream s, with limits vector.

limits is a vector with [min,max,number of bins] the range for the histograms is always $ [min,max) $

histogram(Stream of Number s, Number min, Number max, Number bins) -> Stream of Vector of Integer
STABLE

Calculate a stream histograms over a stream s, with min, max, and bins

the range for the histograms are always $ [min,max) $

histogram(Stream of Vector s, Vector of Vector limits) -> Stream of Vector of Vector
STABLE

Calculate a stream of histograms over a stream of vector s,

with limits vector. Limits must be a vector of the same dimension as each vector in s and:

limitsi=[mini,maxi,binsi]limits_i = [min_i,max_i, bins_i]

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

MERGE​

merge(Vector of Stream vs) -> Stream
STABLE

Merge streams in vs

merge(Stream s1, Stream s2) -> Stream
STABLE

Merge streams s1 and s2

PIVOT​

pivot(Vector of Stream vs, Vector iv) -> Stream of Vector
STABLE

A stream of the most recently received values in vs,

having the vector iv as the initial element

pivot(Vector of Stream vs) -> Stream of Vector
STABLE

A stream of the most recently received elements in vs

PIVOT_EVENTS​

pivot_events(Vector keys, Stream of Vector bus) -> Stream of Timeval of Vector
STABLE

Pivot stream bus of [timestamp, key, value]

into stream of timestamped vectors pivoted on keys

PLAYBACK​

playback(Stream s) -> Stream
STABLE

Playback time stamped stream of vectors s with pace

according to time stamp in each first vector elements of s

RANDSTREAM​

randstream(Real l, Real u) -> Stream of Real
STABLE

Infinite stream of random numbers between l and u

RAVG​

ravg(Stream s) -> Stream of Real
STABLE

Running averages of elements in stream s

RCOUNT​

rcount(Stream s) -> Stream of Integer
STABLE

Stream of running count of elements in stream s

READLINES​

readlines(Charstring file, Charstring delim, Number chunk) -> Stream of Vector of Charstring
STABLE

No description.

readlines(Charstring file) -> Stream of Charstring
STABLE

Stream of lines in file

READ_FILE_CHUNKED​

read_file_chunked(Charstring file, Integer chunk) -> Stream
STABLE

No description.

REMOTE:FUNCTION​

remote:function(Charstring peer, Charstring fn, Vector args) -> Stream
STABLE

No description.

REMOTE:QUERY​

remote:query(Charstring peer, Charstring query) -> Stream
STABLE

No description.

REMOTE_FUNCTION_STREAM​

remote_function_stream(Charstring peer, Charstring fn, Vector args) -> Stream of Vector
STABLE

Return stream of tuples from result of fn(args) on peer

RSUM​

rsum(Stream s) -> Stream of Real
STABLE

Stream of running averages of elements in stream s

SAMPLE_EVERY​

sample_every(Stream s, Real pace) -> Stream
STABLE

Run stream s and emit values every pace seconds since the last value

SAMPLE_STREAM​

sample_stream(Bag expression, Real pace) -> Stream
STABLE

Stream of expression evaluated every pace seconds

SAVE_LAST_ELEMENT​

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

No description.

SECTION​

section(Stream s, Number start, Number stop) -> Stream
STABLE

The section of stream s starting at position start

and ending at stop.

SIMSIG​

simsig(Real x) -> Real
STABLE

A simulated harmonic stream reading x seconds from its start

SIMSTREAM​

simstream(Real pace) -> Stream of Real
STABLE

A simulated harmonic stream

SINK​

sink(Stream s) -> Boolean
STABLE

Run stream s silently without extracting any elements

SIOTA​

siota(Integer l, Integer u) -> Stream of Integer
STABLE

Stream of natural numbers between l and u

SKIP​

skip(Stream s, Number n) -> Stream
STABLE

Skip first n elements in stream s

SKIP_S​

skip_s(Stream s, Number sec) -> Stream
STABLE

Skip all elements arriving in the first sec seconds of

stream s.

STREAMOF​

streamof(Stream s) -> Stream
STABLE

No description.

streamof(Bag b) -> Stream
STABLE

Convert a bag b to a stream

STREAM_FUNCTION_TUPLES​

stream_function_tuples(Charstring peer, Charstring fn, Vector args) -> Bag of Vector
STABLE

No description.

TIMEOUT​

timeout(Stream s, Number timeout) -> Stream
STABLE

No description.

TIMESTAMPS​

timestamps(Number pace) -> Stream of Charstring
STABLE

Stream of local timestamp UTC every pace seconds

TIMESTREAM​

timestream(Number pace) -> Stream of Timeval
STABLE

Stream of time stamps every pace seconds

TIME_SECTION​

time_section(Stream s, Number start_s, Number stop_s) -> Stream
STABLE

Skip elements in s arriving in the first start_s seconds and stop

after stop_s seconds. This is similar to section(stream,start,stop), except that the start and stop values are real-time seconds.

TIME_SPENT​

time_spent(Stream s) -> Real
STABLE

Real time spent in running s

TS_SIMSTREAM​

ts_simstream(Real pace) -> Stream of Timeval of Real
STABLE

A sumulated time stamped harmonic stream

VECTOROF​

vectorof(Stream b) -> Vector v
STABLE

Convert finite stream to vector

VSTREAM​

vstream(Vector v) -> Stream
STABLE

Convert a vector v to a stream

WRITELINES​

writelines(Stream s, Charstring file) -> Charstring
STABLE

Create file by lines in stream s

ZIP​

zip(Vector of Stream vs, Vector of Integer indices) -> Stream of Vector
STABLE

A stream where each received vector in vs is "zipped" together on the

indices. Vector elements not in indices will retain the latest seen value

zip(Vector of Stream vs) -> Stream of Vector
STABLE

A stream where each received values in vs is "zipped" together one at a

time. Should only be used of streams have the same pace.