Socket
Socket
Sign inDemoInstall

vega-dataflow

Package Overview
Dependencies
Maintainers
2
Versions
98
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

vega-dataflow - npm Package Compare versions

Comparing version 2.1.0 to 2.1.1

2

build/vega-dataflow.min.js

@@ -1,1 +0,1 @@

!function(t,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports,require("vega-util"),require("vega-loader"),require("vega-statistics"),require("d3-array")):"function"==typeof define&&define.amd?define(["exports","vega-util","vega-loader","vega-statistics","d3-array"],e):e(t.vega=t.vega||{},t.vega,t.vega,t.vega,t.d3)}(this,function(t,e,i,n,r){"use strict";function a(t){var i=t||e.identity,n=[],r={};return n.add=function(t){var e=i(t);return r[e]||(r[e]=1,n.push(t)),n},n.remove=function(t){var e,a=i(t);return r[a]&&(r[a]=0,(e=n.indexOf(t))>=0&&n.splice(e,1)),n},n}function s(t){return t[Nt]}function u(t,e){return t[Nt]=e,t}function o(t){var e=t===Object(t)?t:{data:t};return s(e)?e:u(e,Ct++)}function l(t){return h(t,o({}))}function h(t,e){for(var i in t)e[i]=t[i];return e}function f(t,e){return u(e,s(t))}function d(t){return t&&t.constructor===c}function c(){var t=[],i=[],n=[],r=[],a=[],u=!1;return{constructor:c,insert:function(i){for(var n=e.array(i),r=0,a=n.length;r<a;++r)t.push(n[r]);return this},remove:function(t){for(var n=e.isFunction(t)?r:i,a=e.array(t),s=0,u=a.length;s<u;++s)n.push(a[s]);return this},modify:function(t,i,r){var s={field:i,value:e.constant(r)};return e.isFunction(t)?(s.filter=t,a.push(s)):(s.tuple=t,n.push(s)),this},encode:function(t,i){return e.isFunction(t)?a.push({filter:t,field:i}):n.push({tuple:t,field:i}),this},reflow:function(){return u=!0,this},pulse:function(e,l){function h(t,i,n){n?t[i]=n(t):e.encode=i,u||(f[s(t)]=t)}var f,d,c,m,p,v,g;for(d=0,c=t.length;d<c;++d)e.add.push(o(t[d]));for(f={},d=0,c=i.length;d<c;++d)f[s(v=i[d])]=v;for(d=0,c=r.length;d<c;++d)p=r[d],l.forEach(function(t){p(t)&&(f[s(t)]=t)});for(g in f)e.rem.push(f[g]);for(f={},d=0,c=n.length;d<c;++d)h((m=n[d]).tuple,m.field,m.value),e.modifies(m.field);for(d=0,c=a.length;d<c;++d)m=a[d],p=m.filter,l.forEach(function(t){p(t)&&h(t,m.field,m.value)}),e.modifies(m.field);if(u)e.mod=i.length||r.length?l.filter(function(t){return f.hasOwnProperty(s(t))}):l.slice();else for(g in f)e.mod.push(f[g]);return e}}}function m(){Object.defineProperty(this,Pt,{writable:!0,value:{}})}function p(t,e,i,n){this.id=++Lt,this.value=t,this.stamp=-1,this.rank=-1,this.qrank=-1,this.flags=0,e&&(this._update=e),i&&this.parameters(i,n)}function v(t){return function(e){var i=this.flags;return 0===arguments.length?!!(i&t):(this.flags=e?i|t:i&~t,this)}}function g(t,e,i){this.id=++Tt,this.value=null,i&&(this.receive=i),t&&(this._filter=t),e&&(this._apply=e)}function y(t,e,i){return new g(t,e,i)}function _(t,i,n,r,a,s){var u,o,l=e.extend({},s,Wt);e.isFunction(n)||(n=e.constant(n)),void 0===r?u=function(e){t.touch(n(e))}:e.isFunction(r)?(o=new p(null,r,a,!1),u=function(e){var i,r=n(e);o.evaluate(e),d(i=o.value)?t.pulse(r,i,s):t.update(r,i,l)}):u=function(e){t.update(n(e),r,l)},i.apply(u)}function x(t,i,n,r,a,s){var u,o;void 0===r?o=n:(u=e.isFunction(r)?r:e.constant(r),(o=new p(null,r=n?function(t,e){var i=u(t,e);return n.skip()?i:n.skip(!0).value=i}:u,a,!1)).modified(s&&s.force),o.rank=0,n&&(o.skip(!0),o.value=n.value,o.targets().add(n))),i.targets().add(o)}function k(t,e,i){this.dataflow=t,this.stamp=null==e?-1:e,this.add=[],this.rem=[],this.mod=[],this.fields=null,this.encode=i||null}function D(t,e){return t?function(i,n){return t(i,n)&&e(i,n)}:e}function w(t,e){var i={};return t.visit(e,function(t){i[s(t)]=1}),function(t){return i[s(t)]?null:t}}function O(t){var e,i,n=new Promise(function(t,n){e=t,i=n});return n.requests=0,n.done=function(){0==--n.requests&&t.runAfter(function(){t._pending=null;try{t.run(),e(t)}catch(t){i(t)}})},t._pending=n}function q(t,e,i,n){var r,a,s,u,o,l=this,h=0;for(this.dataflow=t,this.stamp=e,this.fields=null,this.encode=n||null,this.pulses=i,s=0,u=i.length;s<u;++s)if((r=i[s]).stamp===e){if(r.fields){a=l.fields||(l.fields={});for(o in r.fields)a[o]=1}r.changed(l.ADD)&&(h|=l.ADD),r.changed(l.REM)&&(h|=l.REM),r.changed(l.MOD)&&(h|=l.MOD)}this.changes=h}function E(t){this.cmp=t,this.nodes=[]}function b(t,e,i,n){var r,a,s;for(r=t[i];i>e&&n(r,a=t[s=i-1>>1])<0;)t[i]=a,i=s;return t[i]=r}function A(t,e,i){for(var n,r=e,a=t.length,s=t[e],u=2*e+1;u<a;)(n=u+1)<a&&i(t[u],t[n])>=0&&(u=n),t[e]=t[u],u=2*(e=u)+1;return t[e]=s,b(t,r,e,i)}function F(){this._log=e.logger(),this.logLevel(e.Error),this._clock=0,this._rank=0,this._loader=i.loader(),this._touched=a(e.id),this._pulses={},this._pulse=null,this._heap=new E(function(t,e){return t.qrank-e.qrank}),this._postrun=[]}function R(t){return function(){return this._log[t].apply(this,arguments)}}function M(t,e){p.call(this,t,null,e)}function S(t,e){var i=t.type;N(i,t),C(i,e)}function N(t,e){return t=t&&t.toLowerCase(),arguments.length>1?(Xt[t]=e,this):Xt.hasOwnProperty(t)?Xt[t]:null}function C(t,e){return arguments.length>1?(Qt[t]=e,this):Qt.hasOwnProperty(t)?Qt[t]:null}function P(t){this._key=t?e.field(t):s,this._add=[],this._rem=[],this._ext=null,this._get=null,this._q=null}function U(t,e){return Zt[t](e)}function L(t){return function(i){var n=e.extend({init:"",add:"",rem:"",idx:0},t);return n.out=i||t.name,n}}function z(t,e){return t.idx-e.idx}function I(t,e){function i(t,n){function r(e){t[e]||i(t,t[e]=Zt[e]())}return n.req&&n.req.forEach(r),e&&n.str&&n.str.forEach(r),t}var n,r=t.reduce(i,t.reduce(function(t,e){return t[e.name]=e,t},{})),a=[];for(n in r)a.push(r[n]);return a.sort(z)}function T(t,i){var n=i||e.identity,r="this.cell = cell; this.tuple = t; this.valid = 0; this.missing = 0;",a="if(v==null){++this.missing; return;} if(v!==v) return; ++this.valid;",s="if(v==null){--this.missing; return;} if(v!==v) return; --this.valid;",u="var t = this.tuple; var cell = this.cell;";return I(t,!0).forEach(function(t){t.idx<0?(r=t.init+r,a=t.add+a,s=t.rem+s):(r+=t.init,a+=t.add,s+=t.rem)}),t.slice().sort(z).forEach(function(t){u+="t['"+t.out+"']="+t.set+";"}),u+="return t;",r=Function("cell","t",r),r.prototype.add=Function("v","t",a),r.prototype.rem=Function("v","t",s),r.prototype.set=Function(u),r.prototype.get=n,r.fields=t.map(function(t){return t.out}),r}function j(t){M.call(this,null,t),this._adds=[],this._mods=[],this._alen=0,this._mlen=0,this._drop=!0,this._cross=!1,this._dims=[],this._dnames=[],this._measures=[],this._countOnly=!1,this._counts=null,this._prev=null,this._inputs=null,this._outputs=null}function W(t,e,i){return i||t+(e?"_"+e:"")}function G(t){var e,i=this._dims,n=i.length,r=String(i[0](t));for(e=1;e<n;++e)r+="|"+i[e](t);return r}function K(t){M.call(this,null,t)}function V(t){M.call(this,[],t)}function B(t){p.call(this,null,J,t)}function J(t){return this.value&&!t.modified()?this.value:e.compare(t.fields,t.orders)}function $(t){M.call(this,null,t)}function H(t,e,i){switch(e){case"upper":t=t.toUpperCase();break;case"lower":t=t.toLowerCase()}return t.match(i)}function Q(t){M.call(this,null,t)}function X(t,e,i,n){for(var r,a,s=[],u={},l=t.length,h=0;h<l;++h)for(u[e]=a=t[h],r=0;r<l;++r)u[i]=t[r],n(u)&&(s.push(o(u)),(u={})[e]=a);return s}function Y(t,i){var n=t[ae];ne.hasOwnProperty(n)||e.error("Unknown distribution function: "+n);var r=ne[n]();for(var a in t)a===se?r.data((t.from||i()).map(t[a])):a===re?r[a](t[a].map(function(t){return Y(t,i)})):typeof r[a]===ae&&r[a](t[a]);return r}function Z(t){M.call(this,null,t)}function tt(t){return function(){return t.materialize(t.SOURCE).source}}function et(t){M.call(this,[1/0,-1/0],t)}function it(t,e){p.call(this,t),this.parent=e}function nt(t){M.call(this,{},t),this._keys=e.fastmap();var i=this._targets=[];i.active=0,i.forEach=function(t){for(var e=0,n=i.active;e<n;++e)t(i[e],e,i)}}function rt(t){p.call(this,null,at,t)}function at(t){return this.value&&!t.modified()?this.value:e.isArray(t.name)?e.array(t.name).map(function(t){return e.field(t)}):e.field(t.name,t.as)}function st(t){M.call(this,e.fastmap(),t)}function ut(t){M.call(this,{},t)}function ot(t){return t.fields.join("|")}function lt(t){M.call(this,null,t)}function ht(t){M.call(this,[],t)}function ft(t){M.call(this,[],t)}function dt(t){var i,n=t.method||le.value;if(null!=le[n])return n===le.value?(i=void 0!==t.value?t.value:0,function(){return i}):le[n];e.error("Unrecognized imputation method: "+n)}function ct(t){var e=t.field;return function(t){return t?e(t):NaN}}function mt(t,e,i,n){var r,a,s,u,o,l,h,f,d=[],c=n?n.slice():[],m={},p={};for(c.forEach(function(t,e){m[t]=e+1}),u=0,h=t.length;u<h;++u)l=i(f=t[u]),o=m[l]||(m[l]=c.push(l)),(s=p[a=(r=e?e.map(function(t){return t(f)}):he)+""])||(s=p[a]=[],d.push(s),s.values=r),s[o-1]=f;return d.domain=c,d}function pt(t){j.call(this,t)}function vt(t){p.call(this,null,gt,t)}function gt(t){return this.value&&!t.modified()?this.value:e.key(t.fields)}function yt(t){M.call(this,{},t)}function _t(t){p.call(this,null,xt,t)}function xt(t){if(this.value&&!t.modified())return this.value;var e,i,n,r=1/0,a=-1/0,s=t.extents;for(e=0,i=s.length;e<i;++e)(n=s[e])[0]<r&&(r=n[0]),n[1]>a&&(a=n[1]);return[r,a]}function kt(t){p.call(this,null,Dt,t)}function Dt(t){return this.value&&!t.modified()?this.value:t.values.reduce(function(t,e){return t.concat(e)},[])}function wt(t){M.call(this,null,t)}function Ot(t){nt.call(this,t)}function qt(t){M.call(this,null,t)}function Et(t){M.call(this,null,t)}function bt(t){M.call(this,null,t)}function At(t){M.call(this,[],t),this.count=0}function Ft(t){M.call(this,null,t)}function Rt(t){M.call(this,null,t),this.modified(!0)}function Mt(t){M.call(this,e.fastmap(),t)}function St(t){M.call(this,null,t)}var Nt=Symbol("vega_id"),Ct=1,Pt="_:mod:_",Ut=m.prototype;Ut.set=function(t,i,n,r){var a=this,s=a[t],u=a[Pt];return null!=i&&i>=0?(s[i]!==n||r)&&(s[i]=n,u[i+":"+t]=-1,u[t]=-1):(s!==n||r)&&(a[t]=n,u[t]=e.isArray(n)?1+n.length:-1),a},Ut.modified=function(t,i){var n,r=this[Pt];if(!arguments.length){for(n in r)if(r[n])return!0;return!1}if(e.isArray(t)){for(n=0;n<t.length;++n)if(r[t[n]])return!0;return!1}return null!=i&&i>=0?i+1<r[t]||!!r[i+":"+t]:!!r[t]},Ut.clear=function(){return this[Pt]={},this};var Lt=0,zt=new m,It=p.prototype;It.targets=function(){return this._targets||(this._targets=a(e.id))},It.set=function(t){return this.value!==t?(this.value=t,1):0},It.skip=v(1),It.modified=v(2),It.parameters=function(t,i){function n(t,e,n){n instanceof p?(n!==o&&(i&&n.targets().add(o),f.push(n)),h.push({op:n,name:t,index:e})):l.set(t,e,n)}i=!1!==i;var r,a,s,u,o=this,l=o._argval=o._argval||new m,h=o._argops=o._argops||[],f=[];for(r in t)if(a=t[r],"pulse"===r)e.array(a).forEach(function(t){t instanceof p?t!==o&&(t.targets().add(o),f.push(t)):e.error("Pulse parameters must be operator instances.")}),o.source=a;else if(e.isArray(a))for(l.set(r,-1,Array(s=a.length)),u=0;u<s;++u)n(r,u,a[u]);else n(r,-1,a);return this.marshall().clear(),f},It.marshall=function(t){var e,i,n,r,a,s=this._argval||zt,u=this._argops;if(u&&(n=u.length))for(i=0;i<n;++i)a=(r=(e=u[i]).op).modified()&&r.stamp===t,s.set(e.name,e.index,r.value,a);return s},It.evaluate=function(t){if(this._update){var e=this.marshall(t.stamp),i=this._update(e,t);if(e.clear(),i!==this.value)this.value=i;else if(!this.modified())return t.StopPropagation}},It.run=function(t){if(t.stamp<=this.stamp)return t.StopPropagation;var e;return this.skip()?(this.skip(!1),e=0):e=this.evaluate(t),this.stamp=t.stamp,this.pulse=e,e||t};var Tt=0,jt=g.prototype;jt._filter=e.truthy,jt._apply=e.identity,jt.targets=function(){return this._targets||(this._targets=a(e.id))},jt.consume=function(t){return arguments.length?(this._consume=!!t,this):!!this._consume},jt.receive=function(t){if(this._filter(t)){for(var e=this.value=this._apply(t),i=this._targets,n=i?i.length:0,r=0;r<n;++r)i[r].receive(e);this._consume&&(t.preventDefault(),t.stopPropagation())}},jt.filter=function(t){var e=y(t);return this.targets().add(e),e},jt.apply=function(t){var e=y(null,t);return this.targets().add(e),e},jt.merge=function(){var t=y();this.targets().add(t);for(var e=0,i=arguments.length;e<i;++e)arguments[e].targets().add(t);return t},jt.throttle=function(t){var e=-1;return this.filter(function(){var i=Date.now();return i-e>t?(e=i,1):0})},jt.debounce=function(t){var i=y();return this.targets().add(y(null,null,e.debounce(t,function(t){var e=t.dataflow;i.receive(t),e&&e.run&&e.run()}))),i},jt.between=function(t,e){var i=!1;return t.targets().add(y(null,null,function(){i=!0})),e.targets().add(y(null,null,function(){i=!1})),this.filter(function(){return i})};var Wt={skip:!0},Gt={},Kt=k.prototype;Kt.StopPropagation=Gt,Kt.ADD=1,Kt.REM=2,Kt.MOD=4,Kt.ADD_REM=3,Kt.ADD_MOD=5,Kt.ALL=7,Kt.REFLOW=8,Kt.SOURCE=16,Kt.NO_SOURCE=32,Kt.NO_FIELDS=64,Kt.fork=function(t){return new k(this.dataflow).init(this,t)},Kt.addAll=function(){var t=this;return this.source&&this.source.length!==this.add.length?(t=new k(this.dataflow).init(this),t.add=t.source,t):t},Kt.init=function(t,e){var i=this;return i.stamp=t.stamp,i.encode=t.encode,!t.fields||64&e||(i.fields=t.fields),1&e?(i.addF=t.addF,i.add=t.add):(i.addF=null,i.add=[]),2&e?(i.remF=t.remF,i.rem=t.rem):(i.remF=null,i.rem=[]),4&e?(i.modF=t.modF,i.mod=t.mod):(i.modF=null,i.mod=[]),32&e?(i.srcF=null,i.source=null):(i.srcF=t.srcF,i.source=t.source),i},Kt.runAfter=function(t){this.dataflow.runAfter(t)},Kt.changed=function(t){var e=t||7;return 1&e&&this.add.length||2&e&&this.rem.length||4&e&&this.mod.length},Kt.reflow=function(t){if(t)return this.fork(7).reflow();var e=this.add.length,i=this.source&&this.source.length;return i&&i!==e&&(this.mod=this.source,e&&this.filter(4,w(this,1))),this},Kt.modifies=function(t){var i=e.array(t),n=this.fields||(this.fields={});return i.forEach(function(t){n[t]=!0}),this},Kt.modified=function(t){var i=this.fields;return!(!this.mod.length||!i)&&(arguments.length?e.isArray(t)?t.some(function(t){return i[t]}):i[t]:!!i)},Kt.filter=function(t,e){var i=this;return 1&t&&(i.addF=D(i.addF,e)),2&t&&(i.remF=D(i.remF,e)),4&t&&(i.modF=D(i.modF,e)),16&t&&(i.srcF=D(i.srcF,e)),i},Kt.materialize=function(t){var e=this;return 1&(t=t||7)&&e.addF&&(e.add=e.add.filter(e.addF),e.addF=null),2&t&&e.remF&&(e.rem=e.rem.filter(e.remF),e.remF=null),4&t&&e.modF&&(e.mod=e.mod.filter(e.modF),e.modF=null),16&t&&e.srcF&&(e.source=e.source.filter(e.srcF),e.srcF=null),e},Kt.visit=function(t,i){var n,r,a=i;return 16&t?(e.visitArray(this.source,this.srcF,a),this):(1&t&&e.visitArray(this.add,this.addF,a),2&t&&e.visitArray(this.rem,this.remF,a),4&t&&e.visitArray(this.mod,this.modF,a),8&t&&(n=this.source)&&((r=this.add.length+this.mod.length)===n.length||(r?e.visitArray(n,w(this,5),a):e.visitArray(n,this.srcF,a))),this)};var Vt={skip:!1,force:!1},Bt=e.inherits(q,k);Bt.fork=function(){return arguments.length&&arguments[0]&k.prototype.ALL&&e.error("MultiPulse fork does not support tuple change sets."),new k(this.dataflow).init(this,0)},Bt.changed=function(t){return this.changes&t},Bt.modified=function(t){var i=this,n=i.fields;return n&&i.changes&i.MOD?e.isArray(t)?t.some(function(t){return n[t]}):n[t]:0},Bt.filter=function(){e.error("MultiPulse does not support filtering.")},Bt.materialize=function(){e.error("MultiPulse does not support materialization.")},Bt.visit=function(t,e){var i=this,n=i.pulses,r=n.length,a=0;if(t&i.SOURCE)for(;a<r;++a)n[a].visit(t,e);else for(;a<r;++a)n[a].stamp===i.stamp&&n[a].visit(t,e);return i};var Jt=E.prototype;Jt.size=function(){return this.nodes.length},Jt.clear=function(){return this.nodes=[],this},Jt.peek=function(){return this.nodes[0]},Jt.push=function(t){var e=this.nodes;return e.push(t),b(e,0,e.length-1,this.cmp)},Jt.pop=function(){var t,e=this.nodes,i=e.pop();return e.length?(t=e[0],e[0]=i,A(e,0,this.cmp)):t=i,t},Jt.replace=function(t){var e=this.nodes,i=e[0];return e[0]=t,A(e,0,this.cmp),i},Jt.pushpop=function(t){var e=this.nodes,i=e[0];return e.length&&this.cmp(i,t)<0&&(e[0]=t,t=i,A(e,0,this.cmp)),t};var $t=F.prototype;$t.stamp=function(){return this._clock},$t.loader=function(t){return arguments.length?(this._loader=t,this):this._loader},$t.cleanThreshold=1e4,$t.add=function(t,i,n,r){var a,s=1;return t instanceof p?a=t:t&&t.prototype instanceof p?a=new t:e.isFunction(t)?a=new p(null,t):(s=0,a=new p(t,i)),this.rank(a),s&&(r=n,n=i),n&&this.connect(a,a.parameters(n,r)),this.touch(a),a},$t.connect=function(t,e){var i,n,r=t.rank;for(i=0,n=e.length;i<n;++i)if(r<e[i].rank)return void this.rerank(t)},$t.rank=function(t){t.rank=++this._rank},$t.rerank=function(t){for(var e,i,n,r=[t];r.length;)if(this.rank(e=r.pop()),i=e._targets)for(n=i.length;--n>=0;)r.push(e=i[n]),e===t&&this.error("Cycle detected in dataflow graph.")},$t.pulse=function(t,e,i){this.touch(t,i||Vt);var n=new k(this,this._clock+(this._pulse?0:1)),r=t.pulse&&t.pulse.source||[];return n.target=t,this._pulses[t.id]=e.pulse(n,r),this},$t.touch=function(t,e){var i=e||Vt;return this._pulse?this._enqueue(t):this._touched.add(t),i.skip&&t.skip(!0),this},$t.update=function(t,e,i){var n=i||Vt;return(t.set(e)||n.force)&&this.touch(t,n),this},$t.changeset=c,$t.ingest=function(t,e,n){return this.pulse(t,this.changeset().insert(i.read(e,n)))},$t.request=function(t,e,i){var n=this,r=n._pending||O(n);r.requests+=1,n.loader().load(e,{context:"dataflow"}).then(function(e){n.ingest(t,e,i)},function(t){n.error("Loading failed",e,t)}).catch(function(t){n.error("Data ingestion failed",e,t)}).then(r.done,r.done)},$t.events=function(t,i,n,r){for(var a,s=this,u=y(n,r),o=0,l=(a="string"==typeof t&&"undefined"!=typeof document?document.querySelectorAll(t):e.array(t)).length;o<l;++o)a[o].addEventListener(i,function(t){t.dataflow=s;try{u.receive(t)}catch(t){s.error(t)}finally{s.run()}});return u},$t.on=function(t,e,i,n,r){return(t instanceof p?x:_)(this,t,e,i,n,r),this},$t.run=function(t){var i,n,r,s,u=this,o=0,l=u.logLevel();if(u._pending)return u.info("Awaiting requests, delaying dataflow run."),0;if(u._pulse)return u.error("Dataflow invoked recursively. Use the runAfter method to queue invocation."),0;if(!u._touched.length)return u.info("Dataflow invoked, but nothing to do."),0;u._pulse=new k(u,++u._clock,t),l>=e.Info&&(r=Date.now(),u.debug("-- START PROPAGATION ("+u._clock+") -----")),u._touched.forEach(function(t){u._enqueue(t,!0)}),u._touched=a(e.id);try{for(;u._heap.size()>0;)(i=u._heap.pop()).rank===i.qrank?(n=i.run(u._getPulse(i,t)),l>=e.Debug&&u.debug(i.id,n===Gt?"STOP":n,i),n!==Gt&&(u._pulse=n,i._targets&&i._targets.forEach(function(t){u._enqueue(t)})),++o):u._enqueue(i,!0)}catch(t){s=t}if(u._pulses={},u._pulse=null,l>=e.Info&&(r=Date.now()-r,u.info("> Pulse "+u._clock+": "+o+" operators; "+r+"ms")),s&&(u._postrun=[],u.error(s)),u._onrun)try{u._onrun(u,o,s)}catch(t){u.error(t)}if(u._postrun.length){var h=u._postrun;u._postrun=[],h.forEach(function(t){try{t(u)}catch(t){u.error(t)}})}return o},$t.runAsync=function(){return this._pending||Promise.resolve(this.run())},$t.runAfter=function(t){if(this._pulse)this._postrun.push(t);else try{t(this)}catch(t){this.error(t)}},$t._enqueue=function(t,e){var i=!this._pulses[t.id];i&&(this._pulses[t.id]=this._pulse),(i||e)&&(t.qrank=t.rank,this._heap.push(t))},$t._getPulse=function(t,i){var n,r=t.source,a=this._clock;return r&&e.isArray(r)?(n=r.map(function(t){return t.pulse}),new q(this,a,n,i)):(r=r&&r.pulse,n=this._pulses[t.id],r&&r!==Gt&&(r.stamp===a&&n.target!==t?n=r:n.source=r.source),n)},$t.error=R("error"),$t.warn=R("warn"),$t.info=R("info"),$t.debug=R("debug"),$t.logLevel=R("level");var Ht=e.inherits(M,p);Ht.run=function(t){if(t.stamp<=this.stamp)return t.StopPropagation;var e;return this.skip()?this.skip(!1):e=this.evaluate(t),(e=e||t)!==t.StopPropagation&&(this.pulse=e),this.stamp=t.stamp,e},Ht.evaluate=function(t){var e=this.marshall(t.stamp),i=this.transform(e,t);return e.clear(),i},Ht.transform=function(){};var Qt={},Xt={},Yt=P.prototype;Yt.add=function(t){this._add.push(t)},Yt.rem=function(t){this._rem.push(t)},Yt.values=function(){if(this._get=null,0===this._rem.length)return this._add;var t,e,i,n=this._add,r=this._rem,a=this._key,s=n.length,u=r.length,o=Array(s-u),l={};for(t=0;t<u;++t)l[a(r[t])]=1;for(t=0,e=0;t<s;++t)l[a(i=n[t])]?l[a(i)]=0:o[e++]=i;return this._rem=[],this._add=o},Yt.distinct=function(t){for(var e,i=this.values(),n=i.length,r={},a=0;--n>=0;)e=t(i[n])+"",r.hasOwnProperty(e)||(r[e]=1,++a);return a},Yt.extent=function(t){if(this._get!==t||!this._ext){var i=this.values(),n=e.extentIndex(i,t);this._ext=[i[n[0]],i[n[1]]],this._get=t}return this._ext},Yt.argmin=function(t){return this.extent(t)[0]||{}},Yt.argmax=function(t){return this.extent(t)[1]||{}},Yt.min=function(t){var e=this.extent(t)[0];return null!=e?t(e):1/0},Yt.max=function(t){var e=this.extent(t)[1];return null!=e?t(e):-1/0},Yt.quartile=function(t){return this._get===t&&this._q||(this._q=n.quartiles(this.values(),t),this._get=t),this._q},Yt.q1=function(t){return this.quartile(t)[0]},Yt.q2=function(t){return this.quartile(t)[1]},Yt.q3=function(t){return this.quartile(t)[2]},Yt.ci=function(t){return this._get===t&&this._ci||(this._ci=n.bootstrapCI(this.values(),1e3,.05,t),this._get=t),this._ci},Yt.ci0=function(t){return this.ci(t)[0]},Yt.ci1=function(t){return this.ci(t)[1]};var Zt={values:L({name:"values",init:"cell.store = true;",set:"cell.data.values()",idx:-1}),count:L({name:"count",set:"cell.num"}),missing:L({name:"missing",set:"this.missing"}),valid:L({name:"valid",set:"this.valid"}),sum:L({name:"sum",init:"this.sum = 0;",add:"this.sum += v;",rem:"this.sum -= v;",set:"this.sum"}),mean:L({name:"mean",init:"this.mean = 0;",add:"var d = v - this.mean; this.mean += d / this.valid;",rem:"var d = v - this.mean; this.mean -= this.valid ? d / this.valid : this.mean;",set:"this.mean"}),average:L({name:"average",set:"this.mean",req:["mean"],idx:1}),variance:L({name:"variance",init:"this.dev = 0;",add:"this.dev += d * (v - this.mean);",rem:"this.dev -= d * (v - this.mean);",set:"this.valid > 1 ? this.dev / (this.valid-1) : 0",req:["mean"],idx:1}),variancep:L({name:"variancep",set:"this.valid > 1 ? this.dev / this.valid : 0",req:["variance"],idx:2}),stdev:L({name:"stdev",set:"this.valid > 1 ? Math.sqrt(this.dev / (this.valid-1)) : 0",req:["variance"],idx:2}),stdevp:L({name:"stdevp",set:"this.valid > 1 ? Math.sqrt(this.dev / this.valid) : 0",req:["variance"],idx:2}),stderr:L({name:"stderr",set:"this.valid > 1 ? Math.sqrt(this.dev / (this.valid * (this.valid-1))) : 0",req:["variance"],idx:2}),distinct:L({name:"distinct",set:"cell.data.distinct(this.get)",req:["values"],idx:3}),ci0:L({name:"ci0",set:"cell.data.ci0(this.get)",req:["values"],idx:3}),ci1:L({name:"ci1",set:"cell.data.ci1(this.get)",req:["values"],idx:3}),median:L({name:"median",set:"cell.data.q2(this.get)",req:["values"],idx:3}),q1:L({name:"q1",set:"cell.data.q1(this.get)",req:["values"],idx:3}),q3:L({name:"q3",set:"cell.data.q3(this.get)",req:["values"],idx:3}),argmin:L({name:"argmin",add:"if (v < this.min) this.argmin = t;",rem:"if (v <= this.min) this.argmin = null;",set:"this.argmin || cell.data.argmin(this.get)",req:["min"],str:["values"],idx:3}),argmax:L({name:"argmax",add:"if (v > this.max) this.argmax = t;",rem:"if (v >= this.max) this.argmax = null;",set:"this.argmax || cell.data.argmax(this.get)",req:["max"],str:["values"],idx:3}),min:L({name:"min",init:"this.min = null;",add:"if (v < this.min || this.min === null) this.min = v;",rem:"if (v <= this.min) this.min = NaN;",set:"this.min = (isNaN(this.min) ? cell.data.min(this.get) : this.min)",str:["values"],idx:4}),max:L({name:"max",init:"this.max = null;",add:"if (v > this.max || this.max === null) this.max = v;",rem:"if (v >= this.max) this.max = NaN;",set:"this.max = (isNaN(this.max) ? cell.data.max(this.get) : this.max)",str:["values"],idx:4})},te=e.inherits(j,M);te.transform=function(t,e){var i,n=this,r=e.fork(e.NO_SOURCE|e.NO_FIELDS);return this.stamp=r.stamp,this.value&&((i=t.modified())||e.modified(this._inputs))?(this._prev=this.value,this.value=i?this.init(t):{},e.visit(e.SOURCE,function(t){n.add(t)})):(this.value=this.value||this.init(t),e.visit(e.REM,function(t){n.rem(t)}),e.visit(e.ADD,function(t){n.add(t)})),r.modifies(this._outputs),n._drop=!1!==t.drop,t.cross&&n._dims.length>1&&(n._drop=!1,this.cross()),n.changes(r)},te.cross=function(){function t(t){var e,i,n,u;for(e in t)for(n=t[e].tuple,i=0;i<s;++i)a[i][u=n[r[i]]]=u}function e(t,u,o){var l,h,f=r[o],d=a[o++];for(l in d)u[f]=d[l],h=t?t+"|"+l:l,o<s?e(h,u,o):n[h]||i.cell(h,u)}var i=this,n=i.value,r=i._dnames,a=r.map(function(){return{}}),s=r.length;t(i._prev),t(n),e("",{},0)},te.init=function(t){function i(t){for(var e,i=t.fields,r=0,s=i.length;r<s;++r)a[e=i[r]]||(a[e]=1,n.push(e))}var n=this._inputs=[],r=this._outputs=[],a={};this._dims=e.array(t.groupby),this._dnames=this._dims.map(function(t){var n=e.accessorName(t);return i(t),r.push(n),n}),this.cellkey=t.key?t.key:0===this._dims.length?function(){return""}:1===this._dims.length?this._dims[0]:G,this._countOnly=!0,this._counts=[],this._measures=[];var s,u,o,l,h,f,d=t.fields||[null],c=t.ops||["count"],m=t.as||[],p=d.length,v={};for(p!==c.length&&e.error("Unmatched number of fields and aggregate ops."),f=0;f<p;++f)s=d[f],u=c[f],null==s&&"count"!==u&&e.error("Null aggregate field specified."),h=W(u,l=e.accessorName(s),m[f]),r.push(h),"count"!==u?((o=v[l])||(i(s),(o=v[l]=[]).field=s,this._measures.push(o)),"count"!==u&&(this._countOnly=!1),o.push(U(u,h))):this._counts.push(h);return this._measures=this._measures.map(function(t){return T(t,t.field)}),{}},te.cellkey=G,te.cell=function(t,e){var i=this.value[t];return i?0===i.num&&this._drop&&i.stamp<this.stamp?(i.stamp=this.stamp,this._adds[this._alen++]=i):i.stamp<this.stamp&&(i.stamp=this.stamp,this._mods[this._mlen++]=i):(i=this.value[t]=this.newcell(t,e),this._adds[this._alen++]=i),i},te.newcell=function(t,e){var i={key:t,num:0,agg:null,tuple:this.newtuple(e,this._prev&&this._prev[t]),stamp:this.stamp,store:!1};if(!this._countOnly){var n,r=this._measures,a=r.length;for(i.agg=Array(a),n=0;n<a;++n)i.agg[n]=new r[n](i,i.tuple)}return i.store&&(i.data=new P),i},te.newtuple=function(t,e){var i,n,r=this._dnames,a=this._dims,s={};for(i=0,n=a.length;i<n;++i)s[r[i]]=a[i](t);return e?f(e.tuple,s):o(s)},te.add=function(t){var e,i,n,r=this.cellkey(t),a=this.cell(r,t);if(a.num+=1,!this._countOnly)for(a.store&&a.data.add(t),i=0,n=(e=a.agg).length;i<n;++i)e[i].add(e[i].get(t),t)},te.rem=function(t){var e,i,n,r=this.cellkey(t),a=this.cell(r,t);if(a.num-=1,!this._countOnly)for(a.store&&a.data.rem(t),i=0,n=(e=a.agg).length;i<n;++i)e[i].rem(e[i].get(t),t)},te.celltuple=function(t){var e,i,n,r=t.tuple,a=this._counts;for(t.store&&t.data.values(),i=0,n=a.length;i<n;++i)r[a[i]]=t.num;if(!this._countOnly)for(i=0,n=(e=t.agg).length;i<n;++i)e[i].set();return r},te.changes=function(t){var e,i,n,r,a=this._adds,s=this._mods,u=this._prev,o=this._drop,l=t.add,h=t.rem,f=t.mod;if(u)for(i in u)e=u[i],o&&!e.num||h.push(e.tuple);for(n=0,r=this._alen;n<r;++n)l.push(this.celltuple(a[n])),a[n]=null;for(n=0,r=this._mlen;n<r;++n)(0===(e=s[n]).num&&o?h:f).push(this.celltuple(e)),s[n]=null;return this._alen=this._mlen=0,this._prev=null,t};var ee=e.inherits(K,M);ee.transform=function(t,i){var n,r=this._bins(t),a=r.start,s=r.step,u=t.as||["bin0","bin1"],o=u[0],l=u[1];return n=t.modified()?(i=i.reflow(!0)).SOURCE:i.modified(e.accessorFields(t.field))?i.ADD_MOD:i.ADD,i.visit(n,function(t){var e=r(t);t[o]=e,t[l]=null==e?null:a+s*(1+(e-a)/s)}),i.modifies(u)},ee._bins=function(t){if(this.value&&!t.modified())return this.value;var i,r,a=t.field,s=n.bin(t),u=s.start,o=s.stop,l=s.step;null!=(i=t.anchor)&&(r=i-(u+l*Math.floor((i-u)/l)),u+=r,o+=r);var h=function(t){var e=a(t);return null==e?null:(e=Math.max(u,Math.min(+e,o-l)),u+l*Math.floor((e-u)/l))};return h.start=u,h.stop=o,h.step=l,this.value=e.accessor(h,e.accessorFields(a),t.name||"bin_"+e.accessorName(a))},e.inherits(V,M).transform=function(t,i){var n,r=i.fork(i.ALL),a=i.changed(i.ADD),u=i.changed(),o=t.sort,l=this.value;return r.rem.length&&(n={},r.visit(r.REM,function(t){n[s(t)]=1}),l=l.filter(function(t){return!n[s(t)]})),o?((t.modified("sort")||i.modified(o.fields))&&(l.sort(o),u=!0),a&&(l=e.merge(o,l,r.add.sort(o)))):a&&r.visit(r.ADD,function(t){l.push(t)}),this.modified(u),this.value=r.source=l,r},e.inherits(B,p);var ie=e.inherits($,M);ie.transform=function(t,e){function i(e){return function(i){for(var n,r=H(u(i),t.case,a)||[],o=0,l=r.length;o<l;++o)s.test(n=r[o])||e(n)}}var n=this._parameterCheck(t,e),r=this._counts,a=this._match,s=this._stop,u=t.field,o=t.as||["text","count"],l=i(function(t){r[t]=1+(r[t]||0)}),h=i(function(t){r[t]-=1});return n?e.visit(e.SOURCE,l):(e.visit(e.ADD,l),e.visit(e.REM,h)),this._finish(e,o)},ie._parameterCheck=function(t,e){var i=!1;return!t.modified("stopwords")&&this._stop||(this._stop=new RegExp("^"+(t.stopwords||"")+"$","i"),i=!0),!t.modified("pattern")&&this._match||(this._match=new RegExp(t.pattern||"[\\w']+","g"),i=!0),(t.modified("field")||e.modified(t.field.fields))&&(i=!0),i&&(this._counts={}),i},ie._finish=function(t,e){var i,n,r,a=this._counts,s=this._tuples||(this._tuples={}),u=e[0],l=e[1],h=t.fork();for(i in a)n=s[i],r=a[i]||0,!n&&r?(s[i]=n=o({}),n[u]=i,n[l]=r,h.add.push(n)):0===r?(n&&h.rem.push(n),a[i]=null,s[i]=null):n[l]!==r&&(n[l]=r,h.mod.push(n));return h.modifies(e)},e.inherits(Q,M).transform=function(t,i){var n=i.fork(i.NO_SOURCE),r=this.value,a=t.as||["a","b"],s=a[0],u=a[1];return!r||i.changed(i.ADD_REM)||t.modified("as")||t.modified("filter")?(r&&(n.rem=r),n.add=this.value=X(i.source,s,u,t.filter||e.truthy)):n.mod=r,n.source=this.value,n.modifies(a)};var ne={kde:n.randomKDE,mixture:n.randomMixture,normal:n.randomNormal,uniform:n.randomUniform},re="distributions",ae="function",se="field";e.inherits(Z,M).transform=function(t,i){var n=i.fork(i.NO_SOURCE|i.NO_FIELDS);if(!this.value||i.changed()||t.modified()){var a=Y(t.distribution,tt(i)),s=t.method||"pdf";"pdf"!==s&&"cdf"!==s&&e.error("Invalid density method: "+s),t.extent||a.data||e.error("Missing density extent parameter."),s=a[s];var u=t.as||["value","density"],l=t.extent||r.extent(a.data()),h=(l[1]-l[0])/(t.steps||100),f=r.range(l[0],l[1]+h/2,h).map(function(t){var e={};return e[u[0]]=t,e[u[1]]=s(t),o(e)});this.value&&(n.rem=this.value),this.value=n.add=n.source=f}return n},e.inherits(et,M).transform=function(t,e){var i=this.value,n=t.field,r=i[0],a=i[1],s=e.ADD;(e.changed()||e.modified(n.fields)||t.modified("field"))&&(s=e.SOURCE,r=1/0,a=-1/0),e.visit(s,function(t){var e=n(t);e<r&&(r=e),e>a&&(a=e)}),this.value=[r,a]};var ue=e.inherits(it,p);ue.connect=function(t){return this.targets().add(t),t.source=this},ue.add=function(t){this.value.add.push(t)},ue.rem=function(t){this.value.rem.push(t)},ue.mod=function(t){this.value.mod.push(t)},ue.init=function(t){this.value.init(t,t.NO_SOURCE)},ue.evaluate=function(){return this.value};var oe=e.inherits(nt,M);oe.activate=function(t){this._targets[this._targets.active++]=t},oe.subflow=function(t,e,i,n){var r,a,s=this.value,u=s.hasOwnProperty(t)&&s[t];return u?u.value.stamp<i.stamp&&(u.init(i),this.activate(u)):(a=n||(a=this._group[t])&&a.tuple,u=(r=i.dataflow).add(new it(i.fork(i.NO_SOURCE),this)).connect(e(r,t,a)),s[t]=u,this.activate(u)),u},oe.transform=function(t,e){function i(t){return r.subflow(t,u,e)}var n=e.dataflow,r=this,a=t.key,u=t.subflow,o=this._keys,l=t.modified("key");return this._group=t.group||{},this._targets.active=0,e.visit(e.REM,function(t){var e=s(t),n=o.get(e);void 0!==n&&(o.delete(e),i(n).rem(t))}),e.visit(e.ADD,function(t){var e=a(t);o.set(s(t),e),i(e).add(t)}),l||e.modified(a.fields)?e.visit(e.MOD,function(t){var e=s(t),n=o.get(e),r=a(t);n===r?i(r).mod(t):(o.set(e,r),i(n).rem(t),i(r).add(t))}):e.changed(e.MOD)&&e.visit(e.MOD,function(t){i(o.get(s(t))).mod(t)}),l&&e.visit(e.REFLOW,function(t){var e=s(t),n=o.get(e),r=a(t);n!==r&&(o.set(e,r),i(n).rem(t),i(r).add(t))}),o.empty>n.cleanThreshold&&n.runAfter(o.clean),e},e.inherits(rt,p),e.inherits(st,M).transform=function(t,e){function i(e){var i=s(e),n=h(e,t),a=r.get(i);n&&a?(r.delete(i),u.push(e)):n||a?f&&n&&!a&&l.push(e):(r.set(i,1),o.push(e))}var n=e.dataflow,r=this.value,a=e.fork(),u=a.add,o=a.rem,l=a.mod,h=t.expr,f=!0;return e.visit(e.REM,function(t){var e=s(t);r.has(e)?r.delete(e):o.push(t)}),e.visit(e.ADD,function(e){h(e,t)?u.push(e):r.set(s(e),1)}),e.visit(e.MOD,i),t.modified()&&(f=!1,e.visit(e.REFLOW,i)),r.empty>n.cleanThreshold&&n.runAfter(r.clean),a},e.inherits(ut,M).transform=function(t,e){function i(t){for(var e,i=r[s(t)]=Array(m),n=0;n<m;++n)(e=i[n]=l(t))[f]=c[n],e[d]=u[n](t),v.add.push(e)}var n,r=this.value,a=t.modified("fields"),u=t.fields,o=t.as||["key","value"],f=o[0],d=o[1],c=u.map(ot),m=u.length,p=e.stamp,v=e.fork(e.NO_SOURCE),g=0,y=0;if(a){for(n in r)v.rem.push.apply(v.rem,r[n]);r=this.value={},e.visit(e.SOURCE,i)}else{for(e.visit(e.ADD,i);g<m;++g)e.modified(u[g].fields)&&(y|=1<<g);y&&e.visit(e.MOD,function(t){for(var e,i=r[s(t)],n=0;n<m;++n)y&1<<n&&((e=h(t,i[n],p))[f]=c[n],e[d]=u[n](t),v.mod.push(e))}),e.visit(e.REM,function(t){var e=s(t);v.rem.push.apply(v.rem,r[e]),r[e]=null})}return v.modifies(o)},e.inherits(lt,M).transform=function(t,e){var i=t.expr,n=t.as,r=t.modified(),a=t.initonly?e.ADD:r?e.SOURCE:e.modified(i.fields)?e.ADD_MOD:e.ADD;return r&&(e=e.materialize().reflow(!0)),t.initonly||e.modifies(n),e.visit(a,function(e){e[n]=i(e,t)})},e.inherits(ht,M).transform=function(t,e){var i,n,r,a=this.value,s=e.fork(e.ALL),u=t.size-a.length,l=t.generator;if(u>0){for(i=[];--u>=0;)i.push(r=o(l(t))),a.push(r);s.add=s.add.length?s.materialize(s.ADD).add.concat(i):i}else n=a.slice(0,-u),s.rem=s.rem.length?s.materialize(s.REM).rem.concat(n):n,a=a.slice(-u);return s.source=this.value=a,s};var le={value:"value",median:r.median,mean:r.mean,min:r.min,max:r.max},he=[];e.inherits(ft,M).transform=function(t,i){var n,r,a,s,u,l,h,f,d,c,m=i.fork(i.ALL),p=dt(t),v=ct(t),g=e.accessorName(t.field),y=e.accessorName(t.key),_=(t.groupby||[]).map(e.accessorName),x=mt(i.source,t.groupby,t.key,t.keyvals),k=[],D=this.value,w=x.domain.length;for(u=0,f=x.length;u<f;++u)for(a=(n=x[u]).values,r=NaN,h=0;h<w;++h)if(null==n[h]){for(s=x.domain[h],c={_impute:!0},l=0,d=a.length;l<d;++l)c[_[l]]=a[l];c[y]=s,c[g]=isNaN(r)?r=p(n,v):r,k.push(o(c))}return k.length&&(m.add=m.materialize(m.ADD).add.concat(k)),D.length&&(m.rem=m.materialize(m.REM).rem.concat(D)),this.value=k,m};var fe=e.inherits(pt,j);fe.transform=function(t,e){var i,n=this,r=t.modified();return n.value&&(r||e.modified(n._inputs))?(i=n.value=r?n.init(t):{},e.visit(e.SOURCE,function(t){n.add(t)})):(i=n.value=n.value||this.init(t),e.visit(e.REM,function(t){n.rem(t)}),e.visit(e.ADD,function(t){n.add(t)})),n.changes(),e.visit(e.SOURCE,function(t){h(i[n.cellkey(t)].tuple,t)}),e.reflow(r).modifies(this._outputs)},fe.changes=function(){var t,e,i=this._adds,n=this._mods;for(t=0,e=this._alen;t<e;++t)this.celltuple(i[t]),i[t]=null;for(t=0,e=this._mlen;t<e;++t)this.celltuple(n[t]),n[t]=null;this._alen=this._mlen=0},e.inherits(vt,p),e.inherits(yt,M).transform=function(t,i){var n,r,a=i,s=t.as,u=t.fields,o=t.index,l=t.values,h=null==t.default?null:t.default,f=t.modified(),d=f?i.SOURCE:i.ADD,c=u.length;return l?(r=l.length,c>1&&!s&&e.error('Multi-field lookup requires explicit "as" parameter.'),s&&s.length!==c*r&&e.error('The "as" parameter has too few output field names.'),s=s||l.map(e.accessorName),n=function(t){for(var e,i,n=0,a=0;n<c;++n)if(null==(i=o.get(u[n](t))))for(e=0;e<r;++e,++a)t[s[a]]=h;else for(e=0;e<r;++e,++a)t[s[a]]=l[e](i)}):(s||e.error("Missing output field names."),n=function(t){for(var e,i=0;i<c;++i)e=o.get(u[i](t)),t[s[i]]=null==e?h:e}),f?a=i.reflow(!0):d|=u.some(function(t){return i.modified(t.fields)})?i.MOD:0,i.visit(d,n),a.modifies(s)},e.inherits(_t,p),e.inherits(kt,p),e.inherits(wt,M),wt.prototype.transform=function(t,e){return this.modified(t.modified()),this.value=t,e.fork(e.NO_SOURCE|e.NO_FIELDS)},e.inherits(Ot,nt).transform=function(t,i){var n=this,r=t.subflow,a=t.field;return(t.modified("field")||a&&i.modified(e.accessorFields(a)))&&e.error("PreFacet does not support field modification."),this._targets.active=0,i.visit(i.MOD,function(t){var e=n.subflow(s(t),r,i,t);a?a(t).forEach(function(t){e.mod(t)}):e.mod(t)}),i.visit(i.ADD,function(t){var e=n.subflow(s(t),r,i,t);a?a(t).forEach(function(t){e.add(o(t))}):e.add(t)}),i.visit(i.REM,function(t){var e=n.subflow(s(t),r,i,t);a?a(t).forEach(function(t){e.rem(t)}):e.rem(t)}),i},e.inherits(qt,M).transform=function(t,e){return this.value=t.value,t.modified("value")?e.fork(e.NO_SOURCE|e.NO_FIELDS):e.StopPropagation},e.inherits(Et,M).transform=function(t,i){i.source||e.error("Rank transform requires an upstream data source.");var n,r=t.normalize,a=t.field,s=t.as||"rank",u={},o=-1;return a?(i.visit(i.SOURCE,function(t){var e=a(t);null==u[e]&&(u[e]=++o)}),i.visit(i.SOURCE,r&&--o?function(t){t[s]=u[a(t)]/o}:function(t){t[s]=u[a(t)]})):(o+=i.source.length,n=-1,i.visit(i.SOURCE,r&&o?function(t){t[s]=++n/o}:function(t){t[s]=++n})),i.reflow(t.modified()).modifies(s)},e.inherits(bt,M).transform=function(t,e){var i,n;return this.value?n=this.value:(i=e=e.addAll(),n=this.value={}),t.derive&&(i=e.fork(),e.visit(e.REM,function(t){var e=s(t);i.rem.push(n[e]),n[e]=null}),e.visit(e.ADD,function(t){var e=l(t);n[s(t)]=e,i.add.push(e)}),e.visit(e.MOD,function(t){i.mod.push(h(t,n[s(t)]))})),i},e.inherits(At,M).transform=function(t,e){function i(t){var e,i;u.length<a?u.push(t):(i=~~(o*Math.random()))<u.length&&i>=l&&(e=u[i],h[s(e)]&&n.rem.push(e),u[i]=t),++o}var n=e.fork(),r=t.modified("size"),a=t.size,u=this.value,o=this.count,l=0,h=u.reduce(function(t,e){return t[s(e)]=1,t},{});if(e.rem.length&&(e.visit(e.REM,function(t){var e=s(t);h[e]&&(h[e]=-1,n.rem.push(t)),--o}),u=u.filter(function(t){return-1!==h[s(t)]})),(e.rem.length||r)&&u.length<a&&e.source&&(l=o=u.length,e.visit(e.SOURCE,function(t){h[s(t)]||i(t)}),l=-1),r&&u.length>a){for(var f=0,d=u.length-a;f<d;++f)h[s(u[f])]=-1,n.rem.push(u[f]);u=u.slice(d)}return e.mod.length&&e.visit(e.MOD,function(t){h[s(t)]&&n.mod.push(t)}),e.add.length&&e.visit(e.ADD,i),(e.add.length||l<0)&&(n.add=u.filter(function(t){return!h[s(t)]})),this.count=o,this.value=n.source=u,n},e.inherits(Ft,M).transform=function(t,e){if(!this.value||t.modified()){var i=e.materialize().fork(e.MOD);return i.rem=this.value?e.rem.concat(this.value):e.rem,i.source=this.value=r.range(t.start,t.stop,t.step||1).map(o),i.add=e.add.concat(this.value),i}},e.inherits(Rt,M).transform=function(t,e){return this.value=e.source,e.changed()?e.fork(e.NO_SOURCE|e.NO_FIELDS):e.StopPropagation},e.inherits(Mt,M).transform=function(t,e){function i(t){a.set(r(t),t)}var n=e.dataflow,r=t.field,a=this.value,s=!0;return t.modified("field")||e.modified(r.fields)?(a.clear(),e.visit(e.SOURCE,i)):e.changed()?(e.visit(e.REM,function(t){a.delete(r(t))}),e.visit(e.ADD,i)):s=!1,this.modified(s),a.empty>n.cleanThreshold&&n.runAfter(a.clean),e.fork()},e.inherits(St,M).transform=function(t,e){(!this.value||t.modified("field")||t.modified("sort")||e.changed()||t.sort&&e.modified(t.sort.fields))&&(this.value=(t.sort?e.source.slice().sort(t.sort):e.source).map(t.field))};var de={type:"Aggregate",metadata:{generates:!0,changes:!0},params:[{name:"groupby",type:"field",array:!0},{name:"fields",type:"field",array:!0},{name:"ops",type:"enum",array:!0,values:["count","valid","missing","distinct","sum","mean","average","variance","variancep","stdev","stdevp","stderr","median","q1","q3","ci0","ci1","min","max","argmin","argmax"]},{name:"as",type:"string",array:!0},{name:"drop",type:"boolean",default:!0},{name:"cross",type:"boolean",default:!1},{name:"key",type:"field"}]},ce={type:"Bin",metadata:{modifies:!0},params:[{name:"field",type:"field",required:!0},{name:"anchor",type:"number"},{name:"maxbins",type:"number",default:20},{name:"base",type:"number",default:10},{name:"divide",type:"number",array:!0,default:[5,2]},{name:"extent",type:"number",array:!0,length:2,required:!0},{name:"step",type:"number"},{name:"steps",type:"number",array:!0},{name:"minstep",type:"number",default:0},{name:"nice",type:"boolean",default:!0},{name:"name",type:"string"},{name:"as",type:"string",array:!0,length:2,default:["bin0","bin1"]}]},me={type:"Collect",metadata:{source:!0},params:[{name:"sort",type:"compare"}]},pe={type:"CountPattern",metadata:{generates:!0,changes:!0},params:[{name:"field",type:"field",required:!0},{name:"case",type:"enum",values:["upper","lower","mixed"],default:"mixed"},{name:"pattern",type:"string",default:'[\\w"]+'},{name:"stopwords",type:"string",default:""},{name:"as",type:"string",array:!0,length:2,default:["text","count"]}]},ve={type:"Cross",metadata:{source:!0,generates:!0,changes:!0},params:[{name:"filter",type:"expr"},{name:"as",type:"string",array:!0,length:2,default:["a","b"]}]},ge=[{key:{function:"normal"},params:[{name:"mean",type:"number",default:0},{name:"stdev",type:"number",default:1}]},{key:{function:"uniform"},params:[{name:"min",type:"number",default:0},{name:"max",type:"number",default:1}]},{key:{function:"kde"},params:[{name:"field",type:"field",required:!0},{name:"from",type:"data"},{name:"bandwidth",type:"number",default:0}]}],ye={key:{function:"mixture"},params:[{name:"distributions",type:"param",array:!0,params:ge},{name:"weights",type:"number",array:!0}]},_e={type:"Density",metadata:{generates:!0,source:!0},params:[{name:"extent",type:"number",array:!0,length:2},{name:"steps",type:"number",default:100},{name:"method",type:"string",default:"pdf",values:["pdf","cdf"]},{name:"distribution",type:"param",params:ge.concat(ye)},{name:"as",type:"string",array:!0,default:["value","density"]}]},xe={type:"Extent",metadata:{},params:[{name:"field",type:"field",required:!0}]},ke={type:"Filter",metadata:{changes:!0},params:[{name:"expr",type:"expr",required:!0}]},De={type:"Fold",metadata:{generates:!0,changes:!0},params:[{name:"fields",type:"field",array:!0,required:!0},{name:"as",type:"string",array:!0,length:2,default:["key","value"]}]},we={type:"Formula",metadata:{modifies:!0},params:[{name:"expr",type:"expr",required:!0},{name:"as",type:"string",required:!0},{name:"initonly",type:"boolean"}]},Oe={type:"Impute",metadata:{changes:!0},params:[{name:"field",type:"field",required:!0},{name:"key",type:"field",required:!0},{name:"keyvals",array:!0},{name:"groupby",type:"field",array:!0},{name:"method",type:"enum",default:"value",values:["value","mean","median","max","min"]},{name:"value",default:0}]},qe={type:"JoinAggregate",metadata:{modifies:!0},params:[{name:"groupby",type:"field",array:!0},{name:"fields",type:"field",array:!0},{name:"ops",type:"enum",array:!0,values:["count","valid","missing","distinct","sum","mean","average","variance","variancep","stdev","stdevp","stderr","median","q1","q3","ci0","ci1","min","max","argmin","argmax"]},{name:"as",type:"string",array:!0},{name:"key",type:"field"}]},Ee={type:"Lookup",metadata:{modifies:!0},params:[{name:"index",type:"index",params:[{name:"from",type:"data",required:!0},{name:"key",type:"field",required:!0}]},{name:"values",type:"field",array:!0},{name:"fields",type:"field",array:!0,required:!0},{name:"as",type:"string",array:!0},{name:"default",default:null}]},be={type:"Rank",metadata:{modifies:!0},params:[{name:"field",type:"field"},{name:"normalize",type:"boolean",default:!1},{name:"as",type:"string",default:"rank"}]},Ae={type:"Sample",metadata:{source:!0,changes:!0},params:[{name:"size",type:"number",default:1e3}]},Fe={type:"Sequence",metadata:{generates:!0,source:!0},params:[{name:"start",type:"number",required:!0},{name:"stop",type:"number",required:!0},{name:"step",type:"number",default:1}],output:["value"]};S(de,j),S(ce,K),S(me,V),S(pe,$),S(ve,Q),S(_e,Z),S(xe,et),S(ke,st),S(De,ut),S(we,lt),S(Oe,ft),S(qe,pt),S(Ee,yt),S(be,Et),S(Ae,At),S(Fe,Ft),C("Compare",B),C("Facet",nt),C("Field",rt),C("Generate",ht),C("Key",vt),C("MultiExtent",_t),C("MultiValues",kt),C("Params",wt),C("PreFacet",Ot),C("Proxy",qt),C("Relay",bt),C("Sieve",Rt),C("Subflow",it),C("TupleIndex",Mt),C("Values",St),t.UniqueList=a,t.changeset=c,t.isChangeSet=d,t.Dataflow=F,t.EventStream=g,t.Parameters=m,t.Pulse=k,t.MultiPulse=q,t.Operator=p,t.Transform=M,t.ingest=o,t.isTuple=function(t){return!(!t||!s(t))},t.replace=f,t.tupleid=s,t.definition=N,t.definitions=Xt,t.register=S,t.transform=C,t.transforms=Qt,Object.defineProperty(t,"__esModule",{value:!0})});
!function(t,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports,require("vega-util"),require("vega-loader"),require("vega-statistics"),require("d3-array")):"function"==typeof define&&define.amd?define(["exports","vega-util","vega-loader","vega-statistics","d3-array"],e):e(t.vega=t.vega||{},t.vega,t.vega,t.vega,t.d3)}(this,function(t,e,i,n,r){"use strict";function a(t){var i=t||e.identity,n=[],r={};return n.add=function(t){var e=i(t);return r[e]||(r[e]=1,n.push(t)),n},n.remove=function(t){var e,a=i(t);return r[a]&&(r[a]=0,(e=n.indexOf(t))>=0&&n.splice(e,1)),n},n}function s(t){return t[Nt]}function u(t,e){return t[Nt]=e,t}function o(t){var e=t===Object(t)?t:{data:t};return s(e)?e:u(e,Ct++)}function l(t){return h(t,o({}))}function h(t,e){for(var i in t)e[i]=t[i];return e}function f(t,e){return u(e,s(t))}function d(t){return t&&t.constructor===c}function c(){var t=[],i=[],n=[],r=[],a=[],u=!1;return{constructor:c,insert:function(i){for(var n=e.array(i),r=0,a=n.length;r<a;++r)t.push(n[r]);return this},remove:function(t){for(var n=e.isFunction(t)?r:i,a=e.array(t),s=0,u=a.length;s<u;++s)n.push(a[s]);return this},modify:function(t,i,r){var s={field:i,value:e.constant(r)};return e.isFunction(t)?(s.filter=t,a.push(s)):(s.tuple=t,n.push(s)),this},encode:function(t,i){return e.isFunction(t)?a.push({filter:t,field:i}):n.push({tuple:t,field:i}),this},reflow:function(){return u=!0,this},pulse:function(e,l){function h(t,i,n){n?t[i]=n(t):e.encode=i,u||(f[s(t)]=t)}var f,d,c,m,p,v,g;for(d=0,c=t.length;d<c;++d)e.add.push(o(t[d]));for(f={},d=0,c=i.length;d<c;++d)f[s(v=i[d])]=v;for(d=0,c=r.length;d<c;++d)p=r[d],l.forEach(function(t){p(t)&&(f[s(t)]=t)});for(g in f)e.rem.push(f[g]);for(f={},d=0,c=n.length;d<c;++d)h((m=n[d]).tuple,m.field,m.value),e.modifies(m.field);for(d=0,c=a.length;d<c;++d)m=a[d],p=m.filter,l.forEach(function(t){p(t)&&h(t,m.field,m.value)}),e.modifies(m.field);if(u)e.mod=i.length||r.length?l.filter(function(t){return f.hasOwnProperty(s(t))}):l.slice();else for(g in f)e.mod.push(f[g]);return e}}}function m(){Object.defineProperty(this,Pt,{writable:!0,value:{}})}function p(t,e,i,n){this.id=++Lt,this.value=t,this.stamp=-1,this.rank=-1,this.qrank=-1,this.flags=0,e&&(this._update=e),i&&this.parameters(i,n)}function v(t){return function(e){var i=this.flags;return 0===arguments.length?!!(i&t):(this.flags=e?i|t:i&~t,this)}}function g(t,e,i){this.id=++Tt,this.value=null,i&&(this.receive=i),t&&(this._filter=t),e&&(this._apply=e)}function y(t,e,i){return new g(t,e,i)}function _(t,i,n,r,a,s){var u,o,l=e.extend({},s,Wt);e.isFunction(n)||(n=e.constant(n)),void 0===r?u=function(e){t.touch(n(e))}:e.isFunction(r)?(o=new p(null,r,a,!1),u=function(e){var i,r=n(e);o.evaluate(e),d(i=o.value)?t.pulse(r,i,s):t.update(r,i,l)}):u=function(e){t.update(n(e),r,l)},i.apply(u)}function x(t,i,n,r,a,s){var u,o;void 0===r?o=n:(u=e.isFunction(r)?r:e.constant(r),(o=new p(null,r=n?function(t,e){var i=u(t,e);return n.skip()?i:n.skip(!0).value=i}:u,a,!1)).modified(s&&s.force),o.rank=0,n&&(o.skip(!0),o.value=n.value,o.targets().add(n))),i.targets().add(o)}function k(t,e,i){this.dataflow=t,this.stamp=null==e?-1:e,this.add=[],this.rem=[],this.mod=[],this.fields=null,this.encode=i||null}function D(t,e){return t?function(i,n){return t(i,n)&&e(i,n)}:e}function w(t,e){var i={};return t.visit(e,function(t){i[s(t)]=1}),function(t){return i[s(t)]?null:t}}function O(t){var e,i,n=new Promise(function(t,n){e=t,i=n});return n.requests=0,n.done=function(){0==--n.requests&&t.runAfter(function(){t._pending=null;try{t.run(),e(t)}catch(t){i(t)}})},t._pending=n}function q(t,e,i,n){var r,a,s,u,o,l=this,h=0;for(this.dataflow=t,this.stamp=e,this.fields=null,this.encode=n||null,this.pulses=i,s=0,u=i.length;s<u;++s)if((r=i[s]).stamp===e){if(r.fields){a=l.fields||(l.fields={});for(o in r.fields)a[o]=1}r.changed(l.ADD)&&(h|=l.ADD),r.changed(l.REM)&&(h|=l.REM),r.changed(l.MOD)&&(h|=l.MOD)}this.changes=h}function E(t){this.cmp=t,this.nodes=[]}function b(t,e,i,n){var r,a,s;for(r=t[i];i>e&&n(r,a=t[s=i-1>>1])<0;)t[i]=a,i=s;return t[i]=r}function A(t,e,i){for(var n,r=e,a=t.length,s=t[e],u=2*e+1;u<a;)(n=u+1)<a&&i(t[u],t[n])>=0&&(u=n),t[e]=t[u],u=2*(e=u)+1;return t[e]=s,b(t,r,e,i)}function F(){this._log=e.logger(),this.logLevel(e.Error),this._clock=0,this._rank=0,this._loader=i.loader(),this._touched=a(e.id),this._pulses={},this._pulse=null,this._heap=new E(function(t,e){return t.qrank-e.qrank}),this._postrun=[]}function R(t){return function(){return this._log[t].apply(this,arguments)}}function M(t,e){p.call(this,t,null,e)}function S(t,e){var i=t.type;N(i,t),C(i,e)}function N(t,e){return t=t&&t.toLowerCase(),arguments.length>1?(Xt[t]=e,this):Xt.hasOwnProperty(t)?Xt[t]:null}function C(t,e){return arguments.length>1?(Qt[t]=e,this):Qt.hasOwnProperty(t)?Qt[t]:null}function P(t){this._key=t?e.field(t):s,this._add=[],this._rem=[],this._ext=null,this._get=null,this._q=null}function U(t,e){return Zt[t](e)}function L(t){return function(i){var n=e.extend({init:"",add:"",rem:"",idx:0},t);return n.out=i||t.name,n}}function z(t,e){return t.idx-e.idx}function I(t,e){function i(t,n){function r(e){t[e]||i(t,t[e]=Zt[e]())}return n.req&&n.req.forEach(r),e&&n.str&&n.str.forEach(r),t}var n,r=t.reduce(i,t.reduce(function(t,e){return t[e.name]=e,t},{})),a=[];for(n in r)a.push(r[n]);return a.sort(z)}function T(t,i){var n=i||e.identity,r="this.cell = cell; this.tuple = t; this.valid = 0; this.missing = 0;",a="if(v==null){++this.missing; return;} if(v!==v) return; ++this.valid;",s="if(v==null){--this.missing; return;} if(v!==v) return; --this.valid;",u="var t = this.tuple; var cell = this.cell;";return I(t,!0).forEach(function(t){t.idx<0?(r=t.init+r,a=t.add+a,s=t.rem+s):(r+=t.init,a+=t.add,s+=t.rem)}),t.slice().sort(z).forEach(function(t){u+="t['"+t.out+"']="+t.set+";"}),u+="return t;",r=Function("cell","t",r),r.prototype.add=Function("v","t",a),r.prototype.rem=Function("v","t",s),r.prototype.set=Function(u),r.prototype.get=n,r.fields=t.map(function(t){return t.out}),r}function j(t){M.call(this,null,t),this._adds=[],this._mods=[],this._alen=0,this._mlen=0,this._drop=!0,this._cross=!1,this._dims=[],this._dnames=[],this._measures=[],this._countOnly=!1,this._counts=null,this._prev=null,this._inputs=null,this._outputs=null}function W(t,e,i){return i||t+(e?"_"+e:"")}function G(t){var e,i=this._dims,n=i.length,r=String(i[0](t));for(e=1;e<n;++e)r+="|"+i[e](t);return r}function K(t){M.call(this,null,t)}function V(t){M.call(this,[],t)}function B(t){p.call(this,null,J,t)}function J(t){return this.value&&!t.modified()?this.value:e.compare(t.fields,t.orders)}function $(t){M.call(this,null,t)}function H(t,e,i){switch(e){case"upper":t=t.toUpperCase();break;case"lower":t=t.toLowerCase()}return t.match(i)}function Q(t){M.call(this,null,t)}function X(t,e,i,n){for(var r,a,s=[],u={},l=t.length,h=0;h<l;++h)for(u[e]=a=t[h],r=0;r<l;++r)u[i]=t[r],n(u)&&(s.push(o(u)),(u={})[e]=a);return s}function Y(t,i){var n=t[ae];ne.hasOwnProperty(n)||e.error("Unknown distribution function: "+n);var r=ne[n]();for(var a in t)a===se?r.data((t.from||i()).map(t[a])):a===re?r[a](t[a].map(function(t){return Y(t,i)})):typeof r[a]===ae&&r[a](t[a]);return r}function Z(t){M.call(this,null,t)}function tt(t){return function(){return t.materialize(t.SOURCE).source}}function et(t){M.call(this,[1/0,-1/0],t)}function it(t,e){p.call(this,t),this.parent=e}function nt(t){M.call(this,{},t),this._keys=e.fastmap();var i=this._targets=[];i.active=0,i.forEach=function(t){for(var e=0,n=i.active;e<n;++e)t(i[e],e,i)}}function rt(t){p.call(this,null,at,t)}function at(t){return this.value&&!t.modified()?this.value:e.isArray(t.name)?e.array(t.name).map(function(t){return e.field(t)}):e.field(t.name,t.as)}function st(t){M.call(this,e.fastmap(),t)}function ut(t){M.call(this,{},t)}function ot(t){return t.fields.join("|")}function lt(t){M.call(this,null,t)}function ht(t){M.call(this,[],t)}function ft(t){M.call(this,[],t)}function dt(t){var i,n=t.method||le.value;if(null!=le[n])return n===le.value?(i=void 0!==t.value?t.value:0,function(){return i}):le[n];e.error("Unrecognized imputation method: "+n)}function ct(t){var e=t.field;return function(t){return t?e(t):NaN}}function mt(t,e,i,n){var r,a,s,u,o,l,h,f,d=[],c=n?n.slice():[],m={},p={};for(c.forEach(function(t,e){m[t]=e+1}),u=0,h=t.length;u<h;++u)l=i(f=t[u]),o=m[l]||(m[l]=c.push(l)),(s=p[a=(r=e?e.map(function(t){return t(f)}):he)+""])||(s=p[a]=[],d.push(s),s.values=r),s[o-1]=f;return d.domain=c,d}function pt(t){j.call(this,t)}function vt(t){p.call(this,null,gt,t)}function gt(t){return this.value&&!t.modified()?this.value:e.key(t.fields)}function yt(t){M.call(this,{},t)}function _t(t){p.call(this,null,xt,t)}function xt(t){if(this.value&&!t.modified())return this.value;var e,i,n,r=1/0,a=-1/0,s=t.extents;for(e=0,i=s.length;e<i;++e)(n=s[e])[0]<r&&(r=n[0]),n[1]>a&&(a=n[1]);return[r,a]}function kt(t){p.call(this,null,Dt,t)}function Dt(t){return this.value&&!t.modified()?this.value:t.values.reduce(function(t,e){return t.concat(e)},[])}function wt(t){M.call(this,null,t)}function Ot(t){nt.call(this,t)}function qt(t){M.call(this,null,t)}function Et(t){M.call(this,null,t)}function bt(t){M.call(this,null,t)}function At(t){M.call(this,[],t),this.count=0}function Ft(t){M.call(this,null,t)}function Rt(t){M.call(this,null,t),this.modified(!0)}function Mt(t){M.call(this,e.fastmap(),t)}function St(t){M.call(this,null,t)}var Nt=Symbol("vega_id"),Ct=1,Pt="_:mod:_",Ut=m.prototype;Ut.set=function(t,i,n,r){var a=this,s=a[t],u=a[Pt];return null!=i&&i>=0?(s[i]!==n||r)&&(s[i]=n,u[i+":"+t]=-1,u[t]=-1):(s!==n||r)&&(a[t]=n,u[t]=e.isArray(n)?1+n.length:-1),a},Ut.modified=function(t,i){var n,r=this[Pt];if(!arguments.length){for(n in r)if(r[n])return!0;return!1}if(e.isArray(t)){for(n=0;n<t.length;++n)if(r[t[n]])return!0;return!1}return null!=i&&i>=0?i+1<r[t]||!!r[i+":"+t]:!!r[t]},Ut.clear=function(){return this[Pt]={},this};var Lt=0,zt=new m,It=p.prototype;It.targets=function(){return this._targets||(this._targets=a(e.id))},It.set=function(t){return this.value!==t?(this.value=t,1):0},It.skip=v(1),It.modified=v(2),It.parameters=function(t,i){function n(t,e,n){n instanceof p?(n!==o&&(i&&n.targets().add(o),f.push(n)),h.push({op:n,name:t,index:e})):l.set(t,e,n)}i=!1!==i;var r,a,s,u,o=this,l=o._argval=o._argval||new m,h=o._argops=o._argops||[],f=[];for(r in t)if(a=t[r],"pulse"===r)e.array(a).forEach(function(t){t instanceof p?t!==o&&(t.targets().add(o),f.push(t)):e.error("Pulse parameters must be operator instances.")}),o.source=a;else if(e.isArray(a))for(l.set(r,-1,Array(s=a.length)),u=0;u<s;++u)n(r,u,a[u]);else n(r,-1,a);return this.marshall().clear(),f},It.marshall=function(t){var e,i,n,r,a,s=this._argval||zt,u=this._argops;if(u&&(n=u.length))for(i=0;i<n;++i)a=(r=(e=u[i]).op).modified()&&r.stamp===t,s.set(e.name,e.index,r.value,a);return s},It.evaluate=function(t){if(this._update){var e=this.marshall(t.stamp),i=this._update(e,t);if(e.clear(),i!==this.value)this.value=i;else if(!this.modified())return t.StopPropagation}},It.run=function(t){if(t.stamp<=this.stamp)return t.StopPropagation;var e;return this.skip()?(this.skip(!1),e=0):e=this.evaluate(t),this.stamp=t.stamp,this.pulse=e,e||t};var Tt=0,jt=g.prototype;jt._filter=e.truthy,jt._apply=e.identity,jt.targets=function(){return this._targets||(this._targets=a(e.id))},jt.consume=function(t){return arguments.length?(this._consume=!!t,this):!!this._consume},jt.receive=function(t){if(this._filter(t)){for(var e=this.value=this._apply(t),i=this._targets,n=i?i.length:0,r=0;r<n;++r)i[r].receive(e);this._consume&&(t.preventDefault(),t.stopPropagation())}},jt.filter=function(t){var e=y(t);return this.targets().add(e),e},jt.apply=function(t){var e=y(null,t);return this.targets().add(e),e},jt.merge=function(){var t=y();this.targets().add(t);for(var e=0,i=arguments.length;e<i;++e)arguments[e].targets().add(t);return t},jt.throttle=function(t){var e=-1;return this.filter(function(){var i=Date.now();return i-e>t?(e=i,1):0})},jt.debounce=function(t){var i=y();return this.targets().add(y(null,null,e.debounce(t,function(t){var e=t.dataflow;i.receive(t),e&&e.run&&e.run()}))),i},jt.between=function(t,e){var i=!1;return t.targets().add(y(null,null,function(){i=!0})),e.targets().add(y(null,null,function(){i=!1})),this.filter(function(){return i})};var Wt={skip:!0},Gt={},Kt=k.prototype;Kt.StopPropagation=Gt,Kt.ADD=1,Kt.REM=2,Kt.MOD=4,Kt.ADD_REM=3,Kt.ADD_MOD=5,Kt.ALL=7,Kt.REFLOW=8,Kt.SOURCE=16,Kt.NO_SOURCE=32,Kt.NO_FIELDS=64,Kt.fork=function(t){return new k(this.dataflow).init(this,t)},Kt.addAll=function(){var t=this;return this.source&&this.source.length!==this.add.length?(t=new k(this.dataflow).init(this),t.add=t.source,t):t},Kt.init=function(t,e){var i=this;return i.stamp=t.stamp,i.encode=t.encode,!t.fields||64&e||(i.fields=t.fields),1&e?(i.addF=t.addF,i.add=t.add):(i.addF=null,i.add=[]),2&e?(i.remF=t.remF,i.rem=t.rem):(i.remF=null,i.rem=[]),4&e?(i.modF=t.modF,i.mod=t.mod):(i.modF=null,i.mod=[]),32&e?(i.srcF=null,i.source=null):(i.srcF=t.srcF,i.source=t.source),i},Kt.runAfter=function(t){this.dataflow.runAfter(t)},Kt.changed=function(t){var e=t||7;return 1&e&&this.add.length||2&e&&this.rem.length||4&e&&this.mod.length},Kt.reflow=function(t){if(t)return this.fork(7).reflow();var e=this.add.length,i=this.source&&this.source.length;return i&&i!==e&&(this.mod=this.source,e&&this.filter(4,w(this,1))),this},Kt.modifies=function(t){var i=e.array(t),n=this.fields||(this.fields={});return i.forEach(function(t){n[t]=!0}),this},Kt.modified=function(t){var i=this.fields;return!(!this.mod.length||!i)&&(arguments.length?e.isArray(t)?t.some(function(t){return i[t]}):i[t]:!!i)},Kt.filter=function(t,e){var i=this;return 1&t&&(i.addF=D(i.addF,e)),2&t&&(i.remF=D(i.remF,e)),4&t&&(i.modF=D(i.modF,e)),16&t&&(i.srcF=D(i.srcF,e)),i},Kt.materialize=function(t){var e=this;return 1&(t=t||7)&&e.addF&&(e.add=e.add.filter(e.addF),e.addF=null),2&t&&e.remF&&(e.rem=e.rem.filter(e.remF),e.remF=null),4&t&&e.modF&&(e.mod=e.mod.filter(e.modF),e.modF=null),16&t&&e.srcF&&(e.source=e.source.filter(e.srcF),e.srcF=null),e},Kt.visit=function(t,i){var n,r,a=i;return 16&t?(e.visitArray(this.source,this.srcF,a),this):(1&t&&e.visitArray(this.add,this.addF,a),2&t&&e.visitArray(this.rem,this.remF,a),4&t&&e.visitArray(this.mod,this.modF,a),8&t&&(n=this.source)&&((r=this.add.length+this.mod.length)===n.length||(r?e.visitArray(n,w(this,5),a):e.visitArray(n,this.srcF,a))),this)};var Vt={skip:!1,force:!1},Bt=e.inherits(q,k);Bt.fork=function(){return arguments.length&&arguments[0]&k.prototype.ALL&&e.error("MultiPulse fork does not support tuple change sets."),new k(this.dataflow).init(this,0)},Bt.changed=function(t){return this.changes&t},Bt.modified=function(t){var i=this,n=i.fields;return n&&i.changes&i.MOD?e.isArray(t)?t.some(function(t){return n[t]}):n[t]:0},Bt.filter=function(){e.error("MultiPulse does not support filtering.")},Bt.materialize=function(){e.error("MultiPulse does not support materialization.")},Bt.visit=function(t,e){var i=this,n=i.pulses,r=n.length,a=0;if(t&i.SOURCE)for(;a<r;++a)n[a].visit(t,e);else for(;a<r;++a)n[a].stamp===i.stamp&&n[a].visit(t,e);return i};var Jt=E.prototype;Jt.size=function(){return this.nodes.length},Jt.clear=function(){return this.nodes=[],this},Jt.peek=function(){return this.nodes[0]},Jt.push=function(t){var e=this.nodes;return e.push(t),b(e,0,e.length-1,this.cmp)},Jt.pop=function(){var t,e=this.nodes,i=e.pop();return e.length?(t=e[0],e[0]=i,A(e,0,this.cmp)):t=i,t},Jt.replace=function(t){var e=this.nodes,i=e[0];return e[0]=t,A(e,0,this.cmp),i},Jt.pushpop=function(t){var e=this.nodes,i=e[0];return e.length&&this.cmp(i,t)<0&&(e[0]=t,t=i,A(e,0,this.cmp)),t};var $t=F.prototype;$t.stamp=function(){return this._clock},$t.loader=function(t){return arguments.length?(this._loader=t,this):this._loader},$t.cleanThreshold=1e4,$t.add=function(t,i,n,r){var a,s=1;return t instanceof p?a=t:t&&t.prototype instanceof p?a=new t:e.isFunction(t)?a=new p(null,t):(s=0,a=new p(t,i)),this.rank(a),s&&(r=n,n=i),n&&this.connect(a,a.parameters(n,r)),this.touch(a),a},$t.connect=function(t,e){var i,n,r=t.rank;for(i=0,n=e.length;i<n;++i)if(r<e[i].rank)return void this.rerank(t)},$t.rank=function(t){t.rank=++this._rank},$t.rerank=function(t){for(var e,i,n,r=[t];r.length;)if(this.rank(e=r.pop()),i=e._targets)for(n=i.length;--n>=0;)r.push(e=i[n]),e===t&&this.error("Cycle detected in dataflow graph.")},$t.pulse=function(t,e,i){this.touch(t,i||Vt);var n=new k(this,this._clock+(this._pulse?0:1)),r=t.pulse&&t.pulse.source||[];return n.target=t,this._pulses[t.id]=e.pulse(n,r),this},$t.touch=function(t,e){var i=e||Vt;return this._pulse?this._enqueue(t):this._touched.add(t),i.skip&&t.skip(!0),this},$t.update=function(t,e,i){var n=i||Vt;return(t.set(e)||n.force)&&this.touch(t,n),this},$t.changeset=c,$t.ingest=function(t,e,n){return this.pulse(t,this.changeset().insert(i.read(e,n)))},$t.request=function(t,e,i){var n=this,r=n._pending||O(n);r.requests+=1,n.loader().load(e,{context:"dataflow"}).then(function(e){n.ingest(t,e,i)},function(t){n.error("Loading failed",e,t)}).catch(function(t){n.error("Data ingestion failed",e,t)}).then(r.done,r.done)},$t.events=function(t,i,n,r){for(var a,s=this,u=y(n,r),o=0,l=(a="string"==typeof t&&"undefined"!=typeof document?document.querySelectorAll(t):e.array(t)).length;o<l;++o)a[o].addEventListener(i,function(t){t.dataflow=s;try{u.receive(t)}catch(t){s.error(t)}finally{s.run()}});return u},$t.on=function(t,e,i,n,r){return(t instanceof p?x:_)(this,t,e,i,n,r),this},$t.run=function(t){var i,n,r,s,u=this,o=0,l=u.logLevel();if(u._pending)return u.info("Awaiting requests, delaying dataflow run."),0;if(u._pulse)return u.error("Dataflow invoked recursively. Use the runAfter method to queue invocation."),0;if(!u._touched.length)return u.info("Dataflow invoked, but nothing to do."),0;u._pulse=new k(u,++u._clock,t),l>=e.Info&&(r=Date.now(),u.debug("-- START PROPAGATION ("+u._clock+") -----")),u._touched.forEach(function(t){u._enqueue(t,!0)}),u._touched=a(e.id);try{for(;u._heap.size()>0;)(i=u._heap.pop()).rank===i.qrank?(n=i.run(u._getPulse(i,t)),l>=e.Debug&&u.debug(i.id,n===Gt?"STOP":n,i),n!==Gt&&(u._pulse=n,i._targets&&i._targets.forEach(function(t){u._enqueue(t)})),++o):u._enqueue(i,!0)}catch(t){s=t}if(u._pulses={},u._pulse=null,l>=e.Info&&(r=Date.now()-r,u.info("> Pulse "+u._clock+": "+o+" operators; "+r+"ms")),s&&(u._postrun=[],u.error(s)),u._onrun)try{u._onrun(u,o,s)}catch(t){u.error(t)}if(u._postrun.length){var h=u._postrun;u._postrun=[],h.forEach(function(t){try{t(u)}catch(t){u.error(t)}})}return o},$t.runAsync=function(){return this._pending||Promise.resolve(this.run())},$t.runAfter=function(t,e){if(this._pulse||e)this._postrun.push(t);else try{t(this)}catch(t){this.error(t)}},$t._enqueue=function(t,e){var i=!this._pulses[t.id];i&&(this._pulses[t.id]=this._pulse),(i||e)&&(t.qrank=t.rank,this._heap.push(t))},$t._getPulse=function(t,i){var n,r=t.source,a=this._clock;return r&&e.isArray(r)?(n=r.map(function(t){return t.pulse}),new q(this,a,n,i)):(r=r&&r.pulse,n=this._pulses[t.id],r&&r!==Gt&&(r.stamp===a&&n.target!==t?n=r:n.source=r.source),n)},$t.error=R("error"),$t.warn=R("warn"),$t.info=R("info"),$t.debug=R("debug"),$t.logLevel=R("level");var Ht=e.inherits(M,p);Ht.run=function(t){if(t.stamp<=this.stamp)return t.StopPropagation;var e;return this.skip()?this.skip(!1):e=this.evaluate(t),(e=e||t)!==t.StopPropagation&&(this.pulse=e),this.stamp=t.stamp,e},Ht.evaluate=function(t){var e=this.marshall(t.stamp),i=this.transform(e,t);return e.clear(),i},Ht.transform=function(){};var Qt={},Xt={},Yt=P.prototype;Yt.add=function(t){this._add.push(t)},Yt.rem=function(t){this._rem.push(t)},Yt.values=function(){if(this._get=null,0===this._rem.length)return this._add;var t,e,i,n=this._add,r=this._rem,a=this._key,s=n.length,u=r.length,o=Array(s-u),l={};for(t=0;t<u;++t)l[a(r[t])]=1;for(t=0,e=0;t<s;++t)l[a(i=n[t])]?l[a(i)]=0:o[e++]=i;return this._rem=[],this._add=o},Yt.distinct=function(t){for(var e,i=this.values(),n=i.length,r={},a=0;--n>=0;)e=t(i[n])+"",r.hasOwnProperty(e)||(r[e]=1,++a);return a},Yt.extent=function(t){if(this._get!==t||!this._ext){var i=this.values(),n=e.extentIndex(i,t);this._ext=[i[n[0]],i[n[1]]],this._get=t}return this._ext},Yt.argmin=function(t){return this.extent(t)[0]||{}},Yt.argmax=function(t){return this.extent(t)[1]||{}},Yt.min=function(t){var e=this.extent(t)[0];return null!=e?t(e):1/0},Yt.max=function(t){var e=this.extent(t)[1];return null!=e?t(e):-1/0},Yt.quartile=function(t){return this._get===t&&this._q||(this._q=n.quartiles(this.values(),t),this._get=t),this._q},Yt.q1=function(t){return this.quartile(t)[0]},Yt.q2=function(t){return this.quartile(t)[1]},Yt.q3=function(t){return this.quartile(t)[2]},Yt.ci=function(t){return this._get===t&&this._ci||(this._ci=n.bootstrapCI(this.values(),1e3,.05,t),this._get=t),this._ci},Yt.ci0=function(t){return this.ci(t)[0]},Yt.ci1=function(t){return this.ci(t)[1]};var Zt={values:L({name:"values",init:"cell.store = true;",set:"cell.data.values()",idx:-1}),count:L({name:"count",set:"cell.num"}),missing:L({name:"missing",set:"this.missing"}),valid:L({name:"valid",set:"this.valid"}),sum:L({name:"sum",init:"this.sum = 0;",add:"this.sum += v;",rem:"this.sum -= v;",set:"this.sum"}),mean:L({name:"mean",init:"this.mean = 0;",add:"var d = v - this.mean; this.mean += d / this.valid;",rem:"var d = v - this.mean; this.mean -= this.valid ? d / this.valid : this.mean;",set:"this.mean"}),average:L({name:"average",set:"this.mean",req:["mean"],idx:1}),variance:L({name:"variance",init:"this.dev = 0;",add:"this.dev += d * (v - this.mean);",rem:"this.dev -= d * (v - this.mean);",set:"this.valid > 1 ? this.dev / (this.valid-1) : 0",req:["mean"],idx:1}),variancep:L({name:"variancep",set:"this.valid > 1 ? this.dev / this.valid : 0",req:["variance"],idx:2}),stdev:L({name:"stdev",set:"this.valid > 1 ? Math.sqrt(this.dev / (this.valid-1)) : 0",req:["variance"],idx:2}),stdevp:L({name:"stdevp",set:"this.valid > 1 ? Math.sqrt(this.dev / this.valid) : 0",req:["variance"],idx:2}),stderr:L({name:"stderr",set:"this.valid > 1 ? Math.sqrt(this.dev / (this.valid * (this.valid-1))) : 0",req:["variance"],idx:2}),distinct:L({name:"distinct",set:"cell.data.distinct(this.get)",req:["values"],idx:3}),ci0:L({name:"ci0",set:"cell.data.ci0(this.get)",req:["values"],idx:3}),ci1:L({name:"ci1",set:"cell.data.ci1(this.get)",req:["values"],idx:3}),median:L({name:"median",set:"cell.data.q2(this.get)",req:["values"],idx:3}),q1:L({name:"q1",set:"cell.data.q1(this.get)",req:["values"],idx:3}),q3:L({name:"q3",set:"cell.data.q3(this.get)",req:["values"],idx:3}),argmin:L({name:"argmin",add:"if (v < this.min) this.argmin = t;",rem:"if (v <= this.min) this.argmin = null;",set:"this.argmin || cell.data.argmin(this.get)",req:["min"],str:["values"],idx:3}),argmax:L({name:"argmax",add:"if (v > this.max) this.argmax = t;",rem:"if (v >= this.max) this.argmax = null;",set:"this.argmax || cell.data.argmax(this.get)",req:["max"],str:["values"],idx:3}),min:L({name:"min",init:"this.min = null;",add:"if (v < this.min || this.min === null) this.min = v;",rem:"if (v <= this.min) this.min = NaN;",set:"this.min = (isNaN(this.min) ? cell.data.min(this.get) : this.min)",str:["values"],idx:4}),max:L({name:"max",init:"this.max = null;",add:"if (v > this.max || this.max === null) this.max = v;",rem:"if (v >= this.max) this.max = NaN;",set:"this.max = (isNaN(this.max) ? cell.data.max(this.get) : this.max)",str:["values"],idx:4})},te=e.inherits(j,M);te.transform=function(t,e){var i,n=this,r=e.fork(e.NO_SOURCE|e.NO_FIELDS);return this.stamp=r.stamp,this.value&&((i=t.modified())||e.modified(this._inputs))?(this._prev=this.value,this.value=i?this.init(t):{},e.visit(e.SOURCE,function(t){n.add(t)})):(this.value=this.value||this.init(t),e.visit(e.REM,function(t){n.rem(t)}),e.visit(e.ADD,function(t){n.add(t)})),r.modifies(this._outputs),n._drop=!1!==t.drop,t.cross&&n._dims.length>1&&(n._drop=!1,this.cross()),n.changes(r)},te.cross=function(){function t(t){var e,i,n,u;for(e in t)for(n=t[e].tuple,i=0;i<s;++i)a[i][u=n[r[i]]]=u}function e(t,u,o){var l,h,f=r[o],d=a[o++];for(l in d)u[f]=d[l],h=t?t+"|"+l:l,o<s?e(h,u,o):n[h]||i.cell(h,u)}var i=this,n=i.value,r=i._dnames,a=r.map(function(){return{}}),s=r.length;t(i._prev),t(n),e("",{},0)},te.init=function(t){function i(t){for(var e,i=t.fields,r=0,s=i.length;r<s;++r)a[e=i[r]]||(a[e]=1,n.push(e))}var n=this._inputs=[],r=this._outputs=[],a={};this._dims=e.array(t.groupby),this._dnames=this._dims.map(function(t){var n=e.accessorName(t);return i(t),r.push(n),n}),this.cellkey=t.key?t.key:0===this._dims.length?function(){return""}:1===this._dims.length?this._dims[0]:G,this._countOnly=!0,this._counts=[],this._measures=[];var s,u,o,l,h,f,d=t.fields||[null],c=t.ops||["count"],m=t.as||[],p=d.length,v={};for(p!==c.length&&e.error("Unmatched number of fields and aggregate ops."),f=0;f<p;++f)s=d[f],u=c[f],null==s&&"count"!==u&&e.error("Null aggregate field specified."),h=W(u,l=e.accessorName(s),m[f]),r.push(h),"count"!==u?((o=v[l])||(i(s),(o=v[l]=[]).field=s,this._measures.push(o)),"count"!==u&&(this._countOnly=!1),o.push(U(u,h))):this._counts.push(h);return this._measures=this._measures.map(function(t){return T(t,t.field)}),{}},te.cellkey=G,te.cell=function(t,e){var i=this.value[t];return i?0===i.num&&this._drop&&i.stamp<this.stamp?(i.stamp=this.stamp,this._adds[this._alen++]=i):i.stamp<this.stamp&&(i.stamp=this.stamp,this._mods[this._mlen++]=i):(i=this.value[t]=this.newcell(t,e),this._adds[this._alen++]=i),i},te.newcell=function(t,e){var i={key:t,num:0,agg:null,tuple:this.newtuple(e,this._prev&&this._prev[t]),stamp:this.stamp,store:!1};if(!this._countOnly){var n,r=this._measures,a=r.length;for(i.agg=Array(a),n=0;n<a;++n)i.agg[n]=new r[n](i,i.tuple)}return i.store&&(i.data=new P),i},te.newtuple=function(t,e){var i,n,r=this._dnames,a=this._dims,s={};for(i=0,n=a.length;i<n;++i)s[r[i]]=a[i](t);return e?f(e.tuple,s):o(s)},te.add=function(t){var e,i,n,r=this.cellkey(t),a=this.cell(r,t);if(a.num+=1,!this._countOnly)for(a.store&&a.data.add(t),i=0,n=(e=a.agg).length;i<n;++i)e[i].add(e[i].get(t),t)},te.rem=function(t){var e,i,n,r=this.cellkey(t),a=this.cell(r,t);if(a.num-=1,!this._countOnly)for(a.store&&a.data.rem(t),i=0,n=(e=a.agg).length;i<n;++i)e[i].rem(e[i].get(t),t)},te.celltuple=function(t){var e,i,n,r=t.tuple,a=this._counts;for(t.store&&t.data.values(),i=0,n=a.length;i<n;++i)r[a[i]]=t.num;if(!this._countOnly)for(i=0,n=(e=t.agg).length;i<n;++i)e[i].set();return r},te.changes=function(t){var e,i,n,r,a=this._adds,s=this._mods,u=this._prev,o=this._drop,l=t.add,h=t.rem,f=t.mod;if(u)for(i in u)e=u[i],o&&!e.num||h.push(e.tuple);for(n=0,r=this._alen;n<r;++n)l.push(this.celltuple(a[n])),a[n]=null;for(n=0,r=this._mlen;n<r;++n)(0===(e=s[n]).num&&o?h:f).push(this.celltuple(e)),s[n]=null;return this._alen=this._mlen=0,this._prev=null,t};var ee=e.inherits(K,M);ee.transform=function(t,i){var n,r=this._bins(t),a=r.start,s=r.step,u=t.as||["bin0","bin1"],o=u[0],l=u[1];return n=t.modified()?(i=i.reflow(!0)).SOURCE:i.modified(e.accessorFields(t.field))?i.ADD_MOD:i.ADD,i.visit(n,function(t){var e=r(t);t[o]=e,t[l]=null==e?null:a+s*(1+(e-a)/s)}),i.modifies(u)},ee._bins=function(t){if(this.value&&!t.modified())return this.value;var i,r,a=t.field,s=n.bin(t),u=s.start,o=s.stop,l=s.step;null!=(i=t.anchor)&&(r=i-(u+l*Math.floor((i-u)/l)),u+=r,o+=r);var h=function(t){var e=a(t);return null==e?null:(e=Math.max(u,Math.min(+e,o-l)),u+l*Math.floor((e-u)/l))};return h.start=u,h.stop=o,h.step=l,this.value=e.accessor(h,e.accessorFields(a),t.name||"bin_"+e.accessorName(a))},e.inherits(V,M).transform=function(t,i){var n,r=i.fork(i.ALL),a=i.changed(i.ADD),u=i.changed(),o=t.sort,l=this.value;return r.rem.length&&(n={},r.visit(r.REM,function(t){n[s(t)]=1}),l=l.filter(function(t){return!n[s(t)]})),o?((t.modified("sort")||i.modified(o.fields))&&(l.sort(o),u=!0),a&&(l=e.merge(o,l,r.add.sort(o)))):a&&r.visit(r.ADD,function(t){l.push(t)}),this.modified(u),this.value=r.source=l,r},e.inherits(B,p);var ie=e.inherits($,M);ie.transform=function(t,e){function i(e){return function(i){for(var n,r=H(u(i),t.case,a)||[],o=0,l=r.length;o<l;++o)s.test(n=r[o])||e(n)}}var n=this._parameterCheck(t,e),r=this._counts,a=this._match,s=this._stop,u=t.field,o=t.as||["text","count"],l=i(function(t){r[t]=1+(r[t]||0)}),h=i(function(t){r[t]-=1});return n?e.visit(e.SOURCE,l):(e.visit(e.ADD,l),e.visit(e.REM,h)),this._finish(e,o)},ie._parameterCheck=function(t,e){var i=!1;return!t.modified("stopwords")&&this._stop||(this._stop=new RegExp("^"+(t.stopwords||"")+"$","i"),i=!0),!t.modified("pattern")&&this._match||(this._match=new RegExp(t.pattern||"[\\w']+","g"),i=!0),(t.modified("field")||e.modified(t.field.fields))&&(i=!0),i&&(this._counts={}),i},ie._finish=function(t,e){var i,n,r,a=this._counts,s=this._tuples||(this._tuples={}),u=e[0],l=e[1],h=t.fork();for(i in a)n=s[i],r=a[i]||0,!n&&r?(s[i]=n=o({}),n[u]=i,n[l]=r,h.add.push(n)):0===r?(n&&h.rem.push(n),a[i]=null,s[i]=null):n[l]!==r&&(n[l]=r,h.mod.push(n));return h.modifies(e)},e.inherits(Q,M).transform=function(t,i){var n=i.fork(i.NO_SOURCE),r=this.value,a=t.as||["a","b"],s=a[0],u=a[1];return!r||i.changed(i.ADD_REM)||t.modified("as")||t.modified("filter")?(r&&(n.rem=r),n.add=this.value=X(i.source,s,u,t.filter||e.truthy)):n.mod=r,n.source=this.value,n.modifies(a)};var ne={kde:n.randomKDE,mixture:n.randomMixture,normal:n.randomNormal,uniform:n.randomUniform},re="distributions",ae="function",se="field";e.inherits(Z,M).transform=function(t,i){var n=i.fork(i.NO_SOURCE|i.NO_FIELDS);if(!this.value||i.changed()||t.modified()){var a=Y(t.distribution,tt(i)),s=t.method||"pdf";"pdf"!==s&&"cdf"!==s&&e.error("Invalid density method: "+s),t.extent||a.data||e.error("Missing density extent parameter."),s=a[s];var u=t.as||["value","density"],l=t.extent||r.extent(a.data()),h=(l[1]-l[0])/(t.steps||100),f=r.range(l[0],l[1]+h/2,h).map(function(t){var e={};return e[u[0]]=t,e[u[1]]=s(t),o(e)});this.value&&(n.rem=this.value),this.value=n.add=n.source=f}return n},e.inherits(et,M).transform=function(t,e){var i=this.value,n=t.field,r=i[0],a=i[1],s=e.ADD;(e.changed()||e.modified(n.fields)||t.modified("field"))&&(s=e.SOURCE,r=1/0,a=-1/0),e.visit(s,function(t){var e=n(t);e<r&&(r=e),e>a&&(a=e)}),this.value=[r,a]};var ue=e.inherits(it,p);ue.connect=function(t){return this.targets().add(t),t.source=this},ue.add=function(t){this.value.add.push(t)},ue.rem=function(t){this.value.rem.push(t)},ue.mod=function(t){this.value.mod.push(t)},ue.init=function(t){this.value.init(t,t.NO_SOURCE)},ue.evaluate=function(){return this.value};var oe=e.inherits(nt,M);oe.activate=function(t){this._targets[this._targets.active++]=t},oe.subflow=function(t,e,i,n){var r,a,s=this.value,u=s.hasOwnProperty(t)&&s[t];return u?u.value.stamp<i.stamp&&(u.init(i),this.activate(u)):(a=n||(a=this._group[t])&&a.tuple,u=(r=i.dataflow).add(new it(i.fork(i.NO_SOURCE),this)).connect(e(r,t,a)),s[t]=u,this.activate(u)),u},oe.transform=function(t,e){function i(t){return r.subflow(t,u,e)}var n=e.dataflow,r=this,a=t.key,u=t.subflow,o=this._keys,l=t.modified("key");return this._group=t.group||{},this._targets.active=0,e.visit(e.REM,function(t){var e=s(t),n=o.get(e);void 0!==n&&(o.delete(e),i(n).rem(t))}),e.visit(e.ADD,function(t){var e=a(t);o.set(s(t),e),i(e).add(t)}),l||e.modified(a.fields)?e.visit(e.MOD,function(t){var e=s(t),n=o.get(e),r=a(t);n===r?i(r).mod(t):(o.set(e,r),i(n).rem(t),i(r).add(t))}):e.changed(e.MOD)&&e.visit(e.MOD,function(t){i(o.get(s(t))).mod(t)}),l&&e.visit(e.REFLOW,function(t){var e=s(t),n=o.get(e),r=a(t);n!==r&&(o.set(e,r),i(n).rem(t),i(r).add(t))}),o.empty>n.cleanThreshold&&n.runAfter(o.clean),e},e.inherits(rt,p),e.inherits(st,M).transform=function(t,e){function i(e){var i=s(e),n=h(e,t),a=r.get(i);n&&a?(r.delete(i),u.push(e)):n||a?f&&n&&!a&&l.push(e):(r.set(i,1),o.push(e))}var n=e.dataflow,r=this.value,a=e.fork(),u=a.add,o=a.rem,l=a.mod,h=t.expr,f=!0;return e.visit(e.REM,function(t){var e=s(t);r.has(e)?r.delete(e):o.push(t)}),e.visit(e.ADD,function(e){h(e,t)?u.push(e):r.set(s(e),1)}),e.visit(e.MOD,i),t.modified()&&(f=!1,e.visit(e.REFLOW,i)),r.empty>n.cleanThreshold&&n.runAfter(r.clean),a},e.inherits(ut,M).transform=function(t,e){function i(t){for(var e,i=r[s(t)]=Array(m),n=0;n<m;++n)(e=i[n]=l(t))[f]=c[n],e[d]=u[n](t),v.add.push(e)}var n,r=this.value,a=t.modified("fields"),u=t.fields,o=t.as||["key","value"],f=o[0],d=o[1],c=u.map(ot),m=u.length,p=e.stamp,v=e.fork(e.NO_SOURCE),g=0,y=0;if(a){for(n in r)v.rem.push.apply(v.rem,r[n]);r=this.value={},e.visit(e.SOURCE,i)}else{for(e.visit(e.ADD,i);g<m;++g)e.modified(u[g].fields)&&(y|=1<<g);y&&e.visit(e.MOD,function(t){for(var e,i=r[s(t)],n=0;n<m;++n)y&1<<n&&((e=h(t,i[n],p))[f]=c[n],e[d]=u[n](t),v.mod.push(e))}),e.visit(e.REM,function(t){var e=s(t);v.rem.push.apply(v.rem,r[e]),r[e]=null})}return v.modifies(o)},e.inherits(lt,M).transform=function(t,e){var i=t.expr,n=t.as,r=t.modified(),a=t.initonly?e.ADD:r?e.SOURCE:e.modified(i.fields)?e.ADD_MOD:e.ADD;return r&&(e=e.materialize().reflow(!0)),t.initonly||e.modifies(n),e.visit(a,function(e){e[n]=i(e,t)})},e.inherits(ht,M).transform=function(t,e){var i,n,r,a=this.value,s=e.fork(e.ALL),u=t.size-a.length,l=t.generator;if(u>0){for(i=[];--u>=0;)i.push(r=o(l(t))),a.push(r);s.add=s.add.length?s.materialize(s.ADD).add.concat(i):i}else n=a.slice(0,-u),s.rem=s.rem.length?s.materialize(s.REM).rem.concat(n):n,a=a.slice(-u);return s.source=this.value=a,s};var le={value:"value",median:r.median,mean:r.mean,min:r.min,max:r.max},he=[];e.inherits(ft,M).transform=function(t,i){var n,r,a,s,u,l,h,f,d,c,m=i.fork(i.ALL),p=dt(t),v=ct(t),g=e.accessorName(t.field),y=e.accessorName(t.key),_=(t.groupby||[]).map(e.accessorName),x=mt(i.source,t.groupby,t.key,t.keyvals),k=[],D=this.value,w=x.domain.length;for(u=0,f=x.length;u<f;++u)for(a=(n=x[u]).values,r=NaN,h=0;h<w;++h)if(null==n[h]){for(s=x.domain[h],c={_impute:!0},l=0,d=a.length;l<d;++l)c[_[l]]=a[l];c[y]=s,c[g]=isNaN(r)?r=p(n,v):r,k.push(o(c))}return k.length&&(m.add=m.materialize(m.ADD).add.concat(k)),D.length&&(m.rem=m.materialize(m.REM).rem.concat(D)),this.value=k,m};var fe=e.inherits(pt,j);fe.transform=function(t,e){var i,n=this,r=t.modified();return n.value&&(r||e.modified(n._inputs))?(i=n.value=r?n.init(t):{},e.visit(e.SOURCE,function(t){n.add(t)})):(i=n.value=n.value||this.init(t),e.visit(e.REM,function(t){n.rem(t)}),e.visit(e.ADD,function(t){n.add(t)})),n.changes(),e.visit(e.SOURCE,function(t){h(i[n.cellkey(t)].tuple,t)}),e.reflow(r).modifies(this._outputs)},fe.changes=function(){var t,e,i=this._adds,n=this._mods;for(t=0,e=this._alen;t<e;++t)this.celltuple(i[t]),i[t]=null;for(t=0,e=this._mlen;t<e;++t)this.celltuple(n[t]),n[t]=null;this._alen=this._mlen=0},e.inherits(vt,p),e.inherits(yt,M).transform=function(t,i){var n,r,a=i,s=t.as,u=t.fields,o=t.index,l=t.values,h=null==t.default?null:t.default,f=t.modified(),d=f?i.SOURCE:i.ADD,c=u.length;return l?(r=l.length,c>1&&!s&&e.error('Multi-field lookup requires explicit "as" parameter.'),s&&s.length!==c*r&&e.error('The "as" parameter has too few output field names.'),s=s||l.map(e.accessorName),n=function(t){for(var e,i,n=0,a=0;n<c;++n)if(null==(i=o.get(u[n](t))))for(e=0;e<r;++e,++a)t[s[a]]=h;else for(e=0;e<r;++e,++a)t[s[a]]=l[e](i)}):(s||e.error("Missing output field names."),n=function(t){for(var e,i=0;i<c;++i)e=o.get(u[i](t)),t[s[i]]=null==e?h:e}),f?a=i.reflow(!0):d|=u.some(function(t){return i.modified(t.fields)})?i.MOD:0,i.visit(d,n),a.modifies(s)},e.inherits(_t,p),e.inherits(kt,p),e.inherits(wt,M),wt.prototype.transform=function(t,e){return this.modified(t.modified()),this.value=t,e.fork(e.NO_SOURCE|e.NO_FIELDS)},e.inherits(Ot,nt).transform=function(t,i){var n=this,r=t.subflow,a=t.field;return(t.modified("field")||a&&i.modified(e.accessorFields(a)))&&e.error("PreFacet does not support field modification."),this._targets.active=0,i.visit(i.MOD,function(t){var e=n.subflow(s(t),r,i,t);a?a(t).forEach(function(t){e.mod(t)}):e.mod(t)}),i.visit(i.ADD,function(t){var e=n.subflow(s(t),r,i,t);a?a(t).forEach(function(t){e.add(o(t))}):e.add(t)}),i.visit(i.REM,function(t){var e=n.subflow(s(t),r,i,t);a?a(t).forEach(function(t){e.rem(t)}):e.rem(t)}),i},e.inherits(qt,M).transform=function(t,e){return this.value=t.value,t.modified("value")?e.fork(e.NO_SOURCE|e.NO_FIELDS):e.StopPropagation},e.inherits(Et,M).transform=function(t,i){i.source||e.error("Rank transform requires an upstream data source.");var n,r=t.normalize,a=t.field,s=t.as||"rank",u={},o=-1;return a?(i.visit(i.SOURCE,function(t){var e=a(t);null==u[e]&&(u[e]=++o)}),i.visit(i.SOURCE,r&&--o?function(t){t[s]=u[a(t)]/o}:function(t){t[s]=u[a(t)]})):(o+=i.source.length,n=-1,i.visit(i.SOURCE,r&&o?function(t){t[s]=++n/o}:function(t){t[s]=++n})),i.reflow(t.modified()).modifies(s)},e.inherits(bt,M).transform=function(t,e){var i,n;return this.value?n=this.value:(i=e=e.addAll(),n=this.value={}),t.derive&&(i=e.fork(),e.visit(e.REM,function(t){var e=s(t);i.rem.push(n[e]),n[e]=null}),e.visit(e.ADD,function(t){var e=l(t);n[s(t)]=e,i.add.push(e)}),e.visit(e.MOD,function(t){i.mod.push(h(t,n[s(t)]))})),i},e.inherits(At,M).transform=function(t,e){function i(t){var e,i;u.length<a?u.push(t):(i=~~(o*Math.random()))<u.length&&i>=l&&(e=u[i],h[s(e)]&&n.rem.push(e),u[i]=t),++o}var n=e.fork(),r=t.modified("size"),a=t.size,u=this.value,o=this.count,l=0,h=u.reduce(function(t,e){return t[s(e)]=1,t},{});if(e.rem.length&&(e.visit(e.REM,function(t){var e=s(t);h[e]&&(h[e]=-1,n.rem.push(t)),--o}),u=u.filter(function(t){return-1!==h[s(t)]})),(e.rem.length||r)&&u.length<a&&e.source&&(l=o=u.length,e.visit(e.SOURCE,function(t){h[s(t)]||i(t)}),l=-1),r&&u.length>a){for(var f=0,d=u.length-a;f<d;++f)h[s(u[f])]=-1,n.rem.push(u[f]);u=u.slice(d)}return e.mod.length&&e.visit(e.MOD,function(t){h[s(t)]&&n.mod.push(t)}),e.add.length&&e.visit(e.ADD,i),(e.add.length||l<0)&&(n.add=u.filter(function(t){return!h[s(t)]})),this.count=o,this.value=n.source=u,n},e.inherits(Ft,M).transform=function(t,e){if(!this.value||t.modified()){var i=e.materialize().fork(e.MOD);return i.rem=this.value?e.rem.concat(this.value):e.rem,i.source=this.value=r.range(t.start,t.stop,t.step||1).map(o),i.add=e.add.concat(this.value),i}},e.inherits(Rt,M).transform=function(t,e){return this.value=e.source,e.changed()?e.fork(e.NO_SOURCE|e.NO_FIELDS):e.StopPropagation},e.inherits(Mt,M).transform=function(t,e){function i(t){a.set(r(t),t)}var n=e.dataflow,r=t.field,a=this.value,s=!0;return t.modified("field")||e.modified(r.fields)?(a.clear(),e.visit(e.SOURCE,i)):e.changed()?(e.visit(e.REM,function(t){a.delete(r(t))}),e.visit(e.ADD,i)):s=!1,this.modified(s),a.empty>n.cleanThreshold&&n.runAfter(a.clean),e.fork()},e.inherits(St,M).transform=function(t,e){(!this.value||t.modified("field")||t.modified("sort")||e.changed()||t.sort&&e.modified(t.sort.fields))&&(this.value=(t.sort?e.source.slice().sort(t.sort):e.source).map(t.field))};var de={type:"Aggregate",metadata:{generates:!0,changes:!0},params:[{name:"groupby",type:"field",array:!0},{name:"fields",type:"field",array:!0},{name:"ops",type:"enum",array:!0,values:["count","valid","missing","distinct","sum","mean","average","variance","variancep","stdev","stdevp","stderr","median","q1","q3","ci0","ci1","min","max","argmin","argmax"]},{name:"as",type:"string",array:!0},{name:"drop",type:"boolean",default:!0},{name:"cross",type:"boolean",default:!1},{name:"key",type:"field"}]},ce={type:"Bin",metadata:{modifies:!0},params:[{name:"field",type:"field",required:!0},{name:"anchor",type:"number"},{name:"maxbins",type:"number",default:20},{name:"base",type:"number",default:10},{name:"divide",type:"number",array:!0,default:[5,2]},{name:"extent",type:"number",array:!0,length:2,required:!0},{name:"step",type:"number"},{name:"steps",type:"number",array:!0},{name:"minstep",type:"number",default:0},{name:"nice",type:"boolean",default:!0},{name:"name",type:"string"},{name:"as",type:"string",array:!0,length:2,default:["bin0","bin1"]}]},me={type:"Collect",metadata:{source:!0},params:[{name:"sort",type:"compare"}]},pe={type:"CountPattern",metadata:{generates:!0,changes:!0},params:[{name:"field",type:"field",required:!0},{name:"case",type:"enum",values:["upper","lower","mixed"],default:"mixed"},{name:"pattern",type:"string",default:'[\\w"]+'},{name:"stopwords",type:"string",default:""},{name:"as",type:"string",array:!0,length:2,default:["text","count"]}]},ve={type:"Cross",metadata:{source:!0,generates:!0,changes:!0},params:[{name:"filter",type:"expr"},{name:"as",type:"string",array:!0,length:2,default:["a","b"]}]},ge=[{key:{function:"normal"},params:[{name:"mean",type:"number",default:0},{name:"stdev",type:"number",default:1}]},{key:{function:"uniform"},params:[{name:"min",type:"number",default:0},{name:"max",type:"number",default:1}]},{key:{function:"kde"},params:[{name:"field",type:"field",required:!0},{name:"from",type:"data"},{name:"bandwidth",type:"number",default:0}]}],ye={key:{function:"mixture"},params:[{name:"distributions",type:"param",array:!0,params:ge},{name:"weights",type:"number",array:!0}]},_e={type:"Density",metadata:{generates:!0,source:!0},params:[{name:"extent",type:"number",array:!0,length:2},{name:"steps",type:"number",default:100},{name:"method",type:"string",default:"pdf",values:["pdf","cdf"]},{name:"distribution",type:"param",params:ge.concat(ye)},{name:"as",type:"string",array:!0,default:["value","density"]}]},xe={type:"Extent",metadata:{},params:[{name:"field",type:"field",required:!0}]},ke={type:"Filter",metadata:{changes:!0},params:[{name:"expr",type:"expr",required:!0}]},De={type:"Fold",metadata:{generates:!0,changes:!0},params:[{name:"fields",type:"field",array:!0,required:!0},{name:"as",type:"string",array:!0,length:2,default:["key","value"]}]},we={type:"Formula",metadata:{modifies:!0},params:[{name:"expr",type:"expr",required:!0},{name:"as",type:"string",required:!0},{name:"initonly",type:"boolean"}]},Oe={type:"Impute",metadata:{changes:!0},params:[{name:"field",type:"field",required:!0},{name:"key",type:"field",required:!0},{name:"keyvals",array:!0},{name:"groupby",type:"field",array:!0},{name:"method",type:"enum",default:"value",values:["value","mean","median","max","min"]},{name:"value",default:0}]},qe={type:"JoinAggregate",metadata:{modifies:!0},params:[{name:"groupby",type:"field",array:!0},{name:"fields",type:"field",array:!0},{name:"ops",type:"enum",array:!0,values:["count","valid","missing","distinct","sum","mean","average","variance","variancep","stdev","stdevp","stderr","median","q1","q3","ci0","ci1","min","max","argmin","argmax"]},{name:"as",type:"string",array:!0},{name:"key",type:"field"}]},Ee={type:"Lookup",metadata:{modifies:!0},params:[{name:"index",type:"index",params:[{name:"from",type:"data",required:!0},{name:"key",type:"field",required:!0}]},{name:"values",type:"field",array:!0},{name:"fields",type:"field",array:!0,required:!0},{name:"as",type:"string",array:!0},{name:"default",default:null}]},be={type:"Rank",metadata:{modifies:!0},params:[{name:"field",type:"field"},{name:"normalize",type:"boolean",default:!1},{name:"as",type:"string",default:"rank"}]},Ae={type:"Sample",metadata:{source:!0,changes:!0},params:[{name:"size",type:"number",default:1e3}]},Fe={type:"Sequence",metadata:{generates:!0,source:!0},params:[{name:"start",type:"number",required:!0},{name:"stop",type:"number",required:!0},{name:"step",type:"number",default:1}],output:["value"]};S(de,j),S(ce,K),S(me,V),S(pe,$),S(ve,Q),S(_e,Z),S(xe,et),S(ke,st),S(De,ut),S(we,lt),S(Oe,ft),S(qe,pt),S(Ee,yt),S(be,Et),S(Ae,At),S(Fe,Ft),C("Compare",B),C("Facet",nt),C("Field",rt),C("Generate",ht),C("Key",vt),C("MultiExtent",_t),C("MultiValues",kt),C("Params",wt),C("PreFacet",Ot),C("Proxy",qt),C("Relay",bt),C("Sieve",Rt),C("Subflow",it),C("TupleIndex",Mt),C("Values",St),t.UniqueList=a,t.changeset=c,t.isChangeSet=d,t.Dataflow=F,t.EventStream=g,t.Parameters=m,t.Pulse=k,t.MultiPulse=q,t.Operator=p,t.Transform=M,t.ingest=o,t.isTuple=function(t){return!(!t||!s(t))},t.replace=f,t.tupleid=s,t.definition=N,t.definitions=Xt,t.register=S,t.transform=C,t.transforms=Qt,Object.defineProperty(t,"__esModule",{value:!0})});

2

package.json
{
"name": "vega-dataflow",
"version": "2.1.0",
"version": "2.1.1",
"description": "Reactive dataflow processing.",

@@ -5,0 +5,0 @@ "keywords": [

8

src/dataflow/run.js

@@ -128,5 +128,9 @@ import {default as Pulse, StopPropagation} from '../Pulse';

* sole argument.
* @param {boolean} enqueue - A boolean flag indicating that the
* callback should be queued up to run after the next propagation
* cycle, suppressing immediate invovation when propagation is not
* currently occurring.
*/
export function runAfter(callback) {
if (this._pulse) {
export function runAfter(callback, enqueue) {
if (this._pulse || enqueue) {
// pulse propagation is currently running, queue to run after

@@ -133,0 +137,0 @@ this._postrun.push(callback);

build/vega-dataflow.js

Sorry, the diff of this file is too big to display

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc