Skip to main content

Dataflow

FLOWS​

flows( ) -> Bag of Record
STABLE

Get all current data flows

PUBLISH​

publish(Stream s, Charstring flow) -> Stream
STABLE

Publish elements in stream s in data flow

PUMP:ACTIVE_FLOWS​

pump:active_flows(Charstring name) -> Vector of Charstring
STABLE

No description.

SUBSCRIBE​

subscribe(Charstring flow) -> Object
STABLE

Follow data flow

SUBSCRIBE:MERGE​

subscribe:merge(Vector of Charstring flows) -> Object
STABLE

No description.

SUBSCRIBE:MERGE_TAGGED​

subscribe:merge_tagged(Vector of Charstring flows) -> Object
STABLE

No description.

SUBSCRIBE:PIVOT​

subscribe:pivot(Vector of Charstring flows) -> Stream of Vector
STABLE

No description.

SUBSCRIBE:TS_PIVOT​

subscribe:ts_pivot(Vector of Charstring flows) -> Stream of Timeval of Vector
STABLE

No description.