MCPcopy Create free account
hub / github.com/microsoft/SandDance / Pulse

Function Pulse

docs/app/js/sanddance-app.js:108024–108032  ·  view source on GitHub ↗

* A Pulse enables inter-operator communication during a run of the * dataflow graph. In addition to the current timestamp, a pulse may also * contain a change-set of added, removed or modified data tuples, as well as * a pointer to a full backing data source. Tuple change sets may not * be fully

(dataflow, stamp, encode)

Source from the content-addressed store, hash-verified

108022 * setting as appropriate. This parameter can be used in conjunction with
108023 * the Encode transform in the vega-encode module.
108024 */ function Pulse(dataflow, stamp, encode) {
108025 this.dataflow = dataflow;
108026 this.stamp = stamp == null ? -1 : stamp;
108027 this.add = [];
108028 this.rem = [];
108029 this.mod = [];
108030 this.fields = null;
108031 this.encode = encode || null;
108032}
108033function materialize(data, filter5) {
108034 const out = [];
108035 (0, _vegaUtil.visitArray)(data, filter5, (_)=>out.push(_));

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected