Arrow IPC: original codes, decoded quantities and a checked reading
HTML for this example
Select the code and use your copy shortcut. Changes in this preview are temporary.
<!doctype html><html lang="en"><meta charset="utf-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>Dispatch data: inspect the decoded Arrow file</title><style>*{box-sizing:border-box}body{margin:0;padding:20px;font:16px/1.6 system-ui;color:#243346;max-width:960px}h1{font-size:26px;line-height:1.2}button{font:inherit;padding:8px;margin:5px}pre{white-space:pre-wrap;overflow-wrap:anywhere;background:#f1f4f8;padding:14px}.charts{display:flex;flex-wrap:wrap;gap:16px}.chart{width:300px;max-width:100%}.dc-chart .row rect{fill:#315c85;cursor:pointer}.dc-chart .row text{fill:white}.dc-chart .selected rect{fill:#bd6200}.dc-chart .deselected rect{fill:#b7c0ca}svg{max-width:100%}</style><h1>Dispatch data: inspect the decoded Arrow file</h1><p>Fictional exercise. No operational record is submitted or saved.</p><p>Two codes must retain their leading zeros after serialization.</p><button id="change">Use revised quantity</button><button id="restore">Restore original</button><pre id="reading" role="status"></pre><script>// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
(function (global, factory) {
typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports) :
typeof define === 'function' && define.amd ? define(['exports'], factory) :
(factory(global.Arrow = global.Arrow || {}));
}(this, (function (exports) {var h;function aa(a){var b=0;return function(){return b<a.length?{done:!1,value:a[b++]}:{done:!0}}}var ba=typeof Object.defineProperties=="function"?Object.defineProperty:function(a,b,c){if(a==Array.prototype||a==Object.prototype)return a;a[b]=c.value;return a};
function ca(a){a=["object"==typeof globalThis&&globalThis,a,"object"==typeof window&&window,"object"==typeof self&&self,"object"==typeof global&&global];for(var b=0;b<a.length;++b){var c=a[b];if(c&&c.Math==Math)return c}throw Error("Cannot find global object");}var da=ca(this);function ea(a,b){if(b)a:{var c=da;a=a.split(".");for(var d=0;d<a.length-1;d++){var e=a[d];if(!(e in c))break a;c=c[e]}a=a[a.length-1];d=c[a];b=b(d);b!=d&&b!=null&&ba(c,a,{configurable:!0,writable:!0,value:b})}}
ea("Symbol",function(a){function b(f){if(this instanceof b)throw new TypeError("Symbol is not a constructor");return new c(d+(f||"")+"_"+e++,f)}function c(f,g){this.Sb=f;ba(this,"description",{configurable:!0,writable:!0,value:g})}if(a)return a;c.prototype.toString=function(){return this.Sb};var d="jscomp_symbol_"+(Math.random()*1E9>>>0)+"_",e=0;return b});
ea("Symbol.iterator",function(a){if(a)return a;a=Symbol("Symbol.iterator");for(var b="Array Int8Array Uint8Array Uint8ClampedArray Int16Array Uint16Array Int32Array Uint32Array Float32Array Float64Array".split(" "),c=0;c<b.length;c++){var d=da[b[c]];typeof d==="function"&&typeof d.prototype[a]!="function"&&ba(d.prototype,a,{configurable:!0,writable:!0,value:function(){return fa(aa(this))}})}return a});ea("Symbol.asyncIterator",function(a){return a?a:Symbol("Symbol.asyncIterator")});
ea("Symbol.toStringTag",function(a){return a?a:Symbol("Symbol.toStringTag")});function fa(a){a={next:a};a[Symbol.iterator]=function(){return this};return a}function ha(a){function b(d){return a.next(d)}function c(d){return a.throw(d)}return new Promise(function(d,e){function f(g){g.done?d(g.value):Promise.resolve(g.value).then(b,c).then(f,e)}f(a.next())})}function l(a){return ha(a())}
function ia(a){var b=a[Symbol.asyncIterator];if(b!==void 0)a=b.call(a);else{b=ja;var c=typeof Symbol!="undefined"&&Symbol.iterator&&a[Symbol.iterator];if(c)a=c.call(a);else if(typeof a.length=="number")a={next:aa(a)};else throw Error(String(a)+" is not an iterable or ArrayLike");a=new b(a)}return a}
function ja(a){this[Symbol.asyncIterator]=function(){return this};this[Symbol.iterator]=function(){return a};this.next=function(b){return Promise.resolve(a.next(b))};this["throw"]=function(b){return new Promise(function(c,d){var e=a["throw"];e!==void 0?c(e.call(a,b)):(c=a["return"],c!==void 0&&c.call(a),d(new TypeError("no `throw` method")))})};a["return"]!==void 0&&(this["return"]=function(b){return Promise.resolve(a["return"](b))})}function n(a,b){this.action=a;this.value=b}
function ka(a,b,c,d){this.method=a;this.ga=b;this.resolve=c;this.reject=d}function la(a){this.frame=a;this.next=null}function ma(){this.Qa=this.W=null}ma.prototype.first=function(){if(this.W)return this.W.frame;throw Error("no frames in executionQueue");};function na(a){a.W&&(a.W=a.W.next,a.W||(a.Qa=null))}ma.prototype.enqueue=function(a){a=new la(a);this.Qa?this.Qa.next=a:this.W=a;this.Qa=a};
function oa(a){this.Lb=a;this.T=null;this.M=new ma;this[Symbol.asyncIterator]=function(){return this};var b=this;this.kc=function(c){var d=b.M.first();c.done===!0?(b.T=null,d.method="next",d.ga=c.value):(d.resolve({value:c.value,done:!1}),na(b.M));pa(b)};this.jc=function(c){qa(b,c)};this.hb=function(c){ra(b,c)}}function sa(a,b,c){return new Promise(function(d,e){var f=a.M.W===null;a.M.enqueue(new ka(b,c,d,e));f&&pa(a)})}oa.prototype.next=function(a){return sa(this,"next",a)};
oa.prototype.return=function(a){return sa(this,"return",new n(0,a))};oa.prototype.throw=function(a){return sa(this,"throw",a)};function pa(a){if(a.M.W!==null)try{if(a.T){if(!a.T)throw Error("no delegate to perform execution");var b=a.M.first();if(b.method in a.T)try{a.T[b.method](b.ga).then(a.kc,a.jc).catch(a.hb)}catch(c){qa(a,c)}else a.T=null,pa(a)}else ua(a)}catch(c){ra(a,c)}}
function ua(a){var b=a.M.first();try{var c=a.Lb[b.method](b.ga);if(c.value instanceof n)switch(c.value.action){case 0:Promise.resolve(c.value.value).then(function(d){b.resolve({value:d,done:c.done});na(a.M);pa(a)},function(d){b.reject(d);na(a.M);pa(a)}).catch(a.hb);break;case 1:a.T=ia(c.value.value);b.method="next";b.ga=void 0;pa(a);break;case 2:Promise.resolve(c.value.value).then(function(d){b.method="next";b.ga=d;pa(a)},function(d){b.method="throw";b.ga=d;pa(a)}).catch(a.hb);break;default:throw Error("Unrecognized AsyncGeneratorWrapper$ActionEnum");
}else b.resolve(c),na(a.M),pa(a)}catch(d){b.reject(d),na(a.M),pa(a)}}function qa(a,b){var c=a.M.first();a.T=null;c.method="throw";c.ga=b;pa(a)}function ra(a,b){a.M.W!==null&&(a.M.first().reject(b),na(a.M));a.T&&"return"in a.T&&(a.T["return"](void 0),a.T=null);a.Lb["return"](void 0);pa(a)}const va=new TextDecoder("utf-8"),wa=va.decode.bind(va),xa=new TextEncoder;const q=a=>typeof a==="function",t=a=>a!=null&&Object(a)===a,ya=a=>"_getDOMStream"in a&&"_getNodeStream"in a,za=a=>t(a)&&q(a.cancel)&&q(a.getReader)&&!ya(a),Aa=a=>t(a)&&q(a.read)&&q(a.pipe)&&typeof a.readable==="boolean"&&!ya(a);const Ba=typeof SharedArrayBuffer!=="undefined"?SharedArrayBuffer:ArrayBuffer;function Ca(a){const b=a[0]?[a[0]]:[];let c,d,e,f;for(let g,k,m=0,p=0,r=a.length;++m<r;)g=b[p],k=a[m],!g||!k||g.buffer!==k.buffer||k.byteOffset<g.byteOffset?k&&(b[++p]=k):({byteOffset:c,byteLength:e}=g,{byteOffset:d,byteLength:f}=k,c+e<d||d+f<c?k&&(b[++p]=k):b[p]=new Uint8Array(g.buffer,c,d-c+f));return b}
function Da(a,b,c=0,d=b.byteLength){const e=a.byteLength,f=new Uint8Array(a.buffer,a.byteOffset,e);b=new Uint8Array(b.buffer,b.byteOffset,Math.min(d,e));f.set(b,c);return a}
function Ea(a,b){a=Ca(a);const c=a.reduce((m,p)=>m+p.byteLength,0);let d,e,f=0,g=-1;const k=Math.min(b||Number.POSITIVE_INFINITY,c);for(const m=a.length;++g<m;){b=a[g];d=b.subarray(0,Math.min(b.length,k-f));if(k<=f+d.length){d.length<b.length?a[g]=b.subarray(d.length):d.length===b.length&&g++;e?Da(e,d,f):e=d;break}Da(e||(e=new Uint8Array(k)),d,f);f+=d.length}return[e||new Uint8Array(0),a.slice(g),c-(e?e.byteLength:0)]}
function u(a,b){b=t(b)&&"done"in b&&"value"in b?b.value:b;if(b instanceof a)return a===Uint8Array?new a(b.buffer,b.byteOffset,b.byteLength):b;if(!b)return new a(0);typeof b==="string"&&(b=xa.encode(b));return b instanceof ArrayBuffer||b instanceof Ba?new a(b):t(b)&&q(b.clear)&&q(b.bytes)&&q(b.position)&&q(b.setPosition)&&q(b.capacity)&&q(b.getBufferIdentifier)&&q(b.createLong)?u(a,b.bytes()):ArrayBuffer.isView(b)?b.byteLength<=0?new a(0):new a(b.buffer,b.byteOffset,b.byteLength/a.BYTES_PER_ELEMENT):
a.from(b)}const Fa=a=>u(Uint8Array,a),Ga=a=>{a.next();return a};function*Ha(a,b){function*c(d){yield d}b=typeof b==="string"?c(b):ArrayBuffer.isView(b)?c(b):b instanceof ArrayBuffer?c(b):b instanceof Ba?c(b):t(b)&&q(b[Symbol.iterator])?b:c(b);yield*Ga(function*(d){let e=null;do e=d.next(yield u(a,e));while(!e.done)}(b[Symbol.iterator]()));return new a}
function Ia(a,b){return new oa(function*(){function c(f){return new oa(function*(){yield new n(1,Ga(function*(g){let k=null;do{let m;k=g.next(yield(m=k)==null?void 0:m.value)}while(!k.done)}(f[Symbol.iterator]())))}())}function d(f){return new oa(function*(){yield new n(0,yield new n(2,f))}())}if(t(b)&&q(b.then))return new n(0,yield new n(1,Ia(a,yield new n(2,b))));const e=typeof b==="string"?d(b):ArrayBuffer.isView(b)?d(b):b instanceof ArrayBuffer?d(b):b instanceof Ba?d(b):t(b)&&q(b[Symbol.iterator])?
c(b):t(b)&&q(b[Symbol.asyncIterator])?b:d(b);yield new n(1,Ga(function(f){return new oa(function*(){let g=null;do g=yield new n(2,f.next(yield new n(0,u(a,g))));while(!g.done)}())}(e[Symbol.asyncIterator]())));return new n(0,new a)}())}function Ja(a,b,c){if(a!==0){c=c.slice(0,b);for(let d=-1,e=c.length;++d<e;)c[d]+=a}return c.subarray(0,b)}function Ka(a,b){let c=0;const d=a.length;if(d!==b.length)return!1;if(d>0){do if(a[c]!==b[c])return!1;while(++c<d)}return!0}var v={};v.compareArrayLike=Ka;
v.joinUint8Arrays=Ea;v.memcpy=Da;v.rebaseValueOffsets=Ja;v.toArrayBufferView=u;v.toArrayBufferViewAsyncIterator=Ia;v.toArrayBufferViewIterator=Ha;v.toBigInt64Array=a=>u(BigInt64Array,a);v.toBigUint64Array=a=>u(BigUint64Array,a);v.toFloat32Array=a=>u(Float32Array,a);v.toFloat32ArrayAsyncIterator=a=>Ia(Float32Array,a);v.toFloat32ArrayIterator=a=>Ha(Float32Array,a);v.toFloat64Array=a=>u(Float64Array,a);v.toFloat64ArrayAsyncIterator=a=>Ia(Float64Array,a);v.toFloat64ArrayIterator=a=>Ha(Float64Array,a);
v.toInt16Array=a=>u(Int16Array,a);v.toInt16ArrayAsyncIterator=a=>Ia(Int16Array,a);v.toInt16ArrayIterator=a=>Ha(Int16Array,a);v.toInt32Array=a=>u(Int32Array,a);v.toInt32ArrayAsyncIterator=a=>Ia(Int32Array,a);v.toInt32ArrayIterator=a=>Ha(Int32Array,a);v.toInt8Array=a=>u(Int8Array,a);v.toInt8ArrayAsyncIterator=a=>Ia(Int8Array,a);v.toInt8ArrayIterator=a=>Ha(Int8Array,a);v.toUint16Array=a=>u(Uint16Array,a);v.toUint16ArrayAsyncIterator=a=>Ia(Uint16Array,a);v.toUint16ArrayIterator=a=>Ha(Uint16Array,a);
v.toUint32Array=a=>u(Uint32Array,a);v.toUint32ArrayAsyncIterator=a=>Ia(Uint32Array,a);v.toUint32ArrayIterator=a=>Ha(Uint32Array,a);v.toUint8Array=Fa;v.toUint8ArrayAsyncIterator=a=>Ia(Uint8Array,a);v.toUint8ArrayIterator=a=>Ha(Uint8Array,a);v.toUint8ClampedArray=a=>u(Uint8ClampedArray,a);v.toUint8ClampedArrayAsyncIterator=a=>Ia(Uint8ClampedArray,a);v.toUint8ClampedArrayIterator=a=>Ha(Uint8ClampedArray,a);function Ma(){throw Error('"toDOMStream" not available in this environment');}function Na(){throw Error('"toNodeStream" not available in this environment');}const Oa=a=>{a.next();return a};
function*Pa(a){let b,c=!1,d=[],e,f,g,k=0;({O:f,size:g}=(yield null)||{O:"read",size:0});a=Ha(Uint8Array,a)[Symbol.iterator]();try{do if({done:b,value:e}=Number.isNaN(g-k)?a.next():a.next(g-k),!b&&e.byteLength>0&&(d.push(e),k+=e.byteLength),b||g<=k){do{if(f==="peek")var m=Ea(d,g)[0];else[e,d,k]=Ea(d,g),m=e;({O:f,size:g}=yield m)}while(g<k)}while(!b)}catch(p){c=!0,typeof a.throw==="function"&&a.throw(p)}finally{c===!1&&typeof a.return==="function"&&a.return(null)}return null}
function Qa(a){return new oa(function*(){let b,c=!1,d=[],e,f,g,k=0;({O:f,size:g}=(yield new n(0,null))||{O:"read",size:0});const m=Ia(Uint8Array,a)[Symbol.asyncIterator]();try{do if({done:b,value:e}=Number.isNaN(g-k)?yield new n(2,m.next()):yield new n(2,m.next(g-k)),!b&&e.byteLength>0&&(d.push(e),k+=e.byteLength),b||g<=k){do{if(f==="peek")var p=Ea(d,g)[0];else[e,d,k]=Ea(d,g),p=e;({O:f,size:g}=yield new n(0,p))}while(g<k)}while(!b)}catch(r){c=!0,typeof m.throw==="function"&&(yield new n(2,m.throw(r)))}finally{c===
!1&&typeof m.return==="function"&&(yield new n(2,m.return(new Uint8Array(0))))}return new n(0,null)}())}
function Ra(a){return new oa(function*(){let b=!1,c=!1,d=[],e,f,g,k=0;({O:f,size:g}=(yield new n(0,null))||{O:"read",size:0});const m=new Sa(a);try{do if({done:b,value:e}=Number.isNaN(g-k)?yield new n(2,m.read()):yield new n(2,m.read(g-k)),!b&&e.byteLength>0&&(d.push(u(Uint8Array,e)),k+=e.byteLength),b||g<=k){do{if(f==="peek")var p=Ea(d,g)[0];else[e,d,k]=Ea(d,g),p=e;({O:f,size:g}=yield new n(0,p))}while(g<k)}while(!b)}catch(r){c=!0,yield new n(2,m.cancel(r))}finally{c===!1?yield new n(2,m.cancel()):
a.locked&&m.releaseLock()}return new n(0,null)}())}
class Sa{constructor(a){this.source=a;this.X=null;this.X=this.source.getReader();this.X.closed.catch(()=>{})}get closed(){return this.X?this.X.closed.catch(()=>{}):Promise.resolve()}releaseLock(){this.X&&this.X.releaseLock();this.X=null}cancel(a){const b=this;return l(function*(){const c=b.X,d=b.source;c&&(yield c.cancel(a).catch(()=>{}));d&&d.locked&&b.releaseLock()})}read(a){const b=this;return l(function*(){if(a===0)return{done:b.X==null,value:new Uint8Array(0)};const c=yield b.X.read();!c.done&&
(c.value=u(Uint8Array,c));return c})}}const Ta=(a,b)=>{const c=e=>d([b,e]);let d;return[b,c,new Promise(e=>(d=e)&&a.once(b,c))]};
function Ua(a){return new oa(function*(){function b(ta,La){r=p=null;return new Promise((Pc,yj)=>{for(const [Gb,zj]of ta)a.off(Gb,zj);try{const Gb=a.destroy;Gb&&Gb.call(a,La);La=void 0}catch(Gb){La=Gb||La}finally{La!=null?yj(La):Pc()}})}const c=[];let d="error",e=!1,f=null,g,k,m=0,p=[],r;({O:g,size:k}=(yield new n(0,null))||{O:"read",size:0});if(a.isTTY)return yield new n(0,new Uint8Array(0)),new n(0,null);try{c[0]=Ta(a,"end");c[1]=Ta(a,"error");do{c[2]=Ta(a,"readable");[d,f]=yield new n(2,Promise.race(c.map(ta=>
ta[2])));if(d==="error")break;(e=d==="end")||(Number.isFinite(k-m)?(r=Fa(a.read(k-m)),r.byteLength<k-m&&(r=Fa(a.read()))):r=Fa(a.read()),r.byteLength>0&&(p.push(r),m+=r.byteLength));if(e||k<=m){do{if(g==="peek")var T=Ea(p,k)[0];else[r,p,m]=Ea(p,k),T=r;({O:g,size:k}=yield new n(0,T))}while(k<m)}}while(!e)}finally{yield new n(2,b(c,d==="error"?f:null))}return new n(0,null)}())};var w,Va=w||(w={});Va[Va.V1=0]="V1";Va[Va.V2=1]="V2";Va[Va.V3=2]="V3";Va[Va.V4=3]="V4";Va[Va.V5=4]="V5";var x,Wa=x||(x={});Wa[Wa.Sparse=0]="Sparse";Wa[Wa.Dense=1]="Dense";var y,Xa=y||(y={});Xa[Xa.HALF=0]="HALF";Xa[Xa.SINGLE=1]="SINGLE";Xa[Xa.DOUBLE=2]="DOUBLE";var Ya,Za=Ya||(Ya={});Za[Za.DAY=0]="DAY";Za[Za.MILLISECOND=1]="MILLISECOND";var z,$a=z||(z={});$a[$a.SECOND=0]="SECOND";$a[$a.MILLISECOND=1]="MILLISECOND";$a[$a.MICROSECOND=2]="MICROSECOND";$a[$a.NANOSECOND=3]="NANOSECOND";var A,ab=A||(A={});ab[ab.YEAR_MONTH=0]="YEAR_MONTH";ab[ab.DAY_TIME=1]="DAY_TIME";ab[ab.MONTH_DAY_NANO=2]="MONTH_DAY_NANO";const bb=new Int32Array(2);new Float32Array(bb.buffer);new Float64Array(bb.buffer);new Uint16Array((new Uint8Array([1,0])).buffer);var cb,db=cb||(cb={});db[db.UTF8_BYTES=1]="UTF8_BYTES";db[db.UTF16_STRING=2]="UTF16_STRING";function eb(a,b){return(a.l[b]|a.l[b+1]<<8)<<16>>16}function fb(a,b){return BigInt.asIntN(64,BigInt(a.v(b)>>>0)+(BigInt(a.v(b+4)>>>0)<<BigInt(32)))}function B(a,b,c){b-=a.v(b);return c<eb(a,b)?eb(a,b+c):0}function gb(a,b,c){b.h=c+a.v(c);b.g=a;return b}function hb(a,b,c){b+=a.v(b);const d=a.v(b);b+=4;b=a.l.subarray(b,b+d);return c===cb.UTF8_BYTES?b:a.oc.decode(b)}function ib(a,b){return b+a.v(b)}function jb(a,b){return b+a.v(b)+4}function kb(a,b){return a.v(b+a.v(b))}
class lb{constructor(a){this.l=a;this.mb=0;this.oc=new TextDecoder}clear(){this.mb=0}bytes(){return this.l}position(){return this.mb}setPosition(a){this.mb=a}v(a){return this.l[a]|this.l[a+1]<<8|this.l[a+2]<<16|this.l[a+3]<<24}la(a,b){this.l[a]=b}rb(a,b){this.l[a]=b;this.l[a+1]=b>>8}Z(a,b){this.l[a]=b;this.l[a+1]=b>>8;this.l[a+2]=b>>16;this.l[a+3]=b>>24}$(a,b){this.Z(a,Number(BigInt.asIntN(32,b)));this.Z(a+4,Number(BigInt.asIntN(32,b>>BigInt(32))))}};function mb(a){return a.g.bytes().subarray(a.g.position(),a.g.position()+a.offset())}function nb(a,b,c){b>a.ya&&(a.ya=b);const d=~(a.g.l.length-a.C+c)+1&b-1;for(;a.C<d+b+c;){const g=a.g.l.length;var e=a,f=a.g;const k=f.l.length;if(k&3221225472)throw Error("FlatBuffers: cannot grow buffer beyond 2 gigabytes.");const m=k<<1,p=new lb(new Uint8Array(m));p.setPosition(m-k);p.bytes().set(f.bytes(),m-k);e.g=p;a.C+=a.g.l.length-g}a.pad(d)}function ob(a,b){nb(a,2,0);a.rb(b)}
function pb(a,b){nb(a,4,0);a.Z(b)}function qb(a,b,c,d){if(a.ha||c!=d)nb(a,1,0),a.la(c),a.slot(b)}function rb(a,b,c){if(a.ha||b!=c)ob(a,b),a.slot(0)}function sb(a,b,c,d){if(a.ha||c!=d)pb(a,c),a.slot(b)}function tb(a,b,c){var d=BigInt("0");if(a.ha||c!==d)nb(a,8,0),a.$(c),a.slot(b)}function ub(a,b){nb(a,4,0);a.Z(a.offset()-b+4)}function C(a,b,c){if(a.ha||c!=0)ub(a,c),a.slot(b)}function vb(a){if(a.wa)throw new TypeError("FlatBuffers: object serialization must not be nested.");}
function D(a,b){vb(a);a.Y==null&&(a.Y=[]);a.qb=b;for(let c=0;c<b;c++)a.Y[c]=0;a.wa=!0;a.lb=a.offset()}
function E(a){if(a.Y==null||!a.wa)throw Error("FlatBuffers: endObject called without startObject");pb(a,0);const b=a.offset();let c=a.qb-1;for(;c>=0&&a.Y[c]==0;c--);for(var d=c+1;c>=0;c--)ob(a,a.Y[c]!=0?b-a.Y[c]:0);ob(a,b-a.lb);d=(d+2)*2;ob(a,d);let e=0;const f=a.C;c=0;a:for(;c<a.za.length;c++){const g=a.g.l.length-a.za[c];if(d==eb(a.g,g)){for(let k=2;k<d;k+=2)if(eb(a.g,f+k)!=eb(a.g,g+k))continue a;e=a.za[c];break}}e?(a.C=a.g.l.length-b,a.g.Z(a.C,e-b)):(a.za.push(a.offset()),a.g.Z(a.g.l.length-b,
a.offset()-b));a.wa=!1;return b}function wb(a,b,c,d){vb(a);a.pb=c;nb(a,4,b*c);nb(a,d,b*c)}function xb(a){a.Z(a.pb);return a.offset()}function yb(a,b){if(b===null||b===void 0)return 0;b=b instanceof Uint8Array?b:a.qc.encode(b);nb(a,1,0);a.la(0);wb(a,1,b.length,1);a.g.setPosition(a.C-=b.length);a.g.bytes().set(b,a.C);return xb(a)}
class zb{constructor(){this.ya=1;this.Y=null;this.qb=0;this.wa=!1;this.lb=0;this.za=[];this.pb=0;this.ha=!1;this.qc=new TextEncoder;this.g=new lb(new Uint8Array(1024));this.C=1024}clear(){this.g.clear();this.C=this.g.l.length;this.ya=1;this.Y=null;this.qb=0;this.wa=!1;this.lb=0;this.za=[];this.pb=0;this.ha=!1}pad(a){for(let b=0;b<a;b++)this.g.la(--this.C,0)}la(a){this.g.la(--this.C,a)}rb(a){this.g.rb(this.C-=2,a)}Z(a){this.g.Z(this.C-=4,a)}$(a){this.g.$(this.C-=8,a)}slot(a){this.Y!==null&&(this.Y[a]=
this.offset())}offset(){return this.g.l.length-this.C}finish(a,b,c){c=c?4:0;if(b){nb(this,this.ya,8+c);if(b.length!=4)throw new TypeError("FlatBuffers: file identifier must be length 4");for(let d=3;d>=0;d--)this.la(b.charCodeAt(d))}nb(this,this.ya,4+c);ub(this,a);c&&pb(this,this.g.l.length-this.C);this.g.setPosition(this.C)}};var Ab,Bb=Ab||(Ab={});Bb[Bb.BUFFER=0]="BUFFER";var Cb,Db=Cb||(Cb={});Db[Db.LZ4_FRAME=0]="LZ4_FRAME";Db[Db.ZSTD=1]="ZSTD";class Eb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}codec(){const a=B(this.g,this.h,4);return a?this.g.l[this.h+a]<<24>>24:Cb.LZ4_FRAME}method(){const a=B(this.g,this.h,6);return a?this.g.l[this.h+a]<<24>>24:Ab.sb}};class Fb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}offset(){return fb(this.g,this.h)}length(){return fb(this.g,this.h+8)}};class Hb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}length(){return fb(this.g,this.h)}nullCount(){return fb(this.g,this.h+8)}};function Ib(a){const b=B(a.g,a.h,6);return b?kb(a.g,a.h+b):0}function Jb(a){const b=B(a.g,a.h,8);return b?kb(a.g,a.h+b):0}
class Kb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}length(){const a=B(this.g,this.h,4);return a?fb(this.g,this.h+a):BigInt("0")}H(a,b){const c=B(this.g,this.h,6);return c?(b||new Hb).i(jb(this.g,this.h+c)+a*16,this.g):null}buffers(a,b){const c=B(this.g,this.h,8);return c?(b||new Fb).i(jb(this.g,this.h+c)+a*16,this.g):null}compression(a){const b=B(this.g,this.h,10);return b?(a||new Eb).i(ib(this.g,this.h+b),this.g):null}};class Lb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}id(){const a=B(this.g,this.h,4);return a?fb(this.g,this.h+a):BigInt("0")}data(a){const b=B(this.g,this.h,6);return b?(a||new Kb).i(ib(this.g,this.h+b),this.g):null}Oa(){const a=B(this.g,this.h,8);return a?!!(this.g.l[this.h+a]<<24>>24):!1}};var Mb,Nb=Mb||(Mb={});Nb[Nb.Little=0]="Little";Nb[Nb.Big=1]="Big";var Ob,Pb=Ob||(Ob={});Pb[Pb.DenseArray=0]="DenseArray";class Qb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}bitWidth(){const a=B(this.g,this.h,4);return a?this.g.v(this.h+a):0}isSigned(){const a=B(this.g,this.h,6);return a?!!(this.g.l[this.h+a]<<24>>24):!1}};function Rb(a){const b=B(a.g,a.h,6);return b?(new Qb).i(ib(a.g,a.h+b),a.g):null}class Sb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}id(){const a=B(this.g,this.h,4);return a?fb(this.g,this.h+a):BigInt("0")}isOrdered(){const a=B(this.g,this.h,8);return a?!!(this.g.l[this.h+a]<<24>>24):!1}};class Tb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}key(a){const b=B(this.g,this.h,4);return b?hb(this.g,this.h+b,a):null}value(a){const b=B(this.g,this.h,6);return b?hb(this.g,this.h+b,a):null}};class Ub{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}unit(){const a=B(this.g,this.h,4);return a?eb(this.g,this.h+a):Ya.MILLISECOND}};class Vb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}precision(){const a=B(this.g,this.h,4);return a?this.g.v(this.h+a):0}scale(){const a=B(this.g,this.h,6);return a?this.g.v(this.h+a):0}bitWidth(){const a=B(this.g,this.h,8);return a?this.g.v(this.h+a):128}};class Wb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}unit(){const a=B(this.g,this.h,4);return a?eb(this.g,this.h+a):z.MILLISECOND}};class Xb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}byteWidth(){const a=B(this.g,this.h,4);return a?this.g.v(this.h+a):0}};class Yb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}listSize(){const a=B(this.g,this.h,4);return a?this.g.v(this.h+a):0}};class Zb{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}precision(){const a=B(this.g,this.h,4);return a?eb(this.g,this.h+a):y.HALF}};class $b{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}unit(){const a=B(this.g,this.h,4);return a?eb(this.g,this.h+a):A.YEAR_MONTH}};class ac{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}keysSorted(){const a=B(this.g,this.h,4);return a?!!(this.g.l[this.h+a]<<24>>24):!1}};class bc{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}unit(){const a=B(this.g,this.h,4);return a?eb(this.g,this.h+a):z.MILLISECOND}bitWidth(){const a=B(this.g,this.h,6);return a?this.g.v(this.h+a):32}};class cc{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}unit(){const a=B(this.g,this.h,4);return a?eb(this.g,this.h+a):z.SECOND}timezone(a){const b=B(this.g,this.h,6);return b?hb(this.g,this.h+b,a):null}};class dc{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}mode(){const a=B(this.g,this.h,4);return a?eb(this.g,this.h+a):x.Sparse}typeIds(a){const b=B(this.g,this.h,6);return b?this.g.v(jb(this.g,this.h+b)+a*4):0}};var F,G=F||(F={});G[G.NONE=0]="NONE";G[G.Null=1]="Null";G[G.Int=2]="Int";G[G.FloatingPoint=3]="FloatingPoint";G[G.Binary=4]="Binary";G[G.Utf8=5]="Utf8";G[G.Bool=6]="Bool";G[G.Decimal=7]="Decimal";G[G.Date=8]="Date";G[G.Time=9]="Time";G[G.Timestamp=10]="Timestamp";G[G.Interval=11]="Interval";G[G.List=12]="List";G[G.Struct_=13]="Struct_";G[G.Union=14]="Union";G[G.FixedSizeBinary=15]="FixedSizeBinary";G[G.FixedSizeList=16]="FixedSizeList";G[G.Map=17]="Map";G[G.Duration=18]="Duration";
G[G.LargeBinary=19]="LargeBinary";G[G.LargeUtf8=20]="LargeUtf8";G[G.LargeList=21]="LargeList";G[G.RunEndEncoded=22]="RunEndEncoded";function ec(a,b){wb(a,4,b.length,4);for(let c=b.length-1;c>=0;c--)ub(a,b[c]);return xb(a)}function fc(a,b){wb(a,4,b.length,4);for(let c=b.length-1;c>=0;c--)ub(a,b[c]);return xb(a)}function hc(a){const b=B(a.g,a.h,14);return b?kb(a.g,a.h+b):0}
class ic{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}name(a){const b=B(this.g,this.h,4);return b?hb(this.g,this.h+b,a):null}nullable(){const a=B(this.g,this.h,6);return a?!!(this.g.l[this.h+a]<<24>>24):!1}type(a){const b=B(this.g,this.h,10);return b?gb(this.g,a,this.h+b):null}dictionary(a){const b=B(this.g,this.h,12);return b?(a||new Sb).i(ib(this.g,this.h+b),this.g):null}children(a,b){const c=B(this.g,this.h,14);return c?(b||new ic).i(ib(this.g,jb(this.g,this.h+c)+a*4),
this.g):null}La(a){const b=B(this.g,this.h,16);return b?(new Tb).i(ib(this.g,jb(this.g,this.h+b)+a*4),this.g):null}Ma(){const a=B(this.g,this.h,16);return a?kb(this.g,this.h+a):0}};function jc(a,b){wb(a,4,b.length,4);for(let c=b.length-1;c>=0;c--)ub(a,b[c]);return xb(a)}function kc(a,b){wb(a,4,b.length,4);for(let c=b.length-1;c>=0;c--)ub(a,b[c]);return xb(a)}function lc(a){const b=B(a.g,a.h,6);return b?kb(a.g,a.h+b):0}
class mc{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}fields(a,b){const c=B(this.g,this.h,6);return c?(b||new ic).i(ib(this.g,jb(this.g,this.h+c)+a*4),this.g):null}La(a){const b=B(this.g,this.h,8);return b?(new Tb).i(ib(this.g,jb(this.g,this.h+b)+a*4),this.g):null}Ma(){const a=B(this.g,this.h,8);return a?kb(this.g,this.h+a):0}features(a){const b=B(this.g,this.h,10);return b?fb(this.g,jb(this.g,this.h+b)+a*8):BigInt(0)}};var nc,oc=nc||(nc={});oc[oc.Row=0]="Row";oc[oc.Column=1]="Column";var pc,qc=pc||(pc={});qc[qc.NONE=0]="NONE";qc[qc.SparseTensorIndexCOO=1]="SparseTensorIndexCOO";qc[qc.SparseMatrixIndexCSX=2]="SparseMatrixIndexCSX";qc[qc.SparseTensorIndexCSF=3]="SparseTensorIndexCSF";var H,rc=H||(H={});rc[rc.NONE=0]="NONE";rc[rc.Schema=1]="Schema";rc[rc.DictionaryBatch=2]="DictionaryBatch";rc[rc.RecordBatch=3]="RecordBatch";rc[rc.Tensor=4]="Tensor";rc[rc.SparseTensor=5]="SparseTensor";var I,J=I||(I={});J[J.NONE=0]="NONE";J[J.Null=1]="Null";J[J.Int=2]="Int";J[J.Float=3]="Float";J[J.Binary=4]="Binary";J[J.Utf8=5]="Utf8";J[J.Bool=6]="Bool";J[J.Decimal=7]="Decimal";J[J.Date=8]="Date";J[J.Time=9]="Time";J[J.Timestamp=10]="Timestamp";J[J.Interval=11]="Interval";J[J.List=12]="List";J[J.Struct=13]="Struct";J[J.Union=14]="Union";J[J.FixedSizeBinary=15]="FixedSizeBinary";J[J.FixedSizeList=16]="FixedSizeList";J[J.Map=17]="Map";J[J.Duration=18]="Duration";J[J.LargeBinary=19]="LargeBinary";
J[J.LargeUtf8=20]="LargeUtf8";J[J.Dictionary=-1]="Dictionary";J[J.Int8=-2]="Int8";J[J.Int16=-3]="Int16";J[J.Int32=-4]="Int32";J[J.Int64=-5]="Int64";J[J.Uint8=-6]="Uint8";J[J.Uint16=-7]="Uint16";J[J.Uint32=-8]="Uint32";J[J.Uint64=-9]="Uint64";J[J.Float16=-10]="Float16";J[J.Float32=-11]="Float32";J[J.Float64=-12]="Float64";J[J.DateDay=-13]="DateDay";J[J.DateMillisecond=-14]="DateMillisecond";J[J.TimestampSecond=-15]="TimestampSecond";J[J.TimestampMillisecond=-16]="TimestampMillisecond";
J[J.TimestampMicrosecond=-17]="TimestampMicrosecond";J[J.TimestampNanosecond=-18]="TimestampNanosecond";J[J.TimeSecond=-19]="TimeSecond";J[J.TimeMillisecond=-20]="TimeMillisecond";J[J.TimeMicrosecond=-21]="TimeMicrosecond";J[J.TimeNanosecond=-22]="TimeNanosecond";J[J.DenseUnion=-23]="DenseUnion";J[J.SparseUnion=-24]="SparseUnion";J[J.IntervalDayTime=-25]="IntervalDayTime";J[J.IntervalYearMonth=-26]="IntervalYearMonth";J[J.DurationSecond=-27]="DurationSecond";J[J.DurationMillisecond=-28]="DurationMillisecond";
J[J.DurationMicrosecond=-29]="DurationMicrosecond";J[J.DurationNanosecond=-30]="DurationNanosecond";J[J.IntervalMonthDayNano=-31]="IntervalMonthDayNano";var sc,tc=sc||(sc={});tc[tc.OFFSET=0]="OFFSET";tc[tc.DATA=1]="DATA";tc[tc.VALIDITY=2]="VALIDITY";tc[tc.TYPE=3]="TYPE";function uc(a){if(a===null)return"null";if(a===void 0)return"undefined";switch(typeof a){case "number":return`${a}`;case "bigint":return`${a}`;case "string":return`"${a}"`}return typeof a[Symbol.toPrimitive]==="function"?a[Symbol.toPrimitive]("string"):ArrayBuffer.isView(a)?a instanceof BigInt64Array||a instanceof BigUint64Array?`[${[...a].map(b=>uc(b))}]`:`[${a}]`:ArrayBuffer.isView(a)?`[${a}]`:JSON.stringify(a,(b,c)=>typeof c==="bigint"?`${c}`:c)}var vc={};vc.valueToString=uc;function K(a){if(typeof a==="bigint"&&(a<Number.MIN_SAFE_INTEGER||a>Number.MAX_SAFE_INTEGER))throw new TypeError(`${a} is not safe to convert to a number.`);return Number(a)}function wc(a,b){return K(a/b)+K(a%b)/K(b)};const xc=Symbol.for("isArrowBigNum");function yc(a,...b){return b.length===0?Object.setPrototypeOf(u(this.TypedArray,a),this.constructor.prototype):Object.setPrototypeOf(new this.TypedArray(a,...b),this.constructor.prototype)}yc.prototype[xc]=!0;yc.prototype.toJSON=function(){return`"${zc(this)}"`};yc.prototype.valueOf=function(a){return Ac(this,a)};yc.prototype.toString=function(){return zc(this)};yc.prototype[Symbol.toPrimitive]=function(a="default"){switch(a){case "number":return Ac(this);case "default":return Bc(this)}return zc(this)};
function Cc(...a){return yc.apply(this,a)}function Dc(...a){return yc.apply(this,a)}function Ec(...a){return yc.apply(this,a)}Object.setPrototypeOf(Cc.prototype,Object.create(Int32Array.prototype));Object.setPrototypeOf(Dc.prototype,Object.create(Uint32Array.prototype));Object.setPrototypeOf(Ec.prototype,Object.create(Uint32Array.prototype));Object.assign(Cc.prototype,yc.prototype,{constructor:Cc,signed:!0,TypedArray:Int32Array,BigIntArray:BigInt64Array});
Object.assign(Dc.prototype,yc.prototype,{constructor:Dc,signed:!1,TypedArray:Uint32Array,BigIntArray:BigUint64Array});Object.assign(Ec.prototype,yc.prototype,{constructor:Ec,signed:!0,TypedArray:Uint32Array,BigIntArray:BigUint64Array});const Fc=BigInt(4294967296)*BigInt(4294967296)-BigInt(1);
function Ac(a,b){const {buffer:c,byteOffset:d,byteLength:e,signed:f}=a,g=new BigUint64Array(c,d,e/8);a=f&&g.at(-1)&BigInt(1)<<BigInt(63);var k=BigInt(0);let m=0;if(a){for(var p of g)k|=(p^Fc)*(BigInt(1)<<BigInt(64*m++));k*=BigInt(-1);k-=BigInt(1)}else for(var r of g)k|=r*(BigInt(1)<<BigInt(64*m++));return typeof b==="number"&&b>0?(r=BigInt("1".padEnd(b+1,"0")),p=a?-(k%r):k%r,k=K(k/r),+`${a&&k===0?"-":""}${k}.${`${p}`.padStart(b,"0")}`):K(k)}
function zc(a){if(a.byteLength===8)return`${(new a.BigIntArray(a.buffer,a.byteOffset,1))[0]}`;if(!a.signed)return Gc(a);let b=new Uint16Array(a.buffer,a.byteOffset,a.byteLength/2);if((new Int16Array([b.at(-1)]))[0]>=0)return Gc(a);b=b.slice();a=1;for(let c=0;c<b.length;c++){const d=b[c];b[c]=~d+a;a&=d===0?1:0}return`-${Gc(b)}`}function Bc(a){return a.byteLength===8?(new a.BigIntArray(a.buffer,a.byteOffset,1))[0]:zc(a)}
function Gc(a){let b="";const c=new Uint32Array(2);a=new Uint16Array(a.buffer,a.byteOffset,a.byteLength/2);const d=new Uint32Array((a=(new Uint16Array(a)).reverse()).buffer);let e;const f=a.length-1;do{for(c[0]=a[e=0];e<f;)a[e++]=c[1]=c[0]/10,c[0]=(c[0]-c[1]*10<<16)+a[e];a[e]=c[1]=c[0]/10;c[0]-=c[1]*10;b=`${c[0]}${b}`}while(d[0]||d[1]||d[2]||d[3]);let g;return(g=b)!=null?g:"0"}
class Hc{static new(a,b){switch(b){case !0:return new Cc(a);case !1:return new Dc(a)}switch(a.constructor){case Int8Array:case Int16Array:case Int32Array:case BigInt64Array:return new Cc(a)}return a.byteLength===16?new Ec(a):new Dc(a)}static vc(a){return new Cc(a)}constructor(a,b){return Hc.new(a,b)}}var Ic={};Ic.BN=Hc;Ic.bigNumToBigInt=Bc;Ic.bigNumToNumber=Ac;Ic.bigNumToString=zc;Ic.isArrowBigNumSymbol=xc;class L{static isNull(a){return(a==null?void 0:a.typeId)===I.Null}static isInt(a){return(a==null?void 0:a.typeId)===I.Int}static isFloat(a){return(a==null?void 0:a.typeId)===I.Float}static isBinary(a){return(a==null?void 0:a.typeId)===I.Binary}static isLargeBinary(a){return(a==null?void 0:a.typeId)===I.LargeBinary}static isUtf8(a){return(a==null?void 0:a.typeId)===I.Utf8}static isLargeUtf8(a){return(a==null?void 0:a.typeId)===I.LargeUtf8}static isBool(a){return(a==null?void 0:a.typeId)===I.Bool}static isDecimal(a){return(a==
null?void 0:a.typeId)===I.Decimal}static isDate(a){return(a==null?void 0:a.typeId)===I.Date}static isTime(a){return(a==null?void 0:a.typeId)===I.Time}static isTimestamp(a){return(a==null?void 0:a.typeId)===I.Timestamp}static isInterval(a){return(a==null?void 0:a.typeId)===I.Interval}static isDuration(a){return(a==null?void 0:a.typeId)===I.Duration}static isList(a){return(a==null?void 0:a.typeId)===I.List}static isStruct(a){return(a==null?void 0:a.typeId)===I.Struct}static isUnion(a){return(a==null?
void 0:a.typeId)===I.Union}static isFixedSizeBinary(a){return(a==null?void 0:a.typeId)===I.FixedSizeBinary}static isFixedSizeList(a){return(a==null?void 0:a.typeId)===I.FixedSizeList}static isMap(a){return(a==null?void 0:a.typeId)===I.Map}static isDictionary(a){return(a==null?void 0:a.typeId)===I.Dictionary}static isDenseUnion(a){return L.isUnion(a)&&a.mode===x.Dense}static isSparseUnion(a){return L.isUnion(a)&&a.mode===x.Sparse}constructor(a){this.typeId=a}}var Jc=Symbol.toStringTag,Kc,Lc=L.prototype;
Lc.children=null;Lc.ArrayType=Array;Lc.OffsetArrayType=Int32Array;Kc=Lc[Symbol.toStringTag]="DataType";L[Jc]=Kc;class Mc extends L{constructor(){super(I.Null)}toString(){return"Null"}}Mc[Symbol.toStringTag]=Mc.prototype[Symbol.toStringTag]="Null";
class Nc extends L{constructor(a,b){super(I.Int);this.isSigned=a;this.bitWidth=b}get ArrayType(){switch(this.bitWidth){case 8:return this.isSigned?Int8Array:Uint8Array;case 16:return this.isSigned?Int16Array:Uint16Array;case 32:return this.isSigned?Int32Array:Uint32Array;case 64:return this.isSigned?BigInt64Array:BigUint64Array}throw Error(`Unrecognized ${this[Symbol.toStringTag]} type`);}toString(){return`${this.isSigned?"I":"Ui"}nt${this.bitWidth}`}}var Oc=Symbol.toStringTag,Qc,Rc=Nc.prototype;
Rc.isSigned=null;Rc.bitWidth=null;Qc=Rc[Symbol.toStringTag]="Int";Nc[Oc]=Qc;class Sc extends Nc{constructor(){super(!0,8)}get ArrayType(){return Int8Array}}class Tc extends Nc{constructor(){super(!0,16)}get ArrayType(){return Int16Array}}class Uc extends Nc{constructor(){super(!0,32)}get ArrayType(){return Int32Array}}class Vc extends Nc{constructor(){super(!0,64)}get ArrayType(){return BigInt64Array}}class Wc extends Nc{constructor(){super(!1,8)}get ArrayType(){return Uint8Array}}
class Xc extends Nc{constructor(){super(!1,16)}get ArrayType(){return Uint16Array}}class Yc extends Nc{constructor(){super(!1,32)}get ArrayType(){return Uint32Array}}class Zc extends Nc{constructor(){super(!1,64)}get ArrayType(){return BigUint64Array}}Object.defineProperty(Sc.prototype,"ArrayType",{value:Int8Array});Object.defineProperty(Tc.prototype,"ArrayType",{value:Int16Array});Object.defineProperty(Uc.prototype,"ArrayType",{value:Int32Array});Object.defineProperty(Vc.prototype,"ArrayType",{value:BigInt64Array});
Object.defineProperty(Wc.prototype,"ArrayType",{value:Uint8Array});Object.defineProperty(Xc.prototype,"ArrayType",{value:Uint16Array});Object.defineProperty(Yc.prototype,"ArrayType",{value:Uint32Array});Object.defineProperty(Zc.prototype,"ArrayType",{value:BigUint64Array});
class $c extends L{constructor(a){super(I.Float);this.precision=a}get ArrayType(){switch(this.precision){case y.HALF:return Uint16Array;case y.SINGLE:return Float32Array;case y.DOUBLE:return Float64Array}throw Error(`Unrecognized ${this[Symbol.toStringTag]} type`);}toString(){return`Float${this.precision<<5||16}`}}var ad=Symbol.toStringTag,bd,cd=$c.prototype;cd.precision=null;bd=cd[Symbol.toStringTag]="Float";$c[ad]=bd;class dd extends $c{constructor(){super(y.HALF)}}
class ed extends $c{constructor(){super(y.SINGLE)}}class fd extends $c{constructor(){super(y.DOUBLE)}}Object.defineProperty(dd.prototype,"ArrayType",{value:Uint16Array});Object.defineProperty(ed.prototype,"ArrayType",{value:Float32Array});Object.defineProperty(fd.prototype,"ArrayType",{value:Float64Array});class gd extends L{constructor(){super(I.Binary)}toString(){return"Binary"}}var hd=Symbol.toStringTag,id,jd=gd.prototype;jd.ArrayType=Uint8Array;id=jd[Symbol.toStringTag]="Binary";gd[hd]=id;
class kd extends L{constructor(){super(I.LargeBinary)}toString(){return"LargeBinary"}}var ld=Symbol.toStringTag,md,nd=kd.prototype;nd.ArrayType=Uint8Array;nd.OffsetArrayType=BigInt64Array;md=nd[Symbol.toStringTag]="LargeBinary";kd[ld]=md;class od extends L{constructor(){super(I.Utf8)}toString(){return"Utf8"}}var pd=Symbol.toStringTag,qd,rd=od.prototype;rd.ArrayType=Uint8Array;qd=rd[Symbol.toStringTag]="Utf8";od[pd]=qd;
class sd extends L{constructor(){super(I.LargeUtf8)}toString(){return"LargeUtf8"}}var td=Symbol.toStringTag,ud,vd=sd.prototype;vd.ArrayType=Uint8Array;vd.OffsetArrayType=BigInt64Array;ud=vd[Symbol.toStringTag]="LargeUtf8";sd[td]=ud;class wd extends L{constructor(){super(I.Bool)}toString(){return"Bool"}}var xd=Symbol.toStringTag,yd,zd=wd.prototype;zd.ArrayType=Uint8Array;yd=zd[Symbol.toStringTag]="Bool";wd[xd]=yd;
class Ad extends L{constructor(a,b,c=128){super(I.Decimal);this.scale=a;this.precision=b;this.bitWidth=c}toString(){return`Decimal[${this.precision}e${this.scale>0?"+":""}${this.scale}]`}}var Bd=Symbol.toStringTag,Cd,Dd=Ad.prototype;Dd.scale=null;Dd.precision=null;Dd.ArrayType=Uint32Array;Cd=Dd[Symbol.toStringTag]="Decimal";Ad[Bd]=Cd;
class Ed extends L{constructor(a){super(I.Date);this.unit=a}toString(){return`Date${(this.unit+1)*32}<${Ya[this.unit]}>`}get ArrayType(){return this.unit===Ya.DAY?Int32Array:BigInt64Array}}var Fd=Symbol.toStringTag,Gd,Hd=Ed.prototype;Hd.unit=null;Gd=Hd[Symbol.toStringTag]="Date";Ed[Fd]=Gd;class Id extends Ed{constructor(){super(Ya.DAY)}}class Jd extends Ed{constructor(){super(Ya.MILLISECOND)}}
class Kd extends L{constructor(a,b){super(I.Time);this.unit=a;this.bitWidth=b}toString(){return`Time${this.bitWidth}<${z[this.unit]}>`}get ArrayType(){switch(this.bitWidth){case 32:return Int32Array;case 64:return BigInt64Array}throw Error(`Unrecognized ${this[Symbol.toStringTag]} type`);}}var Ld=Symbol.toStringTag,Md,Nd=Kd.prototype;Nd.unit=null;Nd.bitWidth=null;Md=Nd[Symbol.toStringTag]="Time";Kd[Ld]=Md;class Od extends Kd{constructor(){super(z.SECOND,32)}}
class Pd extends Kd{constructor(){super(z.MILLISECOND,32)}}class Qd extends Kd{constructor(){super(z.MICROSECOND,64)}}class Rd extends Kd{constructor(){super(z.NANOSECOND,64)}}class Sd extends L{constructor(a,b){super(I.Timestamp);this.unit=a;this.timezone=b}toString(){return`Timestamp<${z[this.unit]}${this.timezone?`, ${this.timezone}`:""}>`}}var Td=Symbol.toStringTag,Ud,Vd=Sd.prototype;Vd.unit=null;Vd.timezone=null;Vd.ArrayType=BigInt64Array;Ud=Vd[Symbol.toStringTag]="Timestamp";Sd[Td]=Ud;
class Wd extends Sd{constructor(a){super(z.SECOND,a)}}class Xd extends Sd{constructor(a){super(z.MILLISECOND,a)}}class Yd extends Sd{constructor(a){super(z.MICROSECOND,a)}}class Zd extends Sd{constructor(a){super(z.NANOSECOND,a)}}class $d extends L{constructor(a){super(I.Interval);this.unit=a}toString(){return`Interval<${A[this.unit]}>`}}var ae=Symbol.toStringTag,be,ce=$d.prototype;ce.unit=null;ce.ArrayType=Int32Array;be=ce[Symbol.toStringTag]="Interval";$d[ae]=be;
class de extends $d{constructor(){super(A.DAY_TIME)}}class ee extends $d{constructor(){super(A.YEAR_MONTH)}}class fe extends $d{constructor(){super(A.MONTH_DAY_NANO)}}class ge extends L{constructor(a){super(I.Duration);this.unit=a}toString(){return`Duration<${z[this.unit]}>`}}var he=Symbol.toStringTag,ie,je=ge.prototype;je.unit=null;je.ArrayType=BigInt64Array;ie=je[Symbol.toStringTag]="Duration";ge[he]=ie;class ke extends ge{constructor(){super(z.SECOND)}}
class le extends ge{constructor(){super(z.MILLISECOND)}}class me extends ge{constructor(){super(z.MICROSECOND)}}class ne extends ge{constructor(){super(z.NANOSECOND)}}class oe extends L{constructor(a){super(I.List);this.children=[a]}toString(){return`List<${this.valueType}>`}get valueType(){return this.children[0].type}get valueField(){return this.children[0]}get ArrayType(){return this.valueType.ArrayType}}var pe=Symbol.toStringTag,qe,re=oe.prototype;re.children=null;qe=re[Symbol.toStringTag]="List";
oe[pe]=qe;class se extends L{constructor(a){super(I.Struct);this.children=a}toString(){return`Struct<{${this.children.map(a=>`${a.name}:${a.type}`).join(", ")}}>`}}var te=Symbol.toStringTag,ue,ve=se.prototype;ve.children=null;ue=ve[Symbol.toStringTag]="Struct";se[te]=ue;
class we extends L{constructor(a,b,c){super(I.Union);this.mode=a;this.children=c;this.typeIds=b=Int32Array.from(b);this.typeIdToChildIndex=b.reduce((d,e,f)=>(d[e]=f)&&d||d,Object.create(null))}toString(){return`${this[Symbol.toStringTag]}<${this.children.map(a=>`${a.type}`).join(" | ")}>`}}var xe=Symbol.toStringTag,ye,ze=we.prototype;ze.mode=null;ze.typeIds=null;ze.children=null;ze.typeIdToChildIndex=null;ze.ArrayType=Int8Array;ye=ze[Symbol.toStringTag]="Union";we[xe]=ye;
class Ae extends we{constructor(a,b){super(x.Dense,a,b)}}class Be extends we{constructor(a,b){super(x.Sparse,a,b)}}class Ce extends L{constructor(a){super(I.FixedSizeBinary);this.byteWidth=a}toString(){return`FixedSizeBinary[${this.byteWidth}]`}}var De=Symbol.toStringTag,Ee,Fe=Ce.prototype;Fe.byteWidth=null;Fe.ArrayType=Uint8Array;Ee=Fe[Symbol.toStringTag]="FixedSizeBinary";Ce[De]=Ee;
class Ge extends L{constructor(a,b){super(I.FixedSizeList);this.listSize=a;this.children=[b]}get valueType(){return this.children[0].type}get valueField(){return this.children[0]}get ArrayType(){return this.valueType.ArrayType}toString(){return`FixedSizeList[${this.listSize}]<${this.valueType}>`}}var He=Symbol.toStringTag,Ie,Je=Ge.prototype;Je.children=null;Je.listSize=null;Ie=Je[Symbol.toStringTag]="FixedSizeList";Ge[He]=Ie;
class Ke extends L{constructor(a,b=!1){super(I.Map);this.children=[a];this.keysSorted=b;if(a){a.name="entries";let c;if(a==null?0:(c=a.type)==null?0:c.children){let d;(b=a==null?void 0:(d=a.type)==null?void 0:d.children[0])&&(b.name="key");let e;(a=a==null?void 0:(e=a.type)==null?void 0:e.children[1])&&(a.name="value")}}}get keyType(){return this.children[0].type.children[0].type}get valueType(){return this.children[0].type.children[1].type}get childType(){return this.children[0].type}toString(){return`Map<{${this.children[0].type.children.map(a=>
`${a.name}:${a.type}`).join(", ")}}>`}}var Le=Symbol.toStringTag,Me,Ne=Ke.prototype;Ne.children=null;Ne.keysSorted=null;Me=Ne[Symbol.toStringTag]="Map_";Ke[Le]=Me;const Oe=(a=>()=>++a)(-1);
class Pe extends L{constructor(a,b,c,d){super(I.Dictionary);this.indices=b;this.dictionary=a;this.isOrdered=d||!1;this.id=c==null?Oe():K(c)}get children(){return this.dictionary.children}get valueType(){return this.dictionary}get ArrayType(){return this.dictionary.ArrayType}toString(){return`Dictionary<${this.indices}, ${this.dictionary}>`}}var Qe=Symbol.toStringTag,Re,Se=Pe.prototype;Se.id=null;Se.indices=null;Se.isOrdered=null;Se.dictionary=null;Re=Se[Symbol.toStringTag]="Dictionary";Pe[Qe]=Re;
function Te(a){switch(a.typeId){case I.Decimal:return a.bitWidth/32;case I.Interval:return a.unit===A.MONTH_DAY_NANO?4:1+a.unit;case I.FixedSizeList:return a.listSize;case I.FixedSizeBinary:return a.byteWidth;default:return 1}};class Ue{visitMany(a,...b){return a.map((c,d)=>this.visit(c,...b.map(e=>e[d])))}visit(...a){return this.getVisitFn(a[0],!1).apply(this,a)}getVisitFn(a,b=!0){return Ve(this,a,b)}getVisitFnByTypeId(a,b=!0){return We(this,a,b)}visitNull(){return null}visitBool(){return null}visitInt(){return null}visitFloat(){return null}visitUtf8(){return null}visitLargeUtf8(){return null}visitBinary(){return null}visitLargeBinary(){return null}visitFixedSizeBinary(){return null}visitDate(){return null}visitTimestamp(){return null}visitTime(){return null}visitDecimal(){return null}visitList(){return null}visitStruct(){return null}visitUnion(){return null}visitDictionary(){return null}visitInterval(){return null}visitDuration(){return null}visitFixedSizeList(){return null}visitMap(){return null}}
function Ve(a,b,c=!0){return typeof b==="number"?We(a,b,c):typeof b==="string"&&b in I?We(a,I[b],c):b&&b instanceof L?We(a,Xe(b),c):(b==null?0:b.type)&&b.type instanceof L?We(a,Xe(b.type),c):We(a,I.NONE,c)}
function We(a,b,c=!0){let d=null;switch(b){case I.Null:d=a.visitNull;break;case I.Bool:d=a.visitBool;break;case I.Int:d=a.visitInt;break;case I.Int8:d=a.visitInt8||a.visitInt;break;case I.Int16:d=a.visitInt16||a.visitInt;break;case I.Int32:d=a.visitInt32||a.visitInt;break;case I.Int64:d=a.visitInt64||a.visitInt;break;case I.Uint8:d=a.visitUint8||a.visitInt;break;case I.Uint16:d=a.visitUint16||a.visitInt;break;case I.Uint32:d=a.visitUint32||a.visitInt;break;case I.Uint64:d=a.visitUint64||a.visitInt;
break;case I.Float:d=a.visitFloat;break;case I.Float16:d=a.visitFloat16||a.visitFloat;break;case I.Float32:d=a.visitFloat32||a.visitFloat;break;case I.Float64:d=a.visitFloat64||a.visitFloat;break;case I.Utf8:d=a.visitUtf8;break;case I.LargeUtf8:d=a.visitLargeUtf8;break;case I.Binary:d=a.visitBinary;break;case I.LargeBinary:d=a.visitLargeBinary;break;case I.FixedSizeBinary:d=a.visitFixedSizeBinary;break;case I.Date:d=a.visitDate;break;case I.DateDay:d=a.visitDateDay||a.visitDate;break;case I.DateMillisecond:d=
a.visitDateMillisecond||a.visitDate;break;case I.Timestamp:d=a.visitTimestamp;break;case I.TimestampSecond:d=a.visitTimestampSecond||a.visitTimestamp;break;case I.TimestampMillisecond:d=a.visitTimestampMillisecond||a.visitTimestamp;break;case I.TimestampMicrosecond:d=a.visitTimestampMicrosecond||a.visitTimestamp;break;case I.TimestampNanosecond:d=a.visitTimestampNanosecond||a.visitTimestamp;break;case I.Time:d=a.visitTime;break;case I.TimeSecond:d=a.visitTimeSecond||a.visitTime;break;case I.TimeMillisecond:d=
a.visitTimeMillisecond||a.visitTime;break;case I.TimeMicrosecond:d=a.visitTimeMicrosecond||a.visitTime;break;case I.TimeNanosecond:d=a.visitTimeNanosecond||a.visitTime;break;case I.Decimal:d=a.visitDecimal;break;case I.List:d=a.visitList;break;case I.Struct:d=a.visitStruct;break;case I.Union:d=a.visitUnion;break;case I.DenseUnion:d=a.visitDenseUnion||a.visitUnion;break;case I.SparseUnion:d=a.visitSparseUnion||a.visitUnion;break;case I.Dictionary:d=a.visitDictionary;break;case I.Interval:d=a.visitInterval;
break;case I.IntervalDayTime:d=a.visitIntervalDayTime||a.visitInterval;break;case I.IntervalYearMonth:d=a.visitIntervalYearMonth||a.visitInterval;break;case I.IntervalMonthDayNano:d=a.visitIntervalMonthDayNano||a.visitInterval;break;case I.Duration:d=a.visitDuration;break;case I.DurationSecond:d=a.visitDurationSecond||a.visitDuration;break;case I.DurationMillisecond:d=a.visitDurationMillisecond||a.visitDuration;break;case I.DurationMicrosecond:d=a.visitDurationMicrosecond||a.visitDuration;break;case I.DurationNanosecond:d=
a.visitDurationNanosecond||a.visitDuration;break;case I.FixedSizeList:d=a.visitFixedSizeList;break;case I.Map:d=a.visitMap}if(typeof d==="function")return d;if(!c)return()=>null;throw Error(`Unrecognized type '${I[b]}'`);}
function Xe(a){switch(a.typeId){case I.Null:return I.Null;case I.Int:const b=a.isSigned;switch(a.bitWidth){case 8:return b?I.Int8:I.Uint8;case 16:return b?I.Int16:I.Uint16;case 32:return b?I.Int32:I.Uint32;case 64:return b?I.Int64:I.Uint64}return I.Int;case I.Float:switch(a.precision){case y.HALF:return I.Float16;case y.SINGLE:return I.Float32;case y.DOUBLE:return I.Float64}return I.Float;case I.Binary:return I.Binary;case I.LargeBinary:return I.LargeBinary;case I.Utf8:return I.Utf8;case I.LargeUtf8:return I.LargeUtf8;
case I.Bool:return I.Bool;case I.Decimal:return I.Decimal;case I.Time:switch(a.unit){case z.SECOND:return I.TimeSecond;case z.MILLISECOND:return I.TimeMillisecond;case z.MICROSECOND:return I.TimeMicrosecond;case z.NANOSECOND:return I.TimeNanosecond}return I.Time;case I.Timestamp:switch(a.unit){case z.SECOND:return I.TimestampSecond;case z.MILLISECOND:return I.TimestampMillisecond;case z.MICROSECOND:return I.TimestampMicrosecond;case z.NANOSECOND:return I.TimestampNanosecond}return I.Timestamp;case I.Date:switch(a.unit){case Ya.DAY:return I.DateDay;
case Ya.MILLISECOND:return I.DateMillisecond}return I.Date;case I.Interval:switch(a.unit){case A.DAY_TIME:return I.IntervalDayTime;case A.YEAR_MONTH:return I.IntervalYearMonth;case A.MONTH_DAY_NANO:return I.IntervalMonthDayNano}return I.Interval;case I.Duration:switch(a.unit){case z.SECOND:return I.DurationSecond;case z.MILLISECOND:return I.DurationMillisecond;case z.MICROSECOND:return I.DurationMicrosecond;case z.NANOSECOND:return I.DurationNanosecond}return I.Duration;case I.Map:return I.Map;case I.List:return I.List;
case I.Struct:return I.Struct;case I.Union:switch(a.mode){case x.Dense:return I.DenseUnion;case x.Sparse:return I.SparseUnion}return I.Union;case I.FixedSizeBinary:return I.FixedSizeBinary;case I.FixedSizeList:return I.FixedSizeList;case I.Dictionary:return I.Dictionary}throw Error(`Unrecognized type '${I[a.typeId]}'`);}h=Ue.prototype;h.visitInt8=null;h.visitInt16=null;h.visitInt32=null;h.visitInt64=null;h.visitUint8=null;h.visitUint16=null;h.visitUint32=null;h.visitUint64=null;h.visitFloat16=null;
h.visitFloat32=null;h.visitFloat64=null;h.visitDateDay=null;h.visitDateMillisecond=null;h.visitTimestampSecond=null;h.visitTimestampMillisecond=null;h.visitTimestampMicrosecond=null;h.visitTimestampNanosecond=null;h.visitTimeSecond=null;h.visitTimeMillisecond=null;h.visitTimeMicrosecond=null;h.visitTimeNanosecond=null;h.visitDenseUnion=null;h.visitSparseUnion=null;h.visitIntervalDayTime=null;h.visitIntervalYearMonth=null;h.visitIntervalMonthDayNano=null;h.visitDuration=null;
h.visitDurationSecond=null;h.visitDurationMillisecond=null;h.visitDurationMicrosecond=null;h.visitDurationNanosecond=null;const Ye=new Float64Array(1),Ze=new Uint32Array(Ye.buffer);function $e(a){const b=(a&31744)>>10,c=(a&1023)/1024;a=Math.pow(-1,(a&32768)>>15);switch(b){case 31:return a*(c?Number.NaN:1/0);case 0:return a*(c?6.103515625E-5*c:0)}return a*Math.pow(2,b-15)*(1+c)}
function af(a){if(a!==a)return 32256;Ye[0]=a;a=(Ze[1]&2147483648)>>16&65535;let b=Ze[1]&2146435072,c=0;b>=1089470464?Ze[0]>0?b=31744:(b=(b&2080374784)>>16,c=(Ze[1]&1048575)>>10):b<=1056964608?(c=1048576+(Ze[1]&1048575),c=1048576+(c<<(b>>20)-998)>>21,b=0):(b=b-1056964608>>10,c=(Ze[1]&1048575)+512>>10);return a|b|c&65535}var bf={};bf.float64ToUint16=af;bf.uint16ToFloat64=$e;class cf extends Ue{}function M(a){return(b,c,d)=>{if(b.setValid(c,d!=null))return a(b,c,d)}}
const df=(a,b,c,d)=>{if(c+1<b.length){const e=K(b[c]);b=K(b[c+1]);a.set(d.subarray(0,b-e),e)}},ef=({values:a},b,c)=>{a[b]=c},ff=({values:a},b,c)=>{a[b]=c},gf=({values:a},b,c)=>{a[b]=af(c)},hf=({values:a},b,c)=>{a[b]=Math.floor(c.valueOf()/864E5)},jf=({values:a},b,c)=>{a[b]=BigInt(c)},kf=({stride:a,values:b},c,d)=>{b.set(d.subarray(0,a),a*c)},lf=({values:a,valueOffsets:b},c,d)=>df(a,b,c,d),mf=({values:a,valueOffsets:b},c,d)=>df(a,b,c,xa.encode(d)),nf=(a,b,c)=>{a.type.unit===Ya.DAY?hf(a,b,c):jf(a,b,
c)},of=({values:a},b,c)=>{a[b]=BigInt(c/1E3)},pf=({values:a},b,c)=>{a[b]=BigInt(c)},qf=({values:a},b,c)=>{a[b]=BigInt(c*1E3)},rf=({values:a},b,c)=>{a[b]=BigInt(c*1E6)},sf=(a,b,c)=>{switch(a.type.unit){case z.SECOND:return of(a,b,c);case z.MILLISECOND:return pf(a,b,c);case z.MICROSECOND:return qf(a,b,c);case z.NANOSECOND:return rf(a,b,c)}},tf=({values:a},b,c)=>{a[b]=c},uf=({values:a},b,c)=>{a[b]=c},vf=({values:a},b,c)=>{a[b]=c},wf=({values:a},b,c)=>{a[b]=c},xf=(a,b,c)=>{switch(a.type.unit){case z.SECOND:return tf(a,
b,c);case z.MILLISECOND:return uf(a,b,c);case z.MICROSECOND:return vf(a,b,c);case z.NANOSECOND:return wf(a,b,c)}},yf=({values:a,stride:b},c,d)=>{a.set(d.subarray(0,b),b*c)},zf=(a,b)=>(c,d,e,f)=>d&&c(d,a,b[f]),Af=(a,b)=>(c,d,e,f)=>d&&c(d,a,b.get(f)),Bf=(a,b)=>(c,d,e)=>d&&c(d,a,b.get(e.name)),Cf=(a,b)=>(c,d,e)=>d&&c(d,a,b[e.name]),Ef=(a,b,c)=>{Df.visit(a.children[a.type.typeIdToChildIndex[a.typeIds[b]]],a.valueOffsets[b],c)},Ff=(a,b,c)=>{Df.visit(a.children[a.type.typeIdToChildIndex[a.typeIds[b]]],
b,c)},Jf=(a,b,c)=>{switch(a.type.unit){case A.YEAR_MONTH:return Gf(a,b,c);case A.DAY_TIME:return Hf(a,b,c);case A.MONTH_DAY_NANO:return If(a,b,c)}},Hf=({values:a},b,c)=>{a.set(c.subarray(0,2),2*b)},Gf=({values:a},b,c)=>{a[b]=c[0]*12+c[1]%12},If=({values:a,stride:b},c,d)=>{a.set(d.subarray(0,b),b*c)},Kf=({values:a},b,c)=>{a[b]=c},Lf=({values:a},b,c)=>{a[b]=c},Mf=({values:a},b,c)=>{a[b]=c},Nf=({values:a},b,c)=>{a[b]=c},Of=(a,b,c)=>{switch(a.type.unit){case z.SECOND:return Kf(a,b,c);case z.MILLISECOND:return Lf(a,
b,c);case z.MICROSECOND:return Mf(a,b,c);case z.NANOSECOND:return Nf(a,b,c)}};h=cf.prototype;h.visitBool=M(({offset:a,values:b},c,d)=>{a+=c;d?b[a>>3]|=1<<a%8:b[a>>3]&=~(1<<a%8)});h.visitInt=M(ef);h.visitInt8=M(ef);h.visitInt16=M(ef);h.visitInt32=M(ef);h.visitInt64=M(ef);h.visitUint8=M(ef);h.visitUint16=M(ef);h.visitUint32=M(ef);h.visitUint64=M(ef);h.visitFloat=M((a,b,c)=>{switch(a.type.precision){case y.HALF:return gf(a,b,c);case y.SINGLE:case y.DOUBLE:return ff(a,b,c)}});h.visitFloat16=M(gf);
h.visitFloat32=M(ff);h.visitFloat64=M(ff);h.visitUtf8=M(mf);h.visitLargeUtf8=M(mf);h.visitBinary=M(lf);h.visitLargeBinary=M(lf);h.visitFixedSizeBinary=M(kf);h.visitDate=M(nf);h.visitDateDay=M(hf);h.visitDateMillisecond=M(jf);h.visitTimestamp=M(sf);h.visitTimestampSecond=M(of);h.visitTimestampMillisecond=M(pf);h.visitTimestampMicrosecond=M(qf);h.visitTimestampNanosecond=M(rf);h.visitTime=M(xf);h.visitTimeSecond=M(tf);h.visitTimeMillisecond=M(uf);h.visitTimeMicrosecond=M(vf);h.visitTimeNanosecond=M(wf);
h.visitDecimal=M(yf);h.visitList=M((a,b,c)=>{const d=a.children[0];a=a.valueOffsets;const e=Df.getVisitFn(d);if(Array.isArray(c))for(let f=-1,g=a[b],k=a[b+1];g<k;)e(d,g++,c[++f]);else for(let f=-1,g=a[b],k=a[b+1];g<k;)e(d,g++,c.get(++f))});h.visitStruct=M((a,b,c)=>{const d=a.type.children.map(f=>Df.getVisitFn(f.type)),e=c instanceof Map?Bf(b,c):c instanceof N?Af(b,c):Array.isArray(c)?zf(b,c):Cf(b,c);a.type.children.forEach((f,g)=>e(d[g],a.children[g],f,g))});
h.visitUnion=M((a,b,c)=>{a.type.mode===x.Dense?Ef(a,b,c):Ff(a,b,c)});h.visitDenseUnion=M(Ef);h.visitSparseUnion=M(Ff);h.visitDictionary=M((a,b,c)=>{let d;(d=a.dictionary)==null||d.set(a.values[b],c)});h.visitInterval=M(Jf);h.visitIntervalDayTime=M(Hf);h.visitIntervalYearMonth=M(Gf);h.visitIntervalMonthDayNano=M(If);h.visitDuration=M(Of);h.visitDurationSecond=M(Kf);h.visitDurationMillisecond=M(Lf);h.visitDurationMicrosecond=M(Mf);h.visitDurationNanosecond=M(Nf);
h.visitFixedSizeList=M((a,b,c)=>{const d=a.stride;a=a.children[0];const e=Df.getVisitFn(a);if(Array.isArray(c))for(let f=-1,g=b*d;++f<d;)e(a,g+f,c[f]);else for(let f=-1,g=b*d;++f<d;)e(a,g+f,c.get(f))});h.visitMap=M((a,b,c)=>{const d=a.children[0],e=a.valueOffsets;a=Df.getVisitFn(d);let {[b]:f,[b+1]:g}=e;b=c instanceof Map?c.entries():Object.entries(c);for(const k of b)if(a(d,f,k),++f>=g)break});const Df=new cf;const Pf=Symbol.for("parent"),Qf=Symbol.for("rowIndex");
class Rf{constructor(a,b){this[Pf]=a;this[Qf]=b;return new Proxy(this,Sf)}toArray(){return Object.values(this.toJSON())}toJSON(){const a=this[Qf],b=this[Pf],c=b.type.children,d={};for(let e=-1,f=c.length;++e<f;)d[c[e].name]=Tf.visit(b.children[e],a);return d}toString(){return`{${[...this].map(([a,b])=>`${uc(a)}: ${uc(b)}`).join(", ")}}`}[Symbol.for("nodejs.util.inspect.custom")](){return this.toString()}[Symbol.iterator](){return new Uf(this[Pf],this[Qf])}}
class Uf{constructor(a,b){this.Ib=0;this.children=a.children;this.rowIndex=b;this.Hb=a.type.children;this.numChildren=this.Hb.length}[Symbol.iterator](){return this}next(){const a=this.Ib;return a<this.numChildren?(this.Ib=a+1,{done:!1,value:[this.Hb[a].name,Tf.visit(this.children[a],this.rowIndex)]}):{done:!0,value:null}}}
Object.defineProperties(Rf.prototype,{[Symbol.toStringTag]:{enumerable:!1,configurable:!1,value:"Row"},[Pf]:{writable:!0,enumerable:!1,configurable:!1,value:null},[Qf]:{writable:!0,enumerable:!1,configurable:!1,value:-1}});
class Vf{isExtensible(){return!1}deleteProperty(){return!1}preventExtensions(){return!0}ownKeys(a){return a[Pf].type.children.map(b=>b.name)}has(a,b){return a[Pf].type.children.some(c=>c.name===b)}getOwnPropertyDescriptor(a,b){if(a[Pf].type.children.some(c=>c.name===b))return{writable:!0,enumerable:!0,configurable:!0}}get(a,b){if(Reflect.has(a,b))return a[b];var c=a[Pf].type.children.findIndex(d=>d.name===b);if(c!==-1)return c=Tf.visit(a[Pf].children[c],a[Qf]),Reflect.set(a,b,c),c}set(a,b,c){const d=
a[Pf].type.children.findIndex(e=>e.name===b);return d!==-1?(Df.visit(a[Pf].children[d],a[Qf],c),Reflect.set(a,b,c)):Reflect.has(a,b)||typeof b==="symbol"?Reflect.set(a,b,c):!1}}const Sf=new Vf;class Wf extends Ue{}function O(a){return(b,c)=>b.getValid(c)?a(b,c):null}
const Xf=(a,b,c)=>{if(c+1>=b.length)return null;const d=K(b[c]);b=K(b[c+1]);return a.subarray(d,b)},Yf=({values:a},b)=>864E5*a[b],Zf=({values:a},b)=>K(a[b]),$f=({stride:a,values:b},c)=>b[a*c],ag=({values:a},b)=>a[b],bg=({values:a,valueOffsets:b},c)=>Xf(a,b,c),cg=({values:a,valueOffsets:b},c)=>{a=Xf(a,b,c);return a!==null?wa(a):null},dg=({values:a},b)=>1E3*K(a[b]),eg=({values:a},b)=>K(a[b]),fg=({values:a},b)=>wc(a[b],BigInt(1E3)),gg=({values:a},b)=>wc(a[b],BigInt(1E6)),hg=({values:a},b)=>a[b],ig=({values:a},
b)=>a[b],jg=({values:a},b)=>a[b],kg=({values:a},b)=>a[b],lg=(a,b)=>Tf.visit(a.children[a.type.typeIdToChildIndex[a.typeIds[b]]],a.valueOffsets[b]),mg=(a,b)=>Tf.visit(a.children[a.type.typeIdToChildIndex[a.typeIds[b]]],b),ng=({values:a},b)=>a.subarray(2*b,2*(b+1)),og=({values:a},b)=>{a=a[b];b=new Int32Array(2);b[0]=Math.trunc(a/12);b[1]=Math.trunc(a%12);return b},pg=({values:a},b)=>a.subarray(4*b,4*(b+1)),qg=({values:a},b)=>a[b],rg=({values:a},b)=>a[b],sg=({values:a},b)=>a[b],tg=({values:a},b)=>a[b];
h=Wf.prototype;h.visitNull=O(()=>null);h.visitBool=O(({offset:a,values:b},c)=>{a+=c;return(b[a>>3]&1<<a%8)!==0});h.visitInt=O(({values:a},b)=>a[b]);h.visitInt8=O($f);h.visitInt16=O($f);h.visitInt32=O($f);h.visitInt64=O(ag);h.visitUint8=O($f);h.visitUint16=O($f);h.visitUint32=O($f);h.visitUint64=O(ag);h.visitFloat=O(({type:a,values:b},c)=>a.precision!==y.HALF?b[c]:$e(b[c]));h.visitFloat16=O(({stride:a,values:b},c)=>$e(b[a*c]));h.visitFloat32=O($f);h.visitFloat64=O($f);h.visitUtf8=O(cg);
h.visitLargeUtf8=O(cg);h.visitBinary=O(bg);h.visitLargeBinary=O(bg);h.visitFixedSizeBinary=O(({stride:a,values:b},c)=>b.subarray(a*c,a*(c+1)));h.visitDate=O((a,b)=>a.type.unit===Ya.DAY?Yf(a,b):Zf(a,b));h.visitDateDay=O(Yf);h.visitDateMillisecond=O(Zf);h.visitTimestamp=O((a,b)=>{switch(a.type.unit){case z.SECOND:return dg(a,b);case z.MILLISECOND:return eg(a,b);case z.MICROSECOND:return fg(a,b);case z.NANOSECOND:return gg(a,b)}});h.visitTimestampSecond=O(dg);h.visitTimestampMillisecond=O(eg);
h.visitTimestampMicrosecond=O(fg);h.visitTimestampNanosecond=O(gg);h.visitTime=O((a,b)=>{switch(a.type.unit){case z.SECOND:return hg(a,b);case z.MILLISECOND:return ig(a,b);case z.MICROSECOND:return jg(a,b);case z.NANOSECOND:return kg(a,b)}});h.visitTimeSecond=O(hg);h.visitTimeMillisecond=O(ig);h.visitTimeMicrosecond=O(jg);h.visitTimeNanosecond=O(kg);h.visitDecimal=O(({values:a,stride:b},c)=>new Ec(a.subarray(b*c,b*(c+1))));
h.visitList=O((a,b)=>{const c=a.stride,d=a.children,{[b*c]:e,[b*c+1]:f}=a.valueOffsets;a=d[0].slice(e,f-e);return new N([a])});h.visitStruct=O((a,b)=>new Rf(a,b));h.visitUnion=O((a,b)=>a.type.mode===x.Dense?lg(a,b):mg(a,b));h.visitDenseUnion=O(lg);h.visitSparseUnion=O(mg);h.visitDictionary=O((a,b)=>{let c;return(c=a.dictionary)==null?void 0:c.get(a.values[b])});h.visitInterval=O((a,b)=>a.type.unit===A.MONTH_DAY_NANO?pg(a,b):a.type.unit===A.DAY_TIME?ng(a,b):og(a,b));h.visitIntervalDayTime=O(ng);
h.visitIntervalYearMonth=O(og);h.visitIntervalMonthDayNano=O(pg);h.visitDuration=O((a,b)=>{switch(a.type.unit){case z.SECOND:return qg(a,b);case z.MILLISECOND:return rg(a,b);case z.MICROSECOND:return sg(a,b);case z.NANOSECOND:return tg(a,b)}});h.visitDurationSecond=O(qg);h.visitDurationMillisecond=O(rg);h.visitDurationMicrosecond=O(sg);h.visitDurationNanosecond=O(tg);h.visitFixedSizeList=O((a,b)=>{const c=a.stride;a=a.children[0].slice(b*c,c);return new N([a])});
h.visitMap=O((a,b)=>{const c=a.children,{[b]:d,[b+1]:e}=a.valueOffsets;return new ug(c[0].slice(d,e-d))});const Tf=new Wf;const vg=Symbol.for("keys"),wg=Symbol.for("vals"),xg=Symbol.for("kKeysAsStrings"),yg=Symbol.for("_kKeysAsStrings");
class ug{constructor(a){this[vg]=(new N([a.children[0]])).memoize();this[wg]=a.children[1];return new Proxy(this,new zg)}get [xg](){return this[yg]||(this[yg]=Array.from(this[vg].toArray(),String))}[Symbol.iterator](){return new Ag(this[vg],this[wg])}get size(){return this[vg].length}toArray(){return Object.values(this.toJSON())}toJSON(){const a=this[vg],b=this[wg],c={};for(let d=-1,e=a.length;++d<e;)c[a.get(d)]=Tf.visit(b,d);return c}toString(){return`{${[...this].map(([a,b])=>`${uc(a)}: ${uc(b)}`).join(", ")}}`}[Symbol.for("nodejs.util.inspect.custom")](){return this.toString()}}
class Ag{constructor(a,b){this.keys=a;this.rc=b;this.Ob=0;this.nc=a.length}[Symbol.iterator](){return this}next(){const a=this.Ob;if(a===this.nc)return{done:!0,value:null};this.Ob++;return{done:!1,value:[this.keys.get(a),Tf.visit(this.rc,a)]}}}
class zg{isExtensible(){return!1}deleteProperty(){return!1}preventExtensions(){return!0}ownKeys(a){return a[xg]}has(a,b){return a[xg].includes(b)}getOwnPropertyDescriptor(a,b){if(a[xg].indexOf(b)!==-1)return{writable:!0,enumerable:!0,configurable:!0}}get(a,b){if(Reflect.has(a,b))return a[b];var c=a[xg].indexOf(b);if(c!==-1)return c=Tf.visit(Reflect.get(a,wg),c),Reflect.set(a,b,c),c}set(a,b,c){const d=a[xg].indexOf(b);return d!==-1?(Df.visit(Reflect.get(a,wg),d,c),Reflect.set(a,b,c)):Reflect.has(a,
b)?Reflect.set(a,b,c):!1}}Object.defineProperties(ug.prototype,{[Symbol.toStringTag]:{enumerable:!1,configurable:!1,value:"Row"},[vg]:{writable:!0,enumerable:!1,configurable:!1,value:null},[wg]:{writable:!0,enumerable:!1,configurable:!1,value:null},[yg]:{writable:!0,enumerable:!1,configurable:!1,value:null}});let Bg;function Cg(a,b,c,d){const {length:e=0}=a;b=typeof b!=="number"?0:b;c=typeof c!=="number"?e:c;b<0&&(b=(b%e+e)%e);c<0&&(c=(c%e+e)%e);c<b&&(Bg=b,b=c,c=Bg);c>e&&(c=e);return d?d(a,b,c):[b,c]}const Dg=a=>a!==a;function Eg(a){if(typeof a!=="object"||a===null)return a!==a?Dg:b=>b===a;if(a instanceof Date){const b=a.valueOf();return c=>c instanceof Date?c.valueOf()===b:!1}return ArrayBuffer.isView(a)?b=>b?Ka(a,b):!1:a instanceof Map?Fg(a):Array.isArray(a)?Gg(a):a instanceof N?Hg(a):Ig(a)}
function Gg(a){const b=[];for(let c=-1,d=a.length;++c<d;)b[c]=Eg(a[c]);return Jg(b)}function Fg(a){let b=-1;const c=[];for(const d of a.values())c[++b]=Eg(d);return Jg(c)}function Hg(a){const b=[];for(let c=-1,d=a.length;++c<d;)b[c]=Eg(a.get(c));return Jg(b)}function Ig(a){const b=Object.keys(a),c=[];for(let d=-1,e=b.length;++d<e;)c[d]=Eg(a[b[d]]);return Jg(c,b)}
function Jg(a,b){return c=>{if(!c||typeof c!=="object")return!1;switch(c.constructor){case Array:a:{var d=a.length;if(c.length!==d)c=!1;else{for(var e=-1;++e<d;)if(!a[e](c[e])){c=!1;break a}c=!0}}return c;case Map:return Kg(a,c,c.keys());case ug:case Rf:case Object:case void 0:return Kg(a,c,b||Object.keys(c))}if(c instanceof N)a:if(d=a.length,c.length!==d)c=!1;else{for(e=-1;++e<d;)if(!a[e](c.get(e))){c=!1;break a}c=!0}else c=!1;return c}}
function Kg(a,b,c){c=c[Symbol.iterator]();const d=b instanceof Map?b.keys():Object.keys(b)[Symbol.iterator]();b=b instanceof Map?b.values():Object.values(b)[Symbol.iterator]();let e=0;const f=a.length;let g=b.next(),k=c.next(),m=d.next();for(;e<f&&!k.done&&!m.done&&!g.done&&k.value===m.value&&a[e](g.value);++e,k=c.next(),m=d.next(),g=b.next());if(e===f&&k.done&&m.done&&g.done)return!0;c.return&&c.return();d.return&&d.return();b.return&&b.return();return!1}var Lg={};Lg.clampRange=Cg;
Lg.createElementComparator=Eg;Lg.wrapIndex=(a,b)=>a<0?b+a:a;function Mg(a,b,c,d){return(c&1<<d)!==0}function Ng(a,b,c,d){return(c&1<<d)>>d}function Og(a,b,c){const d=c.byteLength+7&-8;if(a>0||c.byteLength<d){const e=new Uint8Array(d);e.set(a%8===0?c.subarray(a>>3):Pg(new Qg(c,a,b,null,Mg)).subarray(0,d));return e}return c}function Pg(a){const b=[];let c=0,d=0,e=0;for(const f of a)f&&(e|=1<<d),++d===8&&(b[c++]=e,e=d=0);if(c===0||d>0)b[c++]=e;a=new Uint8Array(b.length+7&-8);a.set(b);return a}
class Qg{constructor(a,b,c,d,e){this.bytes=a;this.length=c;this.context=d;this.get=e;this.gb=b%8;this.Gb=b>>3;this.Fb=a[this.Gb++];this.index=0}next(){return this.index<this.length?(this.gb===8&&(this.gb=0,this.Fb=this.bytes[this.Gb++]),{value:this.get(this.context,this.index++,this.Fb,this.gb++)}):{done:!0,value:null}}[Symbol.iterator](){return this}}
function Rg(a,b,c){if(c-b<=0)return 0;if(c-b<8){var d=0;for(var e of new Qg(a,b,c-b,a,Ng))d+=e;return d}d=c>>3<<3;e=b+(b%8===0?0:8-b%8);return Rg(a,b,e)+Rg(a,d,c)+Sg(a,e>>3,d-e>>3)}function Sg(a,b,c){let d=0;b=Math.trunc(b);const e=new DataView(a.buffer,a.byteOffset,a.byteLength);for(a=c===void 0?a.byteLength:b+c;a-b>=4;)d+=Tg(e.getUint32(b)),b+=4;for(;a-b>=2;)d+=Tg(e.getUint16(b)),b+=2;for(;a-b>=1;)d+=Tg(e.getUint8(b)),b+=1;return d}
function Tg(a){a=Math.trunc(a);a-=a>>>1&1431655765;a=(a&858993459)+(a>>>2&858993459);return(a+(a>>>4)&252645135)*16843009>>>24}var Ug={};Ug.BitIterator=Qg;Ug.getBit=Ng;Ug.getBool=Mg;Ug.packBools=Pg;Ug.popcnt_array=Sg;Ug.popcnt_bit_range=Rg;Ug.popcnt_uint32=Tg;Ug.setBool=function(a,b,c){return c?!!(a[b>>3]|=1<<b%8)||!0:!(a[b>>3]&=~(1<<b%8))&&!1};Ug.truncateBitmap=Og;function Vg(a,b,c){return a.map(d=>d.slice(b,c))}function Wg(a,b){if(a.typeId===I.Null)return a.clone(a.type,0,b,0);const c=a.length,d=a.nullCount,e=(new Uint8Array((b+63&-64)>>3)).fill(255,0,c>>3);e[c>>3]=(1<<c-(c&-8))-1;d>0&&e.set(Og(a.offset,c,a.nullBitmap),0);const f=a.buffers;f[sc.VALIDITY]=e;return a.clone(a.type,0,b,d+(b-c),f)}
class P{get typeId(){return this.type.typeId}get ArrayType(){return this.type.ArrayType}get buffers(){return[this.valueOffsets,this.values,this.nullBitmap,this.typeIds]}get nullable(){if(this.R!==0){const a=this.type;return L.isSparseUnion(a)?this.children.some(b=>b.nullable):L.isDenseUnion(a)?this.children.some(b=>b.nullable):this.nullBitmap&&this.nullBitmap.byteLength>0}return!0}get byteLength(){let a=0;const b=this.valueOffsets,c=this.values,d=this.nullBitmap,e=this.typeIds;b&&(a+=b.byteLength);
c&&(a+=c.byteLength);d&&(a+=d.byteLength);e&&(a+=e.byteLength);return this.children.reduce((f,g)=>f+g.byteLength,a)}get nullCount(){if(L.isUnion(this.type))return this.children.reduce((c,d)=>c+d.nullCount,0);let a=this.R,b;a<=-1&&(b=this.nullBitmap)&&(this.R=a=b.length===0?0:this.length-Rg(b,this.offset,this.offset+this.length));return a}constructor(a,b,c,d,e,f=[],g){this.type=a;this.children=f;this.dictionary=g;this.offset=Math.floor(Math.max(b||0,0));this.length=Math.floor(Math.max(c||0,0));this.R=
Math.floor(Math.max(d||0,-1));let k;e instanceof P?(this.stride=e.stride,this.values=e.values,this.typeIds=e.typeIds,this.nullBitmap=e.nullBitmap,this.valueOffsets=e.valueOffsets):(this.stride=Te(a),e&&((k=e[0])&&(this.valueOffsets=k),(k=e[1])&&(this.values=k),(k=e[2])&&(this.nullBitmap=k),(k=e[3])&&(this.typeIds=k)))}getValid(a){const b=this.type;return L.isUnion(b)?this.children[b.typeIdToChildIndex[this.typeIds[a]]].getValid(b.mode===x.Dense?this.valueOffsets[a]:a):this.nullable&&this.nullCount>
0?(a=this.offset+a,(this.nullBitmap[a>>3]&1<<a%8)!==0):!0}setValid(a,b){var c=this.type;if(L.isUnion(c)){var d=this.children[c.typeIdToChildIndex[this.typeIds[a]]];a=c.mode===x.Dense?this.valueOffsets[a]:a;c=d.getValid(a);d.setValid(a,b)}else{({nullBitmap:d}=this);c=this.offset;var e=this.length,f=c+a;a=1<<f%8;f>>=3;if(!d||d.byteLength<=f)d=(new Uint8Array((c+e+63&-64)>>3)).fill(255),this.nullCount>0?(d.set(Og(c,e,this.nullBitmap),0),Object.assign(this,{nullBitmap:d})):Object.assign(this,{nullBitmap:d,
R:0});e=d[f];c=(e&a)!==0;d[f]=b?e|a:e&~a}c!==!!b&&(this.R=this.nullCount+(b?-1:1));return b}clone(a=this.type,b=this.offset,c=this.length,d=this.R,e=this,f=this.children){return new P(a,b,c,d,e,f,this.dictionary)}slice(a,b){const c=this.stride,d=this.typeId,e=this.children,f=+(this.R===0)-1,g=d===16?c:1;let k;const m=this.buffers;(k=m[sc.TYPE])&&(m[sc.TYPE]=k.subarray(a,a+b));(k=m[sc.OFFSET])&&(m[sc.OFFSET]=k.subarray(a,a+b+1))||(k=m[sc.DATA])&&(m[sc.DATA]=d===6?k:k.subarray(c*a,c*(a+b)));return this.clone(this.type,
this.offset+a,b,f,m,e.length===0||this.valueOffsets?e:Vg(e,g*a,g*b))}}P.prototype.children=Object.freeze([]);
class Xg extends Ue{visit(a){return this.getVisitFn(a.type).call(this,a)}visitNull(a){const {type:b,offset:c=0,length:d=0}=a;return new P(b,c,d,d)}visitBool(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.ArrayType,a.data),{length:f=e.length>>3,nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,e,d])}visitInt(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.ArrayType,a.data),{length:f=e.length,nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,
e,d])}visitFloat(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.ArrayType,a.data),{length:f=e.length,nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,e,d])}visitUtf8(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.data),e=u(Uint8Array,a.nullBitmap),f=u(Int32Array,a.valueOffsets),{length:g=f.length-1,nullCount:k=a.nullBitmap?-1:0}=a;return new P(b,c,g,k,[f,d,e])}visitLargeUtf8(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.data),e=u(Uint8Array,a.nullBitmap),f=u(BigInt64Array,
a.valueOffsets),{length:g=f.length-1,nullCount:k=a.nullBitmap?-1:0}=a;return new P(b,c,g,k,[f,d,e])}visitBinary(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.data),e=u(Uint8Array,a.nullBitmap),f=u(Int32Array,a.valueOffsets),{length:g=f.length-1,nullCount:k=a.nullBitmap?-1:0}=a;return new P(b,c,g,k,[f,d,e])}visitLargeBinary(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.data),e=u(Uint8Array,a.nullBitmap),f=u(BigInt64Array,a.valueOffsets),{length:g=f.length-1,nullCount:k=a.nullBitmap?-1:0}=a;return new P(b,
c,g,k,[f,d,e])}visitFixedSizeBinary(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.ArrayType,a.data),{length:f=e.length/Te(b),nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,e,d])}visitDate(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.ArrayType,a.data),{length:f=e.length/Te(b),nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,e,d])}visitTimestamp(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.ArrayType,a.data),{length:f=
e.length/Te(b),nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,e,d])}visitTime(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.ArrayType,a.data),{length:f=e.length/Te(b),nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,e,d])}visitDecimal(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.ArrayType,a.data),{length:f=e.length/Te(b),nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,e,d])}visitList(a){const {type:b,offset:c=0,child:d}=
a,e=u(Uint8Array,a.nullBitmap),f=u(Int32Array,a.valueOffsets),{length:g=f.length-1,nullCount:k=a.nullBitmap?-1:0}=a;return new P(b,c,g,k,[f,void 0,e],[d])}visitStruct(a){const {type:b,offset:c=0,children:d=[]}=a,e=u(Uint8Array,a.nullBitmap),{length:f=d.reduce((k,{length:m})=>Math.max(k,m),0),nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,void 0,e],d)}visitUnion(a){const {type:b,offset:c=0,children:d=[]}=a,e=u(b.ArrayType,a.typeIds),{length:f=e.length,nullCount:g=-1}=a;if(L.isSparseUnion(b))return new P(b,
c,f,g,[void 0,void 0,void 0,e],d);a=u(Int32Array,a.valueOffsets);return new P(b,c,f,g,[a,void 0,void 0,e],d)}visitDictionary(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.indices.ArrayType,a.data),{dictionary:f=new N([(new Xg).visit({type:b.dictionary})])}=a,{length:g=e.length,nullCount:k=a.nullBitmap?-1:0}=a;return new P(b,c,g,k,[void 0,e,d],[],f)}visitInterval(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.ArrayType,a.data),{length:f=e.length/Te(b),nullCount:g=
a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,e,d])}visitDuration(a){const {type:b,offset:c=0}=a,d=u(Uint8Array,a.nullBitmap),e=u(b.ArrayType,a.data),{length:f=e.length,nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,e,d])}visitFixedSizeList(a){const {type:b,offset:c=0,child:d=(new Xg).visit({type:b.valueType})}=a,e=u(Uint8Array,a.nullBitmap),{length:f=d.length/Te(b),nullCount:g=a.nullBitmap?-1:0}=a;return new P(b,c,f,g,[void 0,void 0,e],[d])}visitMap(a){const {type:b,offset:c=0,
child:d=(new Xg).visit({type:b.childType})}=a,e=u(Uint8Array,a.nullBitmap),f=u(Int32Array,a.valueOffsets),{length:g=f.length-1,nullCount:k=a.nullBitmap?-1:0}=a;return new P(b,c,g,k,[f,void 0,e],[d])}}const Yg=new Xg;function Q(a){return Yg.visit(a)};class Zg{constructor(a=0,b){this.Pb=a;this.Mb=b;this.ib=0;this.Jb=this.Mb(0)}next(){for(;this.ib<this.Pb;){const a=this.Jb.next();if(!a.done)return a;++this.ib<this.Pb&&(this.Jb=this.Mb(this.ib))}return{done:!0,value:null}}[Symbol.iterator](){return this}}function $g(a){return a.some(b=>b.nullable)}function ah(a){return a.reduce((b,c)=>b+c.nullCount,0)}function bh(a){return a.reduce((b,c,d)=>{b[d+1]=b[d]+c.length;return b},new Uint32Array(a.length+1))}
function ch(a,b,c,d){const e=[];for(let f=-1,g=a.length;++f<g;){const k=a[f],m=b[f],p=k.length;if(m>=d)break;if(c>=m+p)continue;if(m>=c&&m+p<=d){e.push(k);continue}const r=Math.max(0,c-m);e.push(k.slice(r,Math.min(d-m,p)-r))}e.length===0&&e.push(a[0].slice(0,0));return e}function dh(a,b,c,d){let e=0,f,g=b.length-1;do{if(e>=g-1)return c<b[g]?d(a,e,c-b[e]):null;f=e+Math.trunc((g-e)*.5);c<b[f]?g=f:e=f}while(e<g)}function eh(a,b){return a.getValid(b)}
function fh(a){function b(c,d,e){return a(c[d],e)}return function(c){return dh(this.data,this.j,c,b)}}function gh(a){function b(d,e,f){return a(d[e],f,c)}let c;return function(d,e){const f=this.data;c=e;d=dh(f,this.j,d,b);c=void 0;return d}}function hh(a){function b(d,e,f){var g=f;f=0;for(let k=e-1,m=d.length;++k<m;){e=d[k];if(~(g=a(e,c,g)))return f+g;g=0;f+=e.length}return-1}let c;return function(d,e){c=d;d=this.data;e=typeof e!=="number"?b(d,0,0):dh(d,this.j,e,b);c=void 0;return e}};class ih extends Ue{}function R(a,b,c){if(b===void 0)return-1;if(b===null)switch(a.typeId){case I.Union:break;case I.Dictionary:break;default:a:{const e=a.nullBitmap;if(e&&!(a.nullCount<=0)){b=0;for(var d of new Qg(e,a.offset+(c||0),a.length,e,Mg)){if(!d){a=b;break a}++b}}a=-1}return a}d=Tf.getVisitFn(a);b=Eg(b);for(let e=(c||0)-1,f=a.length;++e<f;)if(b(d(a,e)))return e;return-1}
function jh(a,b,c){const d=Tf.getVisitFn(a);b=Eg(b);for(let e=(c||0)-1,f=a.length;++e<f;)if(b(d(a,e)))return e;return-1}h=ih.prototype;h.visitNull=function(a,b){return b===null&&a.length>0?0:-1};h.visitBool=R;h.visitInt=R;h.visitInt8=R;h.visitInt16=R;h.visitInt32=R;h.visitInt64=R;h.visitUint8=R;h.visitUint16=R;h.visitUint32=R;h.visitUint64=R;h.visitFloat=R;h.visitFloat16=R;h.visitFloat32=R;h.visitFloat64=R;h.visitUtf8=R;h.visitLargeUtf8=R;h.visitBinary=R;h.visitLargeBinary=R;
h.visitFixedSizeBinary=R;h.visitDate=R;h.visitDateDay=R;h.visitDateMillisecond=R;h.visitTimestamp=R;h.visitTimestampSecond=R;h.visitTimestampMillisecond=R;h.visitTimestampMicrosecond=R;h.visitTimestampNanosecond=R;h.visitTime=R;h.visitTimeSecond=R;h.visitTimeMillisecond=R;h.visitTimeMicrosecond=R;h.visitTimeNanosecond=R;h.visitDecimal=R;h.visitList=R;h.visitStruct=R;h.visitUnion=R;h.visitDenseUnion=jh;h.visitSparseUnion=jh;h.visitDictionary=R;h.visitInterval=R;h.visitIntervalDayTime=R;
h.visitIntervalYearMonth=R;h.visitIntervalMonthDayNano=R;h.visitDuration=R;h.visitDurationSecond=R;h.visitDurationMillisecond=R;h.visitDurationMicrosecond=R;h.visitDurationNanosecond=R;h.visitFixedSizeList=R;h.visitMap=R;const kh=new ih;class lh extends Ue{}function S(a){const b=a.type;if(a.nullCount===0&&a.stride===1&&(L.isInt(b)&&b.bitWidth!==64||L.isTime(b)&&b.bitWidth!==64||L.isFloat(b)&&b.precision!==y.HALF))return new Zg(a.data.length,d=>{d=a.data[d];return d.values.subarray(0,d.length)[Symbol.iterator]()});let c=0;return new Zg(a.data.length,d=>{d=a.data[d].length;const e=a.slice(c,c+d);c+=d;return new mh(e)})}
class mh{constructor(a){this.Qb=a;this.index=0}next(){return this.index<this.Qb.length?{value:this.Qb.get(this.index++)}:{done:!0,value:null}}[Symbol.iterator](){return this}}h=lh.prototype;h.visitNull=S;h.visitBool=S;h.visitInt=S;h.visitInt8=S;h.visitInt16=S;h.visitInt32=S;h.visitInt64=S;h.visitUint8=S;h.visitUint16=S;h.visitUint32=S;h.visitUint64=S;h.visitFloat=S;h.visitFloat16=S;h.visitFloat32=S;h.visitFloat64=S;h.visitUtf8=S;h.visitLargeUtf8=S;h.visitBinary=S;h.visitLargeBinary=S;
h.visitFixedSizeBinary=S;h.visitDate=S;h.visitDateDay=S;h.visitDateMillisecond=S;h.visitTimestamp=S;h.visitTimestampSecond=S;h.visitTimestampMillisecond=S;h.visitTimestampMicrosecond=S;h.visitTimestampNanosecond=S;h.visitTime=S;h.visitTimeSecond=S;h.visitTimeMillisecond=S;h.visitTimeMicrosecond=S;h.visitTimeNanosecond=S;h.visitDecimal=S;h.visitList=S;h.visitStruct=S;h.visitUnion=S;h.visitDenseUnion=S;h.visitSparseUnion=S;h.visitDictionary=S;h.visitInterval=S;h.visitIntervalDayTime=S;
h.visitIntervalYearMonth=S;h.visitIntervalMonthDayNano=S;h.visitDuration=S;h.visitDurationSecond=S;h.visitDurationMillisecond=S;h.visitDurationMicrosecond=S;h.visitDurationNanosecond=S;h.visitFixedSizeList=S;h.visitMap=S;const nh=new lh;const oh={},ph={};
class N{constructor(a){a=a[0]instanceof N?a.flatMap(f=>f.data):a;if(a.length===0||a.some(f=>!(f instanceof P)))throw new TypeError("Vector constructor expects an Array of Data instances.");let b;const c=(b=a[0])==null?void 0:b.type;switch(a.length){case 0:this.j=[0];break;case 1:const {get:f,set:g,indexOf:k}=oh[c.typeId],m=a[0];this.isValid=p=>m.getValid(p);this.get=p=>f(m,p);this.set=(p,r)=>g(m,p,r);this.indexOf=p=>k(m,p);this.j=[0,m.length];break;default:Object.setPrototypeOf(this,ph[c.typeId]),
this.j=bh(a)}this.data=a;this.type=c;this.stride=Te(c);let d,e;this.numChildren=(e=(d=c.children)==null?void 0:d.length)!=null?e:0;this.length=this.j.at(-1)}get byteLength(){return this.data.reduce((a,b)=>a+b.byteLength,0)}get nullable(){return $g(this.data)}get nullCount(){return ah(this.data)}get ArrayType(){return this.type.ArrayType}get [Symbol.toStringTag](){return`${this.VectorName}<${this.type[Symbol.toStringTag]}>`}get VectorName(){return`${I[this.type.typeId]}Vector`}isValid(){return!1}get(){return null}at(a){return this.get(a<
0?this.length+a:a)}set(){}indexOf(){return-1}includes(a,b){return this.indexOf(a,b)>-1}[Symbol.iterator](){return nh.visit(this)}concat(...a){return new N(this.data.concat(a.flatMap(b=>b.data).flat(Number.POSITIVE_INFINITY)))}slice(a,b){return new N(Cg(this,a,b,({data:c,j:d},e,f)=>ch(c,d,e,f)))}toJSON(){return[...this]}toArray(){const a=this.data,b=this.length,c=this.stride,d=this.ArrayType;switch(this.type.typeId){case I.Int:case I.Float:case I.Decimal:case I.Time:case I.Timestamp:switch(a.length){case 0:return new d;
case 1:return a[0].values.subarray(0,b*c);default:return a.reduce((e,{values:f,length:g})=>{e.Db.set(f.subarray(0,g*c),e.offset);e.offset+=g*c;return e},{Db:new d(b*c),offset:0}).Db}}return[...this]}toString(){return`[${[...this].join()}]`}getChild(a){let b;return this.getChildAt((b=this.type.children)==null?void 0:b.findIndex(c=>c.name===a))}getChildAt(a){return a>-1&&a<this.numChildren?new N(this.data.map(({children:b})=>b[a])):null}get isMemoized(){return L.isDictionary(this.type)?this.data[0].dictionary.isMemoized:
!1}memoize(){if(L.isDictionary(this.type)){const a=new qh(this.data[0].dictionary),b=this.data.map(c=>{c=c.clone();c.dictionary=a;return c});return new N(b)}return new qh(this)}unmemoize(){if(L.isDictionary(this.type)&&this.isMemoized){const a=this.data[0].dictionary.unmemoize(),b=this.data.map(c=>{c=c.clone();c.dictionary=a;return c});return new N(b)}return this}}
N[Symbol.toStringTag]=(a=>{a.type=L.prototype;a.data=[];a.length=0;a.stride=1;a.numChildren=0;a.j=new Uint32Array([0]);a[Symbol.isConcatSpreadable]=!0;var b=Object.keys(I).map(c=>I[c]).filter(c=>typeof c==="number"&&c!==I.NONE);for(const c of b){b=Tf.getVisitFnByTypeId(c);const d=Df.getVisitFnByTypeId(c),e=kh.getVisitFnByTypeId(c);oh[c]={get:b,set:d,indexOf:e};ph[c]=Object.create(a,{isValid:{value:fh(eh)},get:{value:fh(Tf.getVisitFnByTypeId(c))},set:{value:gh(Df.getVisitFnByTypeId(c))},indexOf:{value:hh(kh.getVisitFnByTypeId(c))}})}return"Vector"})(N.prototype);
class qh extends N{constructor(a){super(a.data);const b=this.get,c=this.set,d=this.slice,e=Array(this.length);Object.defineProperty(this,"get",{value(f){var g=e[f];if(g!==void 0)return g;g=b.call(this,f);return e[f]=g}});Object.defineProperty(this,"set",{value(f,g){c.call(this,f,g);e[f]=g}});Object.defineProperty(this,"slice",{value:(f,g)=>new qh(d.call(this,f,g))});Object.defineProperty(this,"isMemoized",{value:!0});Object.defineProperty(this,"unmemoize",{value:()=>new N(this.data)});Object.defineProperty(this,
"memoize",{value:()=>this})}}
function rh(a){if(a){if(a instanceof P)return new N([a]);if(a instanceof N)return new N(a.data);if(a.type instanceof L)return new N([Q(a)]);if(Array.isArray(a))return new N(a.flatMap(b=>b instanceof P?[b]:b instanceof N?b.data:rh(b).data));if(ArrayBuffer.isView(a)){a instanceof DataView&&(a=new Uint8Array(a.buffer));const b={offset:0,length:a.length,nullCount:-1,data:a};if(a instanceof Int8Array)return new N([Q(Object.assign({},b,{type:new Sc}))]);if(a instanceof Int16Array)return new N([Q(Object.assign({},b,
{type:new Tc}))]);if(a instanceof Int32Array)return new N([Q(Object.assign({},b,{type:new Uc}))]);if(a instanceof BigInt64Array)return new N([Q(Object.assign({},b,{type:new Vc}))]);if(a instanceof Uint8Array||a instanceof Uint8ClampedArray)return new N([Q(Object.assign({},b,{type:new Wc}))]);if(a instanceof Uint16Array)return new N([Q(Object.assign({},b,{type:new Xc}))]);if(a instanceof Uint32Array)return new N([Q(Object.assign({},b,{type:new Yc}))]);if(a instanceof BigUint64Array)return new N([Q(Object.assign({},
b,{type:new Zc}))]);if(a instanceof Float32Array)return new N([Q(Object.assign({},b,{type:new ed}))]);if(a instanceof Float64Array)return new N([Q(Object.assign({},b,{type:new fd}))])}}throw Error("Unrecognized input");};function sh(a){if(!a||a.length<=0)return function(){return!0};let b="";const c=a.filter(d=>d===d);c.length>0&&(b=`
switch (x) {${c.map(d=>`
case ${typeof d!=="bigint"?uc(d):`${uc(d)}n`}:`).join("")}
return false;
}`);a.length!==c.length&&(b=`if (x !== x) return false;\n${b}`);return new Function("x",`${b}\nreturn true;`)};function th(a,b){a=Math.ceil(a)*b-1;return(a-a%64+64||64)/b}function uh(a,b=0){return a.length>=b?a.subarray(0,b):Da(new a.constructor(b),a,0)}function vh(a,b){if(b>0){a.length+=b;b=a.length*a.stride;const c=a.buffer.length;b>=c&&(a.buffer=uh(a.buffer,c===0?th(b*1,a.BYTES_PER_ELEMENT):th(b*2,a.BYTES_PER_ELEMENT)))}return a}
class wh{constructor(a,b=0,c=1){this.length=Math.ceil(b/c);this.buffer=new a(this.length);this.stride=c;this.BYTES_PER_ELEMENT=a.BYTES_PER_ELEMENT;this.ArrayType=a}get byteLength(){return Math.ceil(this.length*this.stride)*this.BYTES_PER_ELEMENT}get reservedLength(){return this.buffer.length/this.stride}get reservedByteLength(){return this.buffer.byteLength}set(){return this}append(a){return this.set(this.length,a)}flush(a=this.length){a=th(a*this.stride,this.BYTES_PER_ELEMENT);a=uh(this.buffer,a);
this.clear();return a}clear(){this.length=0;this.buffer=new this.ArrayType;return this}}class xh extends wh{get(a){return this.buffer[a]}set(a,b){vh(this,a-this.length+1);this.buffer[a*this.stride]=b;return this}}
class yh extends xh{constructor(){super(Uint8Array,0,.125);this.Pa=0}get mc(){return this.length-this.Pa}get(a){return this.buffer[a>>3]>>a%8&1}set(a,b){const {buffer:c}=vh(this,a-this.length+1),d=a>>3;a%=8;const e=c[d]>>a&1;b?e===0&&(c[d]|=1<<a,++this.Pa):e===1&&(c[d]&=~(1<<a),--this.Pa);return this}clear(){this.Pa=0;return super.clear()}}
class zh extends xh{constructor(a){super(a.OffsetArrayType,1,1)}append(a){return this.set(this.length-1,a)}set(a,b){const c=this.length-1,d=vh(this,a-c+1).buffer;c<a++&&c>=0&&d.fill(d[c],c,a);d[a]=d[a-1]+b;return this}flush(a=this.length-1){a>this.length&&this.set(a-1,this.BYTES_PER_ELEMENT>4?BigInt(0):0);return super.flush(a+1)}};class Ah{static throughNode(){throw Error('"throughNode" not available in this environment');}static throughDOM(){throw Error('"throughDOM" not available in this environment');}constructor({type:a,nullValues:b}){this.length=0;this.finished=!1;this.type=a;this.children=[];this.nullValues=b;this.stride=Te(a);this.G=new yh;b&&b.length>0&&(this.yb=sh(b))}toVector(){return new N([this.flush()])}get ArrayType(){return this.type.ArrayType}get nullCount(){return this.G.mc}get numChildren(){return this.children.length}get byteLength(){let a=
0;const b=this.j,c=this.o,d=this.G,e=this.ba,f=this.children;b&&(a+=b.byteLength);c&&(a+=c.byteLength);d&&(a+=d.byteLength);e&&(a+=e.byteLength);return f.reduce((g,k)=>g+k.byteLength,a)}get reservedLength(){return this.G.reservedLength}get reservedByteLength(){let a=0;this.j&&(a+=this.j.reservedByteLength);this.o&&(a+=this.o.reservedByteLength);this.G&&(a+=this.G.reservedByteLength);this.ba&&(a+=this.ba.reservedByteLength);return this.children.reduce((b,c)=>b+c.reservedByteLength,a)}get valueOffsets(){return this.j?
this.j.buffer:null}get values(){return this.o?this.o.buffer:null}get nullBitmap(){return this.G?this.G.buffer:null}get typeIds(){return this.ba?this.ba.buffer:null}append(a){return this.set(this.length,a)}isValid(a){return this.yb(a)}set(a,b){this.setValid(a,this.isValid(b))&&this.setValue(a,b);return this}setValue(a,b){this.B(this,a,b)}setValid(a,b){this.length=this.G.set(a,+b).length;return b}addChild(){throw Error(`Cannot append children to non-nested type "${this.type}"`);}getChildAt(a){return this.children[a]||
null}flush(){let a,b,c,d;const e=this.type,f=this.length,g=this.nullCount;var k=this.j;const m=this.o,p=this.G;let r;(b=(r=this.ba)==null?void 0:r.flush(f))?d=k==null?void 0:k.flush(f):a=(d=k==null?void 0:k.flush(f))?m==null?void 0:m.flush(k.get(k.length-1)):m==null?void 0:m.flush(f);g>0&&(c=p==null?void 0:p.flush(f));k=this.children.map(T=>T.flush());this.clear();return Q({type:e,length:f,nullCount:g,children:k,child:k[0],data:a,typeIds:b,nullBitmap:c,valueOffsets:d})}finish(){this.finished=!0;for(const a of this.children)a.finish();
return this}clear(){this.length=0;let a;(a=this.G)==null||a.clear();let b;(b=this.o)==null||b.clear();let c;(c=this.j)==null||c.clear();let d;(d=this.ba)==null||d.clear();for(const e of this.children)e.clear();return this}}h=Ah.prototype;h.length=1;h.stride=1;h.children=null;h.finished=!1;h.nullValues=null;h.yb=()=>!0;class Bh extends Ah{constructor(a){super(a);this.o=new xh(this.ArrayType,0,this.stride)}setValue(a,b){const c=this.o;vh(c,a-c.length+1);return super.setValue(a,b)}}
function Ch(a){const b=a.I,c=a.L;a.L=0;a.I=void 0;b&&b.size>0&&a.V(b,c)}
class Dh extends Ah{constructor(a){super(a);this.L=0;this.j=new zh(a.type)}setValue(a,b){const c=this.I||(this.I=new Map),d=c.get(a);d&&(this.L-=d.length);this.L+=b instanceof ug?b[vg].length:b.length;c.set(a,b)}setValid(a,b){return super.setValid(a,b)?!0:((this.I||(this.I=new Map)).set(a,void 0),!1)}clear(){this.L=0;this.I=void 0;return super.clear()}flush(){Ch(this);return super.flush()}finish(){Ch(this);return super.finish()}};class Eh{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}offset(){return fb(this.g,this.h)}jb(){return this.g.v(this.h+8)}bodyLength(){return fb(this.g,this.h+16)}};class Fh{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}version(){const a=B(this.g,this.h,4);return a?eb(this.g,this.h+a):w.V1}schema(a){const b=B(this.g,this.h,6);return b?(a||new mc).i(ib(this.g,this.h+b),this.g):null}dictionaries(a,b){const c=B(this.g,this.h,8);return c?(b||new Eh).i(jb(this.g,this.h+c)+a*24,this.g):null}ob(a){const b=B(this.g,this.h,10);return b?(new Eh).i(jb(this.g,this.h+b)+a*24,this.g):null}La(a){const b=B(this.g,this.h,12);return b?(new Tb).i(ib(this.g,
jb(this.g,this.h+b)+a*4),this.g):null}Ma(){const a=B(this.g,this.h,12);return a?kb(this.g,this.h+a):0}};class U{constructor(a=[],b,c,d=w.V5){this.fields=a||[];this.metadata=b||new Map;c||(c=Gh(this.fields));this.dictionaries=c;this.xa=d}get [Symbol.toStringTag](){return"Schema"}get names(){return this.fields.map(a=>a.name)}toString(){return`Schema<{ ${this.fields.map((a,b)=>`${b}: ${a}`).join(", ")} }>`}select(a){const b=new Set(a);a=this.fields.filter(c=>b.has(c.name));return new U(a,this.metadata)}selectAt(a){a=a.map(b=>this.fields[b]).filter(Boolean);return new U(a,this.metadata)}assign(...a){var b=
a[0]instanceof U?a[0]:Array.isArray(a[0])?new U(a[0]):new U(a);const c=[...this.fields];a=Hh(Hh(new Map,this.metadata),b.metadata);b=b.fields.filter(e=>{const f=c.findIndex(g=>g.name===e.name);return~f?(c[f]=e.clone({metadata:Hh(Hh(new Map,c[f].metadata),e.metadata)}))&&!1:!0});const d=Gh(b,new Map);return new U([...c,...b],a,new Map([...this.dictionaries,...d]))}}U.prototype.fields=null;U.prototype.metadata=null;U.prototype.dictionaries=null;
class V{static new(...a){let [b,c,d,e]=a;a[0]&&typeof a[0]==="object"&&({name:b}=a[0],c===void 0&&(c=a[0].type),d===void 0&&(d=a[0].nullable),e===void 0&&(e=a[0].metadata));return new V(`${b}`,c,d,e)}constructor(a,b,c=!1,d){this.name=a;this.type=b;this.nullable=c;this.metadata=d||new Map}get typeId(){return this.type.typeId}get [Symbol.toStringTag](){return"Field"}toString(){return`${this.name}: ${this.type}`}clone(...a){let [b,c,d,e]=a;a[0]&&typeof a[0]==="object"?{name:b=this.name,type:c=this.type,
nullable:d=this.nullable,metadata:e=this.metadata}=a[0]:[b=this.name,c=this.type,d=this.nullable,e=this.metadata]=a;return V.new(b,c,d,e)}}V.prototype.type=null;V.prototype.name=null;V.prototype.nullable=null;V.prototype.metadata=null;function Hh(a,b){return new Map([...(a||new Map),...(b||new Map)])}
function Gh(a,b=new Map){for(let c=-1,d=a.length;++c<d;){const e=a[c].type;if(L.isDictionary(e))if(!b.has(e.id))b.set(e.id,e.dictionary);else if(b.get(e.id)!==e.dictionary)throw Error("Cannot create Schema containing two different dictionaries with the same Id");e.children&&e.children.length>0&&Gh(e.children,b)}return b};function*Ih(a){for(let b,c=-1,d=a.numDictionaries;++c<d;)if(b=a.Na(c))yield b}
class Jh{static decode(a){a=new lb(u(Uint8Array,a));a=(new Fh).i(a.v(a.position())+a.position(),a);const b=U.decode(a.schema(),new Map,a.version());return new Kh(b,a)}static encode(a){const b=new zb;var c=U.encode(b,a.schema);wb(b,24,a.numRecordBatches,8);for(var d of[...a.ob()].slice().reverse())Lh.encode(b,d);d=xb(b);wb(b,24,a.numDictionaries,8);for(const e of[...Ih(a)].slice().reverse())Lh.encode(b,e);a=xb(b);D(b,5);C(b,1,c);rb(b,w.V5,w.V1);C(b,3,d);C(b,2,a);c=E(b);b.finish(c);return mb(b)}get numRecordBatches(){return this.ca.length}get numDictionaries(){return this.wb.length}constructor(a,
b=w.V5,c,d){this.schema=a;this.version=b;c&&(this.ca=c);d&&(this.wb=d)}*ob(){for(let a,b=-1,c=this.numRecordBatches;++b<c;)if(a=this.ia(b))yield a}ia(a){return a>=0&&a<this.numRecordBatches&&this.ca[a]||null}Na(a){return a>=0&&a<this.numDictionaries&&this.wb[a]||null}}
class Kh extends Jh{get numRecordBatches(){var a=this.m;const b=B(a.g,a.h,10);return b?kb(a.g,a.h+b):0}get numDictionaries(){var a=this.m;const b=B(a.g,a.h,8);return b?kb(a.g,a.h+b):0}constructor(a,b){super(a,b.version());this.m=b}ia(a){return a>=0&&a<this.numRecordBatches&&(a=this.m.ob(a))?Lh.decode(a):null}Na(a){return a>=0&&a<this.numDictionaries&&(a=this.m.dictionaries(a))?Lh.decode(a):null}}
class Lh{static decode(a){return new Lh(a.jb(),a.bodyLength(),a.offset())}static encode(a,b){var c=BigInt(b.offset),d=b.jb;b=BigInt(b.bodyLength);nb(a,8,24);a.$(BigInt(b!=null?b:0));a.pad(4);a.Z(d);a.$(BigInt(c!=null?c:0));return a.offset()}constructor(a,b,c){this.jb=a;this.offset=K(c);this.bodyLength=K(b)}};class Mh{constructor(){this.g=null;this.h=0}i(a,b){this.h=a;this.g=b;return this}version(){const a=B(this.g,this.h,4);return a?eb(this.g,this.h+a):w.V1}headerType(){const a=B(this.g,this.h,6);return a?this.g.l[this.h+a]:H.NONE}header(a){const b=B(this.g,this.h,8);return b?gb(this.g,a,this.h+b):null}bodyLength(){const a=B(this.g,this.h,10);return a?fb(this.g,this.h+a):BigInt("0")}La(a){const b=B(this.g,this.h,12);return b?(new Tb).i(ib(this.g,jb(this.g,this.h+b)+a*4),this.g):null}Ma(){const a=B(this.g,
this.h,12);return a?kb(this.g,this.h+a):0}};class Nh extends Ue{visit(a,b){return a==null||b==null?void 0:super.visit(a,b)}visitNull(a,b){D(b,0);return E(b)}visitInt(a,b){D(b,2);sb(b,0,a.bitWidth,0);qb(b,1,+a.isSigned,0);return E(b)}visitFloat(a,b){D(b,1);rb(b,a.precision,y.HALF);return E(b)}visitBinary(a,b){D(b,0);return E(b)}visitLargeBinary(a,b){D(b,0);return E(b)}visitBool(a,b){D(b,0);return E(b)}visitUtf8(a,b){D(b,0);return E(b)}visitLargeUtf8(a,b){D(b,0);return E(b)}visitDecimal(a,b){D(b,3);sb(b,1,a.scale,0);sb(b,0,a.precision,0);sb(b,
2,a.bitWidth,128);return E(b)}visitDate(a,b){D(b,1);rb(b,a.unit,Ya.MILLISECOND);return E(b)}visitTime(a,b){D(b,2);rb(b,a.unit,z.MILLISECOND);sb(b,1,a.bitWidth,32);return E(b)}visitTimestamp(a,b){const c=a.timezone&&yb(b,a.timezone)||void 0;D(b,2);rb(b,a.unit,z.SECOND);c!==void 0&&C(b,1,c);return E(b)}visitInterval(a,b){D(b,1);rb(b,a.unit,A.YEAR_MONTH);return E(b)}visitDuration(a,b){D(b,1);rb(b,a.unit,z.MILLISECOND);return E(b)}visitList(a,b){D(b,0);return E(b)}visitStruct(a,b){D(b,0);return E(b)}visitUnion(a,
b){wb(b,4,a.typeIds.length,4);var c=a.typeIds;wb(b,4,c.length,4);for(let d=c.length-1;d>=0;d--)pb(b,c[d]);c=xb(b);D(b,2);rb(b,a.mode,x.Sparse);C(b,1,c);return E(b)}visitDictionary(a,b){const c=this.visit(a.indices,b);D(b,4);tb(b,0,BigInt(a.id));qb(b,2,+a.isOrdered,0);c!==void 0&&C(b,1,c);return E(b)}visitFixedSizeBinary(a,b){D(b,1);sb(b,0,a.byteWidth,0);return E(b)}visitFixedSizeList(a,b){D(b,1);sb(b,0,a.listSize,0);return E(b)}visitMap(a,b){D(b,1);qb(b,0,+a.keysSorted,0);return E(b)}}const Oh=new Nh;function Ph(a){return new Qh(a.count,Rh(a.columns),Sh(a.columns),null)}function Th(a,b){return(a.fields||[]).filter(Boolean).map(c=>V.fromJSON(c,b))}function Uh(a,b){return(a.children||[]).filter(Boolean).map(c=>V.fromJSON(c,b))}function Rh(a){return(a||[]).reduce((b,c)=>[...b,new Vh(c.count,Wh(c.VALIDITY)),...Rh(c.children)],[])}
function Sh(a,b=[]){for(let c=-1,d=(a||[]).length;++c<d;){const e=a[c];e.VALIDITY&&b.push(new Xh(b.length,e.VALIDITY.length));e.TYPE_ID&&b.push(new Xh(b.length,e.TYPE_ID.length));e.OFFSET&&b.push(new Xh(b.length,e.OFFSET.length));e.DATA&&b.push(new Xh(b.length,e.DATA.length));b=Sh(e.children,b)}return b}function Wh(a){return(a||[]).reduce((b,c)=>b+ +(c===0),0)}function Yh(a=[]){return new Map(a.map(({key:b,value:c})=>[b,c]))}function Zh(a){return new Nc(a.isSigned,a.bitWidth)}
function $h(a,b){const c=a.type.name;switch(c){case "NONE":return new Mc;case "null":return new Mc;case "binary":return new gd;case "largebinary":return new kd;case "utf8":return new od;case "largeutf8":return new sd;case "bool":return new wd;case "list":return new oe((b||[])[0]);case "struct":return new se(b||[]);case "struct_":return new se(b||[])}switch(c){case "int":return b=a.type,new Nc(b.isSigned,b.bitWidth);case "floatingpoint":return new $c(y[a.type.precision]);case "decimal":return b=a.type,
new Ad(b.scale,b.precision,b.bitWidth);case "date":return new Ed(Ya[a.type.unit]);case "time":return b=a.type,new Kd(z[b.unit],b.bitWidth);case "timestamp":return b=a.type,new Sd(z[b.unit],b.timezone);case "interval":return new $d(A[a.type.unit]);case "duration":return new ge(z[a.type.unit]);case "union":a=a.type;const [d,...e]=(a.mode+"").toLowerCase();return new we(x[d.toUpperCase()+e.join("")],a.typeIds||[],b||[]);case "fixedsizebinary":return new Ce(a.type.byteWidth);case "fixedsizelist":return new Ge(a.type.listSize,
(b||[])[0]);case "map":return new Ke((b||[])[0],a.type.keysSorted)}throw Error(`Unrecognized type: "${c}"`);};class ai{static fromJSON(a,b){const c=new ai(0,w.V5,b);c.Ua=bi(a,b);return c}static decode(a){a=new lb(u(Uint8Array,a));a=(new Mh).i(a.v(a.position())+a.position(),a);var b=a.bodyLength();const c=a.version(),d=a.headerType();b=new ai(b,c,d);b.Ua=ci(a,d);return b}static encode(a){const b=new zb;let c=-1;a.isSchema()?c=U.encode(b,a.header()):a.isRecordBatch()?c=Qh.encode(b,a.header()):a.isDictionaryBatch()&&(c=di.encode(b,a.header()));D(b,5);rb(b,w.V5,w.V1);C(b,2,c);qb(b,1,a.headerType,H.NONE);tb(b,
3,BigInt(a.bodyLength));a=E(b);b.finish(a);return mb(b)}static from(a,b=0){if(a instanceof U)return new ai(0,w.V5,H.Schema,a);if(a instanceof Qh)return new ai(b,w.V5,H.RecordBatch,a);if(a instanceof di)return new ai(b,w.V5,H.DictionaryBatch,a);throw Error(`Unrecognized Message header: ${a}`);}get type(){return this.headerType}get version(){return this.fc}get headerType(){return this.bc}get compression(){return this.P}get bodyLength(){return this.Wb}header(){return this.Ua()}isSchema(){return this.headerType===
H.Schema}isRecordBatch(){return this.headerType===H.RecordBatch}isDictionaryBatch(){return this.headerType===H.DictionaryBatch}constructor(a,b,c,d){this.fc=b;this.bc=c;this.body=new Uint8Array(0);this.P=d==null?void 0:d.compression;d&&(this.Ua=()=>d);this.Wb=K(a)}}class Qh{get H(){return this.ab}get length(){return this.ec}get buffers(){return this.Sa}get compression(){return this.P}constructor(a,b,c,d){this.ab=b;this.Sa=c;this.ec=K(a);this.P=d}}
class di{get id(){return this.cc}get data(){return this.Yb}get Oa(){return this.dc}get length(){return this.data.length}get H(){return this.data.H}get buffers(){return this.data.buffers}constructor(a,b,c=!1){this.Yb=a;this.dc=c;this.cc=K(b)}}class Xh{constructor(a,b){this.offset=K(a);this.length=K(b)}}class Vh{constructor(a,b){this.length=K(a);this.nullCount=K(b)}}class ei{constructor(a,b=Ab.sb){this.type=a;this.method=b}}
function bi(a,b){return()=>{switch(b){case H.Schema:return U.fromJSON(a);case H.RecordBatch:return Qh.fromJSON(a);case H.DictionaryBatch:return di.fromJSON(a)}throw Error(`Unrecognized Message type: { name: ${H[b]}, type: ${b} }`);}}
function ci(a,b){return()=>{switch(b){case H.Schema:return U.decode(a.header(new mc),new Map,a.version());case H.RecordBatch:return Qh.decode(a.header(new Kb),a.version());case H.DictionaryBatch:return di.decode(a.header(new Lb),a.version())}throw Error(`Unrecognized Message type: { name: ${H[b]}, type: ${b} }`);}}V.encode=fi;V.decode=gi;
V.fromJSON=function(a,b){var c;let d,e;b&&(e=a.dictionary)?(b.has(c=e.id)?(d=(d=e.indexType)?Zh(d):new Uc,c=new Pe(b.get(c),d,c,e.isOrdered)):(d=(d=e.indexType)?Zh(d):new Uc,b.set(c,b=$h(a,Uh(a,b))),c=new Pe(b,d,c,e.isOrdered)),a=new V(a.name,c,a.nullable,Yh(a.metadata))):(b=$h(a,Uh(a,b)),a=new V(a.name,b,a.nullable,Yh(a.metadata)));return a||null};U.encode=hi;U.decode=ii;U.fromJSON=function(a,b=new Map){return new U(Th(a,b),Yh(a.metadata),b)};Qh.encode=ji;Qh.decode=ki;Qh.fromJSON=Ph;di.encode=li;
di.decode=mi;di.fromJSON=function(a){return new di(Ph(a.data),a.id,a.isDelta)};Vh.encode=ni;Vh.decode=oi;Xh.encode=pi;Xh.decode=qi;ei.encode=ri;ei.decode=si;function ii(a,b=new Map,c=w.V5){const d=[];for(let e,f=-1,g=-1,k=lc(a);++f<k;)if(e=a.fields(f))d[++g]=V.decode(e,b);return new U(d,ti(a),b,c)}
function ki(a,b=w.V5){var c=a.length();const d=[];for(let f,g=-1,k=-1,m=Ib(a);++g<m;)if(f=a.H(g))d[++k]=Vh.decode(f);const e=[];for(let f,g=-1,k=-1,m=Jb(a);++g<m;)if(f=a.buffers(g))b<w.V4&&(f.h+=8*(g+1)),e[++k]=Xh.decode(f);return new Qh(c,d,e,si(a.compression()))}function mi(a,b=w.V5){return new di(Qh.decode(a.data(),b),a.id(),a.Oa())}function qi(a){return new Xh(a.offset(),a.length())}function oi(a){return new Vh(a.length(),a.nullCount())}
function ui(a,b){const c=[];for(let d,e=-1,f=-1,g=hc(a);++e<g;)if(d=a.children(e))c[++f]=V.decode(d,b);return c}function gi(a,b){var c;let d,e;b&&(e=a.dictionary())?(b.has(c=K(e.id()))?(d=(d=Rb(e))?vi(d):new Uc,c=new Pe(b.get(c),d,c,e.isOrdered())):(d=(d=Rb(e))?vi(d):new Uc,b.set(c,b=wi(a,ui(a,b))),c=new Pe(b,d,c,e.isOrdered())),a=new V(a.name(),c,a.nullable(),ti(a))):(b=wi(a,ui(a,b)),a=new V(a.name(),b,a.nullable(),ti(a)));return a||null}
function ti(a){const b=new Map;if(a)for(let c,d,e=-1,f=Math.trunc(a.Ma());++e<f;)(c=a.La(e))&&(d=c.key())!=null&&b.set(d,c.value());return b}function vi(a){return new Nc(a.isSigned(),a.bitWidth())}
function wi(a,b){var c=(c=B(a.g,a.h,8))?a.g.l[a.h+c]:F.NONE;switch(c){case F.NONE:return new Mc;case F.Null:return new Mc;case F.Binary:return new gd;case F.LargeBinary:return new kd;case F.Utf8:return new od;case F.LargeUtf8:return new sd;case F.Bool:return new wd;case F.List:return new oe((b||[])[0]);case F.Struct_:return new se(b||[])}switch(c){case F.Int:return b=a.type(new Qb),new Nc(b.isSigned(),b.bitWidth());case F.FloatingPoint:return b=a.type(new Zb),new $c(b.precision());case F.Decimal:return b=
a.type(new Vb),new Ad(b.scale(),b.precision(),b.bitWidth());case F.Date:return b=a.type(new Ub),new Ed(b.unit());case F.Time:return b=a.type(new bc),new Kd(b.unit(),b.bitWidth());case F.Timestamp:return b=a.type(new cc),new Sd(b.unit(),b.timezone());case F.Interval:return b=a.type(new $b),new $d(b.unit());case F.Duration:return b=a.type(new Wb),new ge(b.unit());case F.Union:c=a.type(new dc);a=c.mode();const d=B(c.g,c.h,6);c=d?new Int32Array(c.g.bytes().buffer,c.g.bytes().byteOffset+jb(c.g,c.h+d),
kb(c.g,c.h+d)):null;return new we(a,c||[],b||[]);case F.FixedSizeBinary:return b=a.type(new Xb),new Ce(b.byteWidth());case F.FixedSizeList:return a=a.type(new Yb),new Ge(a.listSize(),(b||[])[0]);case F.Map:return a=a.type(new ac),new Ke((b||[])[0],a.keysSorted())}throw Error(`Unrecognized type: "${F[c]}" (${c})`);}function si(a){return a?new ei(a.codec(),a.method()):null}
function hi(a,b){var c=b.fields.map(d=>V.encode(a,d));wb(a,4,c.length,4);c=jc(a,c);b=b.metadata&&b.metadata.size>0?kc(a,[...b.metadata].map(([d,e])=>{d=yb(a,`${d}`);e=yb(a,`${e}`);D(a,2);C(a,0,d);C(a,1,e);return E(a)})):-1;D(a,4);C(a,1,c);rb(a,xi?Mb.Ub:Mb.sc,Mb.Ub);b!==-1&&C(a,2,b);return E(a)}
function fi(a,b){let c=-1,d=-1,e=-1;var f=b.type;let g=b.typeId;L.isDictionary(f)?(g=f.dictionary.typeId,e=Oh.visit(f,a),d=Oh.visit(f.dictionary,a)):d=Oh.visit(f,a);f=(f.children||[]).map(m=>V.encode(a,m));f=ec(a,f);const k=b.metadata&&b.metadata.size>0?fc(a,[...b.metadata].map(([m,p])=>{m=yb(a,`${m}`);p=yb(a,`${p}`);D(a,2);C(a,0,m);C(a,1,p);return E(a)})):-1;b.name&&(c=yb(a,b.name));D(a,7);C(a,3,d);qb(a,2,g,F.NONE);C(a,5,f);qb(a,1,+!!b.nullable,0);c!==-1&&C(a,0,c);e!==-1&&C(a,4,e);k!==-1&&C(a,6,
k);return E(a)}function ji(a,b){var c=b.H||[],d=b.buffers||[];wb(a,16,c.length,8);for(const f of c.slice().reverse())Vh.encode(a,f);c=xb(a);wb(a,16,d.length,8);for(var e of d.slice().reverse())Xh.encode(a,e);d=xb(a);e=null;b.compression!==null&&(e=ri(a,b.compression));D(a,4);tb(a,0,BigInt(b.length));C(a,1,c);C(a,2,d);b.compression!==null&&e&&C(a,3,e);return E(a)}function ri(a,b){D(a,2);qb(a,0,b.type,Cb.LZ4_FRAME);qb(a,1,b.method,Ab.sb);return E(a)}
function li(a,b){const c=Qh.encode(a,b.data);D(a,3);tb(a,0,BigInt(b.id));qb(a,2,+b.Oa,0);C(a,1,c);return E(a)}function ni(a,b){var c=BigInt(b.length);b=BigInt(b.nullCount);nb(a,8,16);a.$(BigInt(b!=null?b:0));a.$(BigInt(c!=null?c:0));return a.offset()}function pi(a,b){var c=BigInt(b.offset);b=BigInt(b.length);nb(a,8,16);a.$(BigInt(b!=null?b:0));a.$(BigInt(c!=null?c:0));return a.offset()}const yi=new ArrayBuffer(2);(new DataView(yi)).setInt16(0,256,!0);const xi=(new Int16Array(yi))[0]===256;const zi=Object.freeze({done:!0,value:void 0});class Ai{constructor(a){this.pa=a}get schema(){return this.pa.schema}get batches(){return this.pa.batches||[]}get dictionaries(){return this.pa.dictionaries||[]}}function Bi(a){return a.tb||(a.tb=a.toDOMStream())}function Ci(a,b,c){return Ci(a.Ab||(a.Ab=a.toNodeStream()),b,c)}class Di{tee(){return Bi(this).tee()}pipeTo(a,b){return Bi(this).pipeTo(a,b)}pipeThrough(a,b){return Bi(this).pipeThrough(a,b)}}
class Ei extends Di{constructor(){super();this.o=[];this.ka=[];this.Ta=new Promise(a=>this.N=a)}get closed(){return this.Ta}cancel(a){const b=this;return l(function*(){yield b.return(a)})}write(a){if(!this.N)throw Error("AsyncQueue is closed");this.ka.length<=0?this.o.push(a):this.ka.shift().resolve({done:!1,value:a})}abort(a){this.N&&(this.ka.length<=0?this.Wa={error:a}:this.ka.shift().reject({done:!0,value:a}))}close(){if(this.N){const a=this.ka;for(;a.length>0;)a.shift().resolve(zi);this.N();this.N=
void 0}}[Symbol.asyncIterator](){return this}toDOMStream(a){return Ma(this.N||this.Wa?this:this.o,a)}toNodeStream(){return Na()}throw(a){const b=this;return l(function*(){yield b.abort(a);return zi})}return(){const a=this;return l(function*(){yield a.close();return zi})}read(a){const b=this;return l(function*(){return(yield b.next(a,"read")).value})}peek(a){const b=this;return l(function*(){return(yield b.next(a,"peek")).value})}next(){return this.o.length>0?Promise.resolve({done:!1,value:this.o.shift()}):
this.Wa?Promise.reject({done:!0,value:this.Wa.error}):this.N?new Promise((a,b)=>{this.ka.push({resolve:a,reject:b})}):Promise.resolve(zi)}};class Fi extends Ei{write(a){if((a=u(Uint8Array,a)).byteLength>0)return super.write(a)}toString(a=!1){return a?wa(this.toUint8Array(!0)):this.toUint8Array(!1).then(wa)}toUint8Array(a=!1){return a?Ea(this.o)[0]:(()=>{const b=this;return l(function*(){const c=[];let d=0;var e;try{for(var f=ia(b);;){var g=yield f.next();if(g.done)break;const m=g.value;c.push(m);d+=m.byteLength}}catch(m){var k={error:m}}finally{try{g&&!g.done&&(e=f.return)&&(yield e.call(f))}finally{if(k)throw k.error;}}return Ea(c,d)[0]})})()}}
class Gi{constructor(a){a&&(this.source=new Hi(Oa(Pa(a))))}[Symbol.iterator](){return this}next(a){return this.source.next(a)}throw(a){return this.source.throw(a)}return(a){return this.source.return(a)}peek(a){return this.source.peek(a)}read(a){return this.source.read(a)}}
class Ii{constructor(a){a instanceof Ii?this.source=a.source:a instanceof Fi?this.source=new Ji(Oa(Qa(a))):Aa(a)?this.source=new Ji(Oa(Ua(a))):za(a)?this.source=new Ji(Oa(Ra(a))):t(a)&&za(a.body)?this.source=new Ji(Oa(Ra(a.body))):t(a)&&q(a[Symbol.iterator])?this.source=new Ji(Oa(Pa(a))):t(a)&&q(a.then)?this.source=new Ji(Oa(Qa(a))):t(a)&&q(a[Symbol.asyncIterator])&&(this.source=new Ji(Oa(Qa(a))))}[Symbol.asyncIterator](){return this}next(a){return this.source.next(a)}throw(a){return this.source.throw(a)}return(a){return this.source.return(a)}get closed(){return this.source.closed}cancel(a){return this.source.cancel(a)}peek(a){return this.source.peek(a)}read(a){return this.source.read(a)}}
class Hi{constructor(a){this.source=a}cancel(a){this.return(a)}peek(a){return this.next(a,"peek").value}read(a){return this.next(a,"read").value}next(a,b="read"){return this.source.next({O:b,size:a})}throw(a){return Object.create(this.source.throw&&this.source.throw(a)||zi)}return(a){return Object.create(this.source.return&&this.source.return(a)||zi)}}
class Ji{constructor(a){this.source=a;this.Ta=new Promise(b=>this.N=b)}cancel(a){const b=this;return l(function*(){yield b.return(a)})}get closed(){return this.Ta}read(a){const b=this;return l(function*(){return(yield b.next(a,"read")).value})}peek(a){const b=this;return l(function*(){return(yield b.next(a,"peek")).value})}next(a,b="read"){const c=this;return l(function*(){return yield c.source.next({O:b,size:a})})}throw(a){const b=this;return l(function*(){const c=b.source.throw&&(yield b.source.throw(a))||
zi;b.N&&b.N();b.N=void 0;return Object.create(c)})}return(a){const b=this;return l(function*(){const c=b.source.return&&(yield b.source.return(a))||zi;b.N&&b.N();b.N=void 0;return Object.create(c)})}};class Ki extends Gi{constructor(a){super();this.position=0;this.buffer=u(Uint8Array,a);this.size=this.buffer.byteLength}v(a){const {buffer:b,byteOffset:c}=this.ja(a,4);return(new DataView(b,c)).getInt32(0,!0)}seek(a){this.position=Math.min(a,this.size);return a<this.size}read(a){const b=this.buffer,c=this.size,d=this.position;return b&&d<c?(typeof a!=="number"&&(a=Number.POSITIVE_INFINITY),this.position=Math.min(c,d+Math.min(c-d,a)),b.subarray(d,this.position)):null}ja(a,b){const c=this.buffer,d=
Math.min(this.size,a+b);return c?c.subarray(a,d):new Uint8Array(b)}close(){this.buffer&&(this.buffer=null)}throw(a){this.close();return{done:!0,value:a}}return(a){this.close();return{done:!0,value:a}}}
class Li extends Ii{constructor(a,b){super();this.position=0;this.K=a;typeof b==="number"?this.size=b:this.I=(()=>{const c=this;return l(function*(){c.size=(yield a.stat()).size;delete c.I})})()}v(a){const b=this;return l(function*(){const {buffer:c,byteOffset:d}=yield b.ja(a,4);return(new DataView(c,d)).getInt32(0,!0)})}seek(a){const b=this;return l(function*(){b.I&&(yield b.I);b.position=Math.min(a,b.size);return a<b.size})}read(a){const b=this;return l(function*(){b.I&&(yield b.I);const c=b.K;
var d=b.size,e=b.position;if(c&&e<d){typeof a!=="number"&&(a=Number.POSITIVE_INFINITY);let f=0,g=0;d=Math.min(d,e+Math.min(d-e,a));const k=new Uint8Array(Math.max(0,(b.position=d)-e));for(;(e+=g)<d&&(f+=g)<k.byteLength;)({tc:g}=yield c.read(k,f,k.byteLength-f,e));return k}return null})}ja(a,b){const c=this;return l(function*(){c.I&&(yield c.I);const d=c.K;var e=c.size;return d&&a+b<e?(e=new Uint8Array(Math.min(e,a+b)-a),(yield d.read(e,0,b,a)).buffer):new Uint8Array(b)})}close(){const a=this;return l(function*(){const b=
a.K;a.K=null;b&&(yield b.close())})}throw(a){const b=this;return l(function*(){yield b.close();return{done:!0,value:a}})}return(a){const b=this;return l(function*(){yield b.close();return{done:!0,value:a}})}};function Mi(a){a<0&&(a=4294967295+a+1);return`0x${a.toString(16)}`}const Ni=[1,10,100,1E3,1E4,1E5,1E6,1E7,1E8];
function Oi(a,b){const c=new Uint32Array([a.buffer[1]>>>16,a.buffer[1]&65535,a.buffer[0]>>>16,a.buffer[0]&65535]);b=new Uint32Array([b.buffer[1]>>>16,b.buffer[1]&65535,b.buffer[0]>>>16,b.buffer[0]&65535]);let d=c[3]*b[3];a.buffer[0]=d&65535;let e=d>>>16;d=c[2]*b[3];e+=d;d=c[3]*b[2]>>>0;e+=d;a.buffer[0]+=e<<16;a.buffer[1]=e>>>0<d?65536:0;a.buffer[1]+=e>>>16;a.buffer[1]+=c[1]*b[3]+c[2]*b[2]+c[3]*b[1];a.buffer[1]+=c[0]*b[3]+c[1]*b[2]+c[2]*b[1]+c[3]*b[0]<<16}
function Pi(a,b){const c=a.buffer[0]+b.buffer[0]>>>0;a.buffer[1]+=b.buffer[1];c<a.buffer[0]>>>0&&++a.buffer[1];a.buffer[0]=c}class Qi{constructor(a){this.buffer=a}high(){return this.buffer[1]}low(){return this.buffer[0]}lessThan(a){return this.buffer[1]<a.buffer[1]||this.buffer[1]===a.buffer[1]&&this.buffer[0]<a.buffer[0]}equals(a){return this.buffer[1]===a.buffer[1]&&this.buffer[0]==a.buffer[0]}greaterThan(a){return a.lessThan(this)}hex(){return`${Mi(this.buffer[1])} ${Mi(this.buffer[0])}`}}
class W extends Qi{times(a){Oi(this,a);return this}plus(a){Pi(this,a);return this}static from(a,b=new Uint32Array(2)){return W.fromString(typeof a==="string"?a:a.toString(),b)}static fromNumber(a,b=new Uint32Array(2)){return W.fromString(a.toString(),b)}static fromString(a,b=new Uint32Array(2)){const c=a.length;b=new W(b);for(let d=0;d<c;){const e=8<c-d?8:c-d,f=new W(new Uint32Array([Number.parseInt(a.slice(d,d+e),10),0])),g=new W(new Uint32Array([Ni[e],0]));b.times(g);b.plus(f);d+=e}return b}static convertArray(a){const b=
new Uint32Array(a.length*2);for(let c=-1,d=a.length;++c<d;)W.from(a[c],new Uint32Array(b.buffer,b.byteOffset+2*c*4,2));return b}static multiply(a,b){return(new W(new Uint32Array(a.buffer))).times(b)}static add(a,b){return(new W(new Uint32Array(a.buffer))).plus(b)}}
class Ri extends Qi{negate(){this.buffer[0]=~this.buffer[0]+1;this.buffer[1]=~this.buffer[1];this.buffer[0]==0&&++this.buffer[1];return this}times(a){Oi(this,a);return this}plus(a){Pi(this,a);return this}lessThan(a){const b=this.buffer[1]<<0,c=a.buffer[1]<<0;return b<c||b===c&&this.buffer[0]<a.buffer[0]}static from(a,b=new Uint32Array(2)){return Ri.fromString(typeof a==="string"?a:a.toString(),b)}static fromNumber(a,b=new Uint32Array(2)){return Ri.fromString(a.toString(),b)}static fromString(a,b=
new Uint32Array(2)){const c=a.startsWith("-"),d=a.length;b=new Ri(b);for(let e=c?1:0;e<d;){const f=8<d-e?8:d-e,g=new Ri(new Uint32Array([Number.parseInt(a.slice(e,e+f),10),0])),k=new Ri(new Uint32Array([Ni[f],0]));b.times(k);b.plus(g);e+=f}return c?b.negate():b}static convertArray(a){const b=new Uint32Array(a.length*2);for(let c=-1,d=a.length;++c<d;)Ri.from(a[c],new Uint32Array(b.buffer,b.byteOffset+2*c*4,2));return b}static multiply(a,b){return(new Ri(new Uint32Array(a.buffer))).times(b)}static add(a,
b){return(new Ri(new Uint32Array(a.buffer))).plus(b)}}
class Si{constructor(a){this.buffer=a}high(){return new Ri(new Uint32Array(this.buffer.buffer,this.buffer.byteOffset+8,2))}low(){return new Ri(new Uint32Array(this.buffer.buffer,this.buffer.byteOffset,2))}negate(){this.buffer[0]=~this.buffer[0]+1;this.buffer[1]=~this.buffer[1];this.buffer[2]=~this.buffer[2];this.buffer[3]=~this.buffer[3];this.buffer[0]==0&&++this.buffer[1];this.buffer[1]==0&&++this.buffer[2];this.buffer[2]==0&&++this.buffer[3];return this}times(a){const b=new W(new Uint32Array([this.buffer[3],
0])),c=new W(new Uint32Array([this.buffer[2],0])),d=new W(new Uint32Array([this.buffer[1],0])),e=new W(new Uint32Array([this.buffer[0],0])),f=new W(new Uint32Array([a.buffer[3],0])),g=new W(new Uint32Array([a.buffer[2],0])),k=new W(new Uint32Array([a.buffer[1],0]));a=new W(new Uint32Array([a.buffer[0],0]));let m=W.multiply(e,a);this.buffer[0]=m.low();const p=new W(new Uint32Array([m.high(),0]));m=W.multiply(d,a);p.plus(m);m=W.multiply(e,k);p.plus(m);this.buffer[1]=p.low();this.buffer[3]=p.lessThan(m)?
1:0;this.buffer[2]=p.high();(new W(new Uint32Array(this.buffer.buffer,this.buffer.byteOffset+8,2))).plus(W.multiply(c,a)).plus(W.multiply(d,k)).plus(W.multiply(e,g));this.buffer[3]+=W.multiply(b,a).plus(W.multiply(c,k)).plus(W.multiply(d,g)).plus(W.multiply(e,f)).low();return this}plus(a){const b=new Uint32Array(4);b[3]=this.buffer[3]+a.buffer[3]>>>0;b[2]=this.buffer[2]+a.buffer[2]>>>0;b[1]=this.buffer[1]+a.buffer[1]>>>0;b[0]=this.buffer[0]+a.buffer[0]>>>0;b[0]<this.buffer[0]>>>0&&++b[1];b[1]<this.buffer[1]>>>
0&&++b[2];b[2]<this.buffer[2]>>>0&&++b[3];this.buffer[3]=b[3];this.buffer[2]=b[2];this.buffer[1]=b[1];this.buffer[0]=b[0];return this}hex(){return`${Mi(this.buffer[3])} ${Mi(this.buffer[2])} ${Mi(this.buffer[1])} ${Mi(this.buffer[0])}`}static multiply(a,b){return(new Si(new Uint32Array(a.buffer))).times(b)}static add(a,b){return(new Si(new Uint32Array(a.buffer))).plus(b)}static from(a,b=new Uint32Array(4)){return Si.fromString(typeof a==="string"?a:a.toString(),b)}static fromNumber(a,b=new Uint32Array(4)){return Si.fromString(a.toString(),
b)}static fromString(a,b=new Uint32Array(4)){const c=a.startsWith("-"),d=a.length;b=new Si(b);for(let e=c?1:0;e<d;){const f=8<d-e?8:d-e,g=new Si(new Uint32Array([Number.parseInt(a.slice(e,e+f),10),0,0,0])),k=new Si(new Uint32Array([Ni[f],0,0,0]));b.times(k);b.plus(g);e+=f}return c?b.negate():b}static convertArray(a){const b=new Uint32Array(a.length*4);for(let c=-1,d=a.length;++c<d;)Si.from(a[c],new Uint32Array(b.buffer,b.byteOffset+16*c,4));return b}}var Ti={};Ti.BaseInt64=Qi;Ti.Int128=Si;
Ti.Int64=Ri;Ti.Uint64=W;function Ui(a){const b=a.length,c=new Int32Array(b*2);for(let d=0,e=0;d<b;d++){const f=a[d];let g;c[e++]=(g=f.days)!=null?g:0;let k;c[e++]=(k=f.milliseconds)!=null?k:0}return c}function Vi(a){const b=a.length,c=new Int32Array(b*4);for(let e=0,f=0;e<b;e++){var d=a[e];let g;c[f++]=(g=d.months)!=null?g:0;let k;c[f++]=(k=d.days)!=null?k:0;(d=d.nanoseconds)?(c[f++]=Number(BigInt(d)&BigInt(4294967295)),c[f++]=Number(BigInt(d)>>BigInt(32))):f+=2}return c}
function Wi(a){const b=a.length,c=Array(b/2);for(let d=0,e=0;d<b;d+=2)c[e++]={days:a[d],milliseconds:a[d+1]};return c}function Xi(a,b){const c=a.length,d=Array(c/4);for(let e=0,f=0;e<c;e+=4){const g=BigInt(a[e+3])<<BigInt(32)|BigInt(a[e+2]>>>0);d[f++]={months:a[e],days:a[e+1],nanoseconds:b?`${g}`:g}}return d}var Yi={};Yi.toIntervalDayTimeInt32Array=Ui;Yi.toIntervalDayTimeObjects=Wi;Yi.toIntervalMonthDayNanoInt32Array=Vi;Yi.toIntervalMonthDayNanoObjects=Xi;function X(a){return a.H[++a.lc]}function Zi(a){return a.buffers[++a.Eb]}
class $i extends Ue{constructor(a,b,c,d,e=w.V5){super();this.Eb=this.lc=-1;this.bytes=a;this.H=b;this.buffers=c;this.dictionaries=d;this.xa=e}visit(a){return super.visit(a instanceof V?a.type:a)}visitNull(a,{length:b}=X(this)){return Q({type:a,length:b})}visitBool(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),data:this.F(a)})}visitInt(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),data:this.F(a)})}visitFloat(a,
{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),data:this.F(a)})}visitUtf8(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),valueOffsets:this.da(a),data:this.F(a)})}visitLargeUtf8(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),valueOffsets:this.da(a),data:this.F(a)})}visitBinary(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,
c),valueOffsets:this.da(a),data:this.F(a)})}visitLargeBinary(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),valueOffsets:this.da(a),data:this.F(a)})}visitFixedSizeBinary(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),data:this.F(a)})}visitDate(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),data:this.F(a)})}visitTimestamp(a,{length:b,nullCount:c}=X(this)){return Q({type:a,
length:b,nullCount:c,nullBitmap:this.D(a,c),data:this.F(a)})}visitTime(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),data:this.F(a)})}visitDecimal(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),data:this.F(a)})}visitList(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),valueOffsets:this.da(a),child:this.visit(a.children[0])})}visitStruct(a,{length:b,nullCount:c}=
X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),children:this.visitMany(a.children)})}visitUnion(a,{length:b,nullCount:c}=X(this)){this.xa<w.V5&&this.D(a,c);return a.mode===x.Sparse?this.visitSparseUnion(a,{length:b,nullCount:c}):this.visitDenseUnion(a,{length:b,nullCount:c})}visitDenseUnion(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,typeIds:this.nb(a),valueOffsets:this.da(a),children:this.visitMany(a.children)})}visitSparseUnion(a,{length:b,nullCount:c}=
X(this)){return Q({type:a,length:b,nullCount:c,typeIds:this.nb(a),children:this.visitMany(a.children)})}visitDictionary(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),data:this.F(a.indices),dictionary:this.dictionaries.get(a.id)})}visitInterval(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),data:this.F(a)})}visitDuration(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,
c),data:this.F(a)})}visitFixedSizeList(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),child:this.visit(a.children[0])})}visitMap(a,{length:b,nullCount:c}=X(this)){return Q({type:a,length:b,nullCount:c,nullBitmap:this.D(a,c),valueOffsets:this.da(a),child:this.visit(a.children[0])})}D(a,b){var c=Zi(this);return b>0&&this.F(a,c)||new Uint8Array(0)}da(a){return this.F(a)}nb(a){return this.F(a)}F(a,{length:b,offset:c}=Zi(this)){return this.bytes.subarray(c,
c+b)}}
class aj extends $i{constructor(a,b,c,d,e){super(new Uint8Array(0),b,c,d,e);this.sources=a}D(a,b){({offset:a}=Zi(this));return b<=0?new Uint8Array(0):Pg(this.sources[a])}da(a){({offset:b}=Zi(this));var b;return u(Uint8Array,u(a.OffsetArrayType,this.sources[b]))}nb(a){({offset:b}=Zi(this));var b;return u(Uint8Array,u(a.ArrayType,this.sources[b]))}F(a,{offset:b}=Zi(this)){const c=this.sources;if(L.isTimestamp(a)||(L.isInt(a)||L.isTime(a))&&a.bitWidth===64||L.isDuration(a)||L.isDate(a)&&a.unit===Ya.MILLISECOND)return u(Uint8Array,
Ri.convertArray(c[b]));if(L.isDecimal(a))return u(Uint8Array,Si.convertArray(c[b]));if(L.isBinary(a)||L.isLargeBinary(a)||L.isFixedSizeBinary(a))return bj(c[b]);if(L.isBool(a))return Pg(c[b]);if(L.isUtf8(a)||L.isLargeUtf8(a))return xa.encode(c[b].join(""));if(L.isInterval(a))switch(a.unit){case A.DAY_TIME:return Ui(c[b]);case A.MONTH_DAY_NANO:return Vi(c[b])}return u(Uint8Array,u(a.ArrayType,c[b].map(d=>+d)))}}
function bj(a){a=a.join("");const b=new Uint8Array(a.length/2);for(let c=0;c<a.length;c+=2)b[c>>1]=Number.parseInt(a.slice(c,c+2),16);return b}class cj extends $i{constructor(a,b,c,d,e){super(new Uint8Array(0),b,c,d,e);this.hc=a}F(a,b=Zi(this)){return this.hc[this.Eb]}};class dj extends Dh{constructor(a){super(a);this.o=new wh(Uint8Array)}get byteLength(){let a=this.L+this.length*4;this.j&&(a+=this.j.byteLength);this.o&&(a+=this.o.byteLength);this.G&&(a+=this.G.byteLength);return a}setValue(a,b){return super.setValue(a,u(Uint8Array,b))}V(a,b){const c=this.j;b=vh(this.o,b).buffer;let d=0;for(const [e,f]of a)f===void 0?c.set(e,0):(a=f.length,b.set(f,d),c.set(e,a),d+=a)}};class ej extends Dh{constructor(a){super(a);this.o=new wh(Uint8Array)}get byteLength(){let a=this.L+this.length*4;this.j&&(a+=this.j.byteLength);this.o&&(a+=this.o.byteLength);this.G&&(a+=this.G.byteLength);return a}setValue(a,b){return super.setValue(a,u(Uint8Array,b))}V(a,b){const c=this.j;b=vh(this.o,b).buffer;let d=0;for(const [e,f]of a)f===void 0?c.set(e,BigInt(0)):(a=f.length,b.set(f,d),c.set(e,BigInt(a)),d+=a)}};class fj extends Ah{constructor(a){super(a);this.o=new yh}setValue(a,b){this.o.set(a,+b)}};class gj extends Bh{}gj.prototype.B=nf;class hj extends gj{}hj.prototype.B=hf;class ij extends gj{}ij.prototype.B=jf;class jj extends Bh{}jj.prototype.B=yf;class kj extends Ah{constructor({type:a,nullValues:b,dictionaryHashFunction:c}){super({type:new Pe(a.dictionary,a.indices,a.id,a.isOrdered)});this.G=null;this.Da=0;this.zb=Object.create(null);this.indices=lj({type:this.type.indices,nullValues:b});this.dictionary=lj({type:this.type.dictionary,nullValues:null});typeof c==="function"&&(this.valueToKey=c)}get values(){return this.indices.values}get nullCount(){return this.indices.nullCount}get nullBitmap(){return this.indices.nullBitmap}get byteLength(){return this.indices.byteLength+
this.dictionary.byteLength}get reservedLength(){return this.indices.reservedLength+this.dictionary.reservedLength}get reservedByteLength(){return this.indices.reservedByteLength+this.dictionary.reservedByteLength}isValid(a){return this.indices.isValid(a)}setValid(a,b){const c=this.indices;b=c.setValid(a,b);this.length=c.length;return b}setValue(a,b){const c=this.zb,d=this.valueToKey(b);let e=c[d];e===void 0&&(c[d]=e=this.Da+this.dictionary.append(b).length-1);return this.indices.setValue(a,e)}flush(){var a=
this.type;const b=this.$b,c=this.dictionary.toVector();a=this.indices.flush().clone(a);a.dictionary=b?b.concat(c):c;this.finished||(this.Da+=c.length);this.$b=a.dictionary;this.clear();return a}finish(){this.indices.finish();this.dictionary.finish();this.Da=0;this.zb=Object.create(null);return super.finish()}clear(){this.indices.clear();this.dictionary.clear();return super.clear()}valueToKey(a){return typeof a==="string"?a:`${a}`}};class mj extends Bh{}mj.prototype.B=kf;class nj extends Ah{setValue(a,b){const [c]=this.children;a*=this.stride;for(let d=-1,e=this.stride;++d<e;)c.set(a+d,b[d])}setValid(a,b){super.setValid(a,b)||this.children[0].setValid((a+1)*this.stride-1,!1);return b}addChild(a,b="0"){if(this.numChildren>0)throw Error("FixedSizeListBuilder can only have one child.");const c=this.children.push(a);this.type=new Ge(this.type.listSize,new V(b,a.type,!0));return c}};class oj extends Bh{setValue(a,b){this.o.set(a,b)}}class pj extends oj{setValue(a,b){super.setValue(a,af(b))}}class qj extends oj{}class rj extends oj{};class sj extends Bh{}sj.prototype.B=Jf;class tj extends sj{}tj.prototype.B=Hf;class uj extends sj{}uj.prototype.B=Gf;class vj extends sj{}vj.prototype.B=If;class wj extends Bh{}wj.prototype.B=Of;class xj extends wj{}xj.prototype.B=Kf;class Aj extends wj{}Aj.prototype.B=Lf;class Bj extends wj{}Bj.prototype.B=Mf;class Cj extends wj{}Cj.prototype.B=Nf;class Dj extends Bh{setValue(a,b){this.o.set(a,b)}}class Ej extends Dj{}class Fj extends Dj{}class Gj extends Dj{}class Hj extends Dj{}class Ij extends Dj{}class Jj extends Dj{}class Kj extends Dj{}class Lj extends Dj{};class Mj extends Dh{constructor(a){super(a);this.j=new zh(a.type)}addChild(a,b="0"){if(this.numChildren>0)throw Error("ListBuilder can only have one child.");this.children[this.numChildren]=a;this.type=new oe(new V(b,a.type,!0));return this.numChildren-1}V(a){const b=this.j,[c]=this.children;for(const [d,e]of a)if(typeof e==="undefined")b.set(d,0);else{a=e;const f=a.length,g=b.set(d,f).buffer[d];for(let k=-1;++k<f;)c.set(g+k,a[k])}}};class Nj extends Dh{set(a,b){return super.set(a,b)}setValue(a,b){b=b instanceof Map?b:new Map(Object.entries(b));const c=this.I||(this.I=new Map),d=c.get(a);d&&(this.L-=d.size);this.L+=b.size;c.set(a,b)}addChild(a,b=`${this.numChildren}`){if(this.numChildren>0)throw Error("ListBuilder can only have one child.");this.children[this.numChildren]=a;this.type=new Ke(new V(b,a.type,!0),this.type.keysSorted);return this.numChildren-1}V(a){const b=this.j,[c]=this.children;for(const [d,e]of a)if(e===void 0)b.set(d,
0);else{let {[d]:f,[d+1]:g}=b.set(d,e.size).buffer;for(const k of e.entries())if(c.set(f,k),++f>=g)break}}};class Oj extends Ah{setValue(){}setValid(a,b){this.length=Math.max(a+1,this.length);return b}};class Pj extends Ah{setValue(a,b){const c=this.children,d=this.type;switch(Array.isArray(b)||b.constructor){case !0:return d.children.forEach((e,f)=>c[f].set(a,b[f]));case Map:return d.children.forEach((e,f)=>c[f].set(a,b.get(e.name)));default:return d.children.forEach((e,f)=>c[f].set(a,b[e.name]))}}setValid(a,b){super.setValid(a,b)||this.children.forEach(c=>c.setValid(a,b));return b}addChild(a,b=`${this.numChildren}`){const c=this.children.push(a);this.type=new se([...this.type.children,new V(b,
a.type,!0)]);return c}};class Qj extends Bh{}Qj.prototype.B=sf;class Rj extends Qj{}Rj.prototype.B=of;class Sj extends Qj{}Sj.prototype.B=pf;class Tj extends Qj{}Tj.prototype.B=qf;class Uj extends Qj{}Uj.prototype.B=rf;class Vj extends Bh{}Vj.prototype.B=xf;class Wj extends Vj{}Wj.prototype.B=tf;class Xj extends Vj{}Xj.prototype.B=uf;class Yj extends Vj{}Yj.prototype.B=vf;class Zj extends Vj{}Zj.prototype.B=wf;class ak extends Ah{constructor(a){super(a);this.ba=new xh(Int8Array,0,1);typeof a.valueToChildTypeId==="function"&&(this.Bb=a.valueToChildTypeId)}get typeIdToChildIndex(){return this.type.typeIdToChildIndex}append(a,b){return this.set(this.length,a,b)}set(a,b,c){c===void 0&&(c=this.Bb(this,b,a));this.setValue(a,b,c);return this}setValue(a,b,c){this.ba.set(a,c);let d;(d=this.children[this.type.typeIdToChildIndex[c]])==null||d.set(a,b);this.length=Math.max(a+1,this.length)}addChild(a,b=`${this.children.length}`){const c=
this.children.push(a),d=this.type,e=d.mode,f=d.typeIds;a=[...d.children,new V(b,a.type)];this.type=new we(e,[...f,c],a);return c}Bb(){throw Error("Cannot map UnionBuilder value to child typeId. Pass the `childTypeId` as the second argument to unionBuilder.append(), or supply a `valueToChildTypeId` function as part of the UnionBuilder constructor options.");}}class bk extends ak{}
class ck extends ak{constructor(a){super(a);this.j=new xh(Int32Array)}setValue(a,b,c){c=this.ba.set(a,c).buffer[a];c=this.getChildAt(this.type.typeIdToChildIndex[c]);const d=this.j.set(a,c.length).buffer[a];c==null||c.set(d,b);this.length=Math.max(a+1,this.length)}};class dk extends Dh{constructor(a){super(a);this.o=new wh(Uint8Array)}get byteLength(){let a=this.L+this.length*4;this.j&&(a+=this.j.byteLength);this.o&&(a+=this.o.byteLength);this.G&&(a+=this.G.byteLength);return a}setValue(a,b){return super.setValue(a,xa.encode(b))}V(){}}dk.prototype.V=dj.prototype.V;class ek extends Dh{constructor(a){super(a);this.o=new wh(Uint8Array)}get byteLength(){let a=this.L+this.length*4;this.j&&(a+=this.j.byteLength);this.o&&(a+=this.o.byteLength);this.G&&(a+=this.G.byteLength);return a}setValue(a,b){return super.setValue(a,xa.encode(b))}V(){}}ek.prototype.V=ej.prototype.V;class fk extends Ue{visitNull(){return Oj}visitBool(){return fj}visitInt(){return Dj}visitInt8(){return Ej}visitInt16(){return Fj}visitInt32(){return Gj}visitInt64(){return Hj}visitUint8(){return Ij}visitUint16(){return Jj}visitUint32(){return Kj}visitUint64(){return Lj}visitFloat(){return oj}visitFloat16(){return pj}visitFloat32(){return qj}visitFloat64(){return rj}visitUtf8(){return dk}visitLargeUtf8(){return ek}visitBinary(){return dj}visitLargeBinary(){return ej}visitFixedSizeBinary(){return mj}visitDate(){return gj}visitDateDay(){return hj}visitDateMillisecond(){return ij}visitTimestamp(){return Qj}visitTimestampSecond(){return Rj}visitTimestampMillisecond(){return Sj}visitTimestampMicrosecond(){return Tj}visitTimestampNanosecond(){return Uj}visitTime(){return Vj}visitTimeSecond(){return Wj}visitTimeMillisecond(){return Xj}visitTimeMicrosecond(){return Yj}visitTimeNanosecond(){return Zj}visitDecimal(){return jj}visitList(){return Mj}visitStruct(){return Pj}visitUnion(){return ak}visitDenseUnion(){return ck}visitSparseUnion(){return bk}visitDictionary(){return kj}visitInterval(){return sj}visitIntervalDayTime(){return tj}visitIntervalYearMonth(){return uj}visitIntervalMonthDayNano(){return vj}visitDuration(){return wj}visitDurationSecond(){return xj}visitDurationMillisecond(){return Aj}visitDurationMicrosecond(){return Bj}visitDurationNanosecond(){return Cj}visitFixedSizeList(){return nj}visitMap(){return Nj}}
const gk=new fk;function hk(a,b,c){return b===c||Array.isArray(b)&&Array.isArray(c)&&b.length===c.length&&b.every((d,e)=>a.compareFields(d,c[e]))}class ik extends Ue{compareSchemas(a,b){return a===b||b instanceof a.constructor&&hk(this,a.fields,b.fields)}compareFields(a,b){return a===b||b instanceof a.constructor&&a.name===b.name&&a.nullable===b.nullable&&this.visit(a.type,b.type)}}function jk(a,b){return b instanceof a.constructor}function kk(a,b){return a===b||jk(a,b)}
function lk(a,b){return a===b||jk(a,b)&&a.bitWidth===b.bitWidth&&a.isSigned===b.isSigned}function mk(a,b){return a===b||jk(a,b)&&a.precision===b.precision}function nk(a,b){return a===b||jk(a,b)&&a.unit===b.unit}function ok(a,b){return a===b||jk(a,b)&&a.unit===b.unit&&a.timezone===b.timezone}function pk(a,b){return a===b||jk(a,b)&&a.unit===b.unit&&a.bitWidth===b.bitWidth}
function qk(a,b){return a===b||jk(a,b)&&a.mode===b.mode&&a.typeIds.every((c,d)=>c===b.typeIds[d])&&hk(rk,a.children,b.children)}function sk(a,b){return a===b||jk(a,b)&&a.unit===b.unit}function tk(a,b){return a===b||jk(a,b)&&a.unit===b.unit}h=ik.prototype;h.visitNull=kk;h.visitBool=kk;h.visitInt=lk;h.visitInt8=lk;h.visitInt16=lk;h.visitInt32=lk;h.visitInt64=lk;h.visitUint8=lk;h.visitUint16=lk;h.visitUint32=lk;h.visitUint64=lk;h.visitFloat=mk;h.visitFloat16=mk;h.visitFloat32=mk;h.visitFloat64=mk;
h.visitUtf8=kk;h.visitLargeUtf8=kk;h.visitBinary=kk;h.visitLargeBinary=kk;h.visitFixedSizeBinary=function(a,b){return a===b||jk(a,b)&&a.byteWidth===b.byteWidth};h.visitDate=nk;h.visitDateDay=nk;h.visitDateMillisecond=nk;h.visitTimestamp=ok;h.visitTimestampSecond=ok;h.visitTimestampMillisecond=ok;h.visitTimestampMicrosecond=ok;h.visitTimestampNanosecond=ok;h.visitTime=pk;h.visitTimeSecond=pk;h.visitTimeMillisecond=pk;h.visitTimeMicrosecond=pk;h.visitTimeNanosecond=pk;h.visitDecimal=kk;
h.visitList=function(a,b){return a===b||jk(a,b)&&a.children.length===b.children.length&&hk(rk,a.children,b.children)};h.visitStruct=function(a,b){return a===b||jk(a,b)&&a.children.length===b.children.length&&hk(rk,a.children,b.children)};h.visitUnion=qk;h.visitDenseUnion=qk;h.visitSparseUnion=qk;h.visitDictionary=function(a,b){return a===b||jk(a,b)&&a.id===b.id&&a.isOrdered===b.isOrdered&&rk.visit(a.indices,b.indices)&&rk.visit(a.dictionary,b.dictionary)};h.visitInterval=sk;
h.visitIntervalDayTime=sk;h.visitIntervalYearMonth=sk;h.visitIntervalMonthDayNano=sk;h.visitDuration=tk;h.visitDurationSecond=tk;h.visitDurationMillisecond=tk;h.visitDurationMicrosecond=tk;h.visitDurationNanosecond=tk;h.visitFixedSizeList=function(a,b){return a===b||jk(a,b)&&a.listSize===b.listSize&&a.children.length===b.children.length&&hk(rk,a.children,b.children)};
h.visitMap=function(a,b){return a===b||jk(a,b)&&a.keysSorted===b.keysSorted&&a.children.length===b.children.length&&hk(rk,a.children,b.children)};const rk=new ik;function uk(a,b){return rk.compareSchemas(a,b)}function vk(a,b){return rk.visit(a,b)};function lj(a){var b=a.type;const c=new (gk.getVisitFn(b)())(a);if(b.children&&b.children.length>0){const d=a.children||[],e={nullValues:a.nullValues};a=Array.isArray(d)?(f,g)=>d[g]||e:({name:f})=>d[f]||e;for(const [f,g]of b.children.entries()){b=g.type;const k=a(g,f);c.children.push(lj(Object.assign({},k,{type:b})))}}return c}
function wk(a,b){if(a instanceof P||a instanceof N||a.type instanceof L||ArrayBuffer.isView(a))return rh(a);b={type:b!=null?b:xk(a),nullValues:[null]};a=[...yk(b)(a)];a=a.length===1?a[0]:a.reduce((c,d)=>c.concat(d));return L.isDictionary(a.type)?a.memoize():a}
function xk(a){if(a.length===0)return new Mc;var b=0;let c=0,d=0,e=0,f=0,g=0,k=0,m=0;for(const p of a)if(p==null)++b;else{switch(typeof p){case "bigint":++g;continue;case "boolean":++k;continue;case "number":++e;continue;case "string":++f;continue;case "object":Array.isArray(p)?++c:Object.prototype.toString.call(p)==="[object Date]"?++m:++d;continue}throw new TypeError("Unable to infer Vector type from input values, explicit type declaration expected.");}if(e+b===a.length)return new fd;if(f+b===a.length)return new Pe(new od,
new Uc);if(g+b===a.length)return new Vc;if(k+b===a.length)return new wd;if(m+b===a.length)return new Xd;if(c+b===a.length){const p=xk(a[a.findIndex(r=>r!=null)]);if(a.every(r=>r==null||vk(p,xk(r))))return new oe(new V("",p,!0))}else if(d+b===a.length){b=new Map;for(const p of a)for(const r of Object.keys(p))b.has(r)||p[r]==null||b.set(r,new V(r,xk([p[r]]),!0));return new se([...b.values()])}throw new TypeError("Unable to infer Vector type from input values, explicit type declaration expected.");}
function yk(a){const {queueingStrategy:b="count"}=a,{highWaterMark:c=b!=="bytes"?Number.POSITIVE_INFINITY:16384}=a,d=b!=="bytes"?"length":"byteLength";return function*(e){let f=0;const g=lj(a);for(const k of e)g.append(k)[d]>=c&&++f&&(yield g.toVector());if(g.finish().length>0||f===0)yield g.toVector()}};function zk(a,b){return Ak(a,b.map(c=>c.data.concat()))}function Ak(a,b){const c=[...a.fields],d=[],e={kb:b.reduce((T,ta)=>Math.max(T,ta.length),0)};let f=0,g=0,k=-1;const m=b.length;let p,r=[];for(;e.kb-- >0;){g=Number.POSITIVE_INFINITY;for(k=-1;++k<m;)r[k]=p=b[k].shift(),g=Math.min(g,p?p.length:g);Number.isFinite(g)&&(r=Bk(c,g,r,b,e),g>0&&(d[f++]=Q({type:new se(c),length:g,nullCount:0,children:r.slice()})))}return[a=a.assign(c),d.map(T=>new Y(a,T))]}
function Bk(a,b,c,d,e){const f=(b+63&-64)>>3;for(let k=-1,m=d.length;++k<m;){const p=c[k];let r;var g=(r=p)==null?void 0:r.length;if(g>=b)g===b?c[k]=p:(c[k]=p.slice(0,b),e.kb=Math.max(e.kb,d[k].unshift(p.slice(b,g-b))));else{g=a[k];a[k]=g.clone({nullable:!0});let T,ta;c[k]=(ta=(T=p)==null?void 0:Wg(T,b))!=null?ta:Q({type:g.type,length:b,nullCount:b,nullBitmap:new Uint8Array(f)})}}return c};class Ck{constructor(...a){if(a.length===0)return this.batches=[],this.schema=new U([]),this.j=[0],this;let b,c;a[0]instanceof U&&(b=a.shift());a.at(-1)instanceof Uint32Array&&(c=a.pop());const d=m=>{if(m){if(m instanceof Y)return[m];if(m instanceof Ck)return m.batches;if(m instanceof P){if(m.type instanceof se)return[new Y(new U(m.type.children),m)]}else{if(Array.isArray(m))return m.flatMap(r=>d(r));if(typeof m[Symbol.iterator]==="function")return[...m].flatMap(r=>d(r));if(typeof m==="object"){var p=
Object.keys(m);const r=p.map(La=>new N([m[La]]));let T;const ta=(T=b)!=null?T:new U(p.map((La,Pc)=>new V(String(La),r[Pc].type,r[Pc].nullable)));[,p]=zk(ta,r);return p.length===0?[new Y(m)]:p}}}return[]};a=a.flatMap(m=>d(m));let e,f,g;b=(g=(f=b)!=null?f:(e=a[0])==null?void 0:e.schema)!=null?g:new U([]);if(!(b instanceof U))throw new TypeError("Table constructor expects a [Schema, RecordBatch[]] pair.");for(const m of a){if(!(m instanceof Y))throw new TypeError("Table constructor expects a [Schema, RecordBatch[]] pair.");
if(!uk(b,m.schema))throw new TypeError("Table and inner RecordBatch schemas must be equivalent.");}this.schema=b;this.batches=a;let k;this.j=(k=c)!=null?k:bh(this.data)}get data(){return this.batches.map(({data:a})=>a)}get numCols(){return this.schema.fields.length}get numRows(){return this.data.reduce((a,b)=>a+b.length,0)}get nullCount(){this.R===-1&&(this.R=ah(this.data));return this.R}isValid(){return!1}get(){return null}at(a){return this.get(a<0?this.numRows+a:a)}set(){}indexOf(){return-1}[Symbol.iterator](){return this.batches.length>
0?nh.visit(new N(this.data)):[][Symbol.iterator]()}toArray(){return[...this]}toString(){return`[\n ${this.toArray().join(",\n ")}\n]`}concat(...a){const b=this.schema;a=this.data.concat(a.flatMap(({data:c})=>c));return new Ck(b,a.map(c=>new Y(b,c)))}slice(a,b){const c=this.schema;[a,b]=Cg({length:this.numRows},a,b);a=ch(this.data,this.j,a,b);return new Ck(c,a.map(d=>new Y(c,d)))}getChild(a){return this.getChildAt(this.schema.fields.findIndex(b=>b.name===a))}getChildAt(a){if(a>-1&&a<this.schema.fields.length){const c=
this.data.map(d=>d.children[a]);if(c.length===0){var {type:b}=this.schema.fields[a];b=Q({type:b,length:0,nullCount:0});c.push(Wg(b,this.numRows))}return new N(c)}return null}setChild(a,b){let c;return this.setChildAt((c=this.schema.fields)==null?void 0:c.findIndex(d=>d.name===a),b)}setChildAt(a,b){let c=this.schema;var d=[...this.batches];if(a>-1&&a<this.numCols){b||(b=new N([Q({type:new Mc,length:this.numRows})]));d=c.fields.slice();const e=d[a].clone({type:b.type}),f=this.schema.fields.map((g,k)=>
this.getChildAt(k));[d[a],f[a]]=[e,b];[c,d]=zk(c,f)}return new Ck(c,d)}select(a){const b=this.schema.fields.reduce((c,d,e)=>c.set(d.name,e),new Map);return this.selectAt(a.map(c=>b.get(c)).filter(c=>c>-1))}selectAt(a){const b=this.schema.selectAt(a),c=this.batches.map(d=>d.selectAt(a));return new Ck(b,c)}assign(a){const b=this.schema.fields,[c,d]=a.schema.fields.reduce((g,k,m)=>{const [p,r]=g,T=b.findIndex(ta=>ta.name===k.name);~T?r[T]=m:p.push(m);return g},[[],[]]),e=this.schema.assign(a.schema),
f=[...b.map((g,k)=>[k,d[k]]).map(([g,k])=>k===void 0?this.getChildAt(g):a.getChildAt(k)),...c.map(g=>a.getChildAt(g))].filter(Boolean);return new Ck(...zk(e,f))}}var Dk=Symbol.toStringTag,Ek=Ck.prototype;Ek.schema=null;Ek.batches=[];Ek.j=new Uint32Array([0]);Ek.R=-1;Ek[Symbol.isConcatSpreadable]=!0;Ek.isValid=fh(eh);Ek.get=fh(Tf.getVisitFn(I.Struct));Ek.set=gh(Df.getVisitFn(I.Struct));Ek.indexOf=hh(kh.getVisitFn(I.Struct));Ck[Dk]="Table";class Y{constructor(...a){switch(a.length){case 2:[this.schema]=a;if(!(this.schema instanceof U))throw new TypeError("RecordBatch constructor expects a [Schema, Data] pair.");[,this.data=Q({nullCount:0,type:new se(this.schema.fields),children:this.schema.fields.map(g=>Q({type:g.type,nullCount:0}))})]=a;if(!(this.data instanceof P))throw new TypeError("RecordBatch constructor expects a [Schema, Data] pair.");[this.schema,this.data]=Fk(this.schema,this.data.children);break;case 1:const [b]=a,{fields:c,
children:d,length:e}=Object.keys(b).reduce((g,k,m)=>{g.children[m]=b[k];g.length=Math.max(g.length,b[k].length);g.fields[m]=V.new({name:k,type:b[k].type,nullable:!0});return g},{length:0,fields:[],children:[]});a=new U(c);const f=Q({type:new se(c),length:e,children:d,nullCount:0});[this.schema,this.data]=Fk(a,f.children,e);break;default:throw new TypeError("RecordBatch constructor expects an Object mapping names to child Data, or a [Schema, Data] pair.");}}get dictionaries(){return this.Zb||(this.Zb=
Gk(this.schema.fields,this.data.children))}get numCols(){return this.schema.fields.length}get numRows(){return this.data.length}get nullCount(){return this.data.nullCount}isValid(a){return this.data.getValid(a)}get(a){return Tf.visit(this.data,a)}at(a){return this.get(a<0?this.numRows+a:a)}set(a,b){return Df.visit(this.data,a,b)}indexOf(a,b){return kh.visit(this.data,a,b)}[Symbol.iterator](){return nh.visit(new N([this.data]))}toArray(){return[...this]}concat(...a){return new Ck(this.schema,[this,
...a])}slice(a,b){[a]=(new N([this.data])).slice(a,b).data;return new Y(this.schema,a)}getChild(a){let b;return this.getChildAt((b=this.schema.fields)==null?void 0:b.findIndex(c=>c.name===a))}getChildAt(a){return a>-1&&a<this.schema.fields.length?new N([this.data.children[a]]):null}setChild(a,b){let c;return this.setChildAt((c=this.schema.fields)==null?void 0:c.findIndex(d=>d.name===a),b)}setChildAt(a,b){var c=this.schema,d=this.data;if(a>-1&&a<this.numCols){b||(b=new N([Q({type:new Mc,length:this.numRows})]));
const e=c.fields.slice();d=d.children.slice();c=e[a].clone({type:b.type});[e[a],d[a]]=[c,b.data[0]];c=new U(e,new Map(this.schema.metadata));d=Q({type:new se(e),children:d})}return new Y(c,d)}select(a){const b=this.schema.select(a),c=new se(b.fields),d=[];for(const e of a)a=this.schema.fields.findIndex(f=>f.name===e),~a&&(d[a]=this.data.children[a]);return new Y(b,Q({type:c,length:this.numRows,children:d}))}selectAt(a){const b=this.schema.selectAt(a);a=a.map(c=>this.data.children[c]).filter(Boolean);
a=Q({type:new se(b.fields),length:this.numRows,children:a});return new Y(b,a)}}var Hk=Symbol.toStringTag,Ik=Y.prototype;Ik.R=-1;Ik[Symbol.isConcatSpreadable]=!0;Y[Hk]="RecordBatch";
function Fk(a,b,c=b.reduce((d,e)=>Math.max(d,e.length),0)){const d=[...a.fields],e=[...b],f=(c+63&-64)>>3;for(const [g,k]of a.fields.entries()){const m=b[g];if(!m||m.length!==c){d[g]=k.clone({nullable:!0});let p,r;e[g]=(r=(p=m)==null?void 0:Wg(p,c))!=null?r:Q({type:k.type,length:c,nullCount:c,nullBitmap:new Uint8Array(f)})}}return[a.assign(d),Q({type:new se(d),length:c,children:e})]}
function Gk(a,b,c=new Map){var d;if(((d=a==null?void 0:a.length)!=null?d:0)>0&&(a==null?void 0:a.length)===(b==null?void 0:b.length))for(let f=-1,g=a.length;++f<g;){var {type:e}=a[f];d=b[f];let k,m;for(const p of[d,...(((k=d)==null?void 0:(m=k.dictionary)==null?void 0:m.data)||[])]){let r;Gk(e.children,(r=p)==null?void 0:r.children,c)}if(L.isDictionary(e))if(e=e.id,!c.has(e)){let p;((p=d)==null?0:p.dictionary)&&c.set(e,d.dictionary)}else if(c.get(e)!==d.dictionary)throw Error("Cannot create Schema containing two different dictionaries with the same Id");
}return c}class Jk extends Y{constructor(a){var b=a.fields.map(c=>Q({type:c.type}));b=Q({type:new se(a.fields),nullCount:0,children:b});super(a,b)}};const Kk=a=>`Expected ${H[a]} Message in stream, but was null or length 0.`,Lk=a=>`Header pointer of flatbuffer-encoded ${H[a]} Message is null or length 0.`,Mk=(a,b)=>`Expected to read ${a} metadata bytes, but only read ${b}.`,Nk=(a,b)=>`Expected to read ${a} bytes for message body, but only read ${b}.`;
class Ok{constructor(a){this.source=a instanceof Gi?a:new Gi(a)}[Symbol.iterator](){return this}next(){let a;return(a=this.readMetadataLength()).done||a.value===-1&&(a=this.readMetadataLength()).done||(a=this.readMetadata(a.value)).done?zi:a}throw(a){return this.source.throw(a)}return(a){return this.source.return(a)}readMessage(a){let b;if((b=this.next()).done)return null;if(a!=null&&b.value.headerType!==a)throw Error(Kk(a));return b.value}readMessageBody(a){if(a<=0)return new Uint8Array(0);var b=
this.source.read(a);b=u(Uint8Array,b);if(b.byteLength<a)throw Error(Nk(a,b.byteLength));return b.byteOffset%8===0&&b.byteOffset+b.byteLength<=b.buffer.byteLength?b:b.slice()}readSchema(a=!1){const b=H.Schema;let c;const d=(c=this.readMessage(b))==null?void 0:c.header();if(a&&!d)throw Error(Lk(b));return d}readMetadataLength(){var a=this.source.read(4);let b;a=((b=a&&new lb(a))==null?void 0:b.v(0))||0;return{done:a===0,value:a}}readMetadata(a){const b=this.source.read(a);if(!b)return zi;if(b.byteLength<
a)throw Error(Mk(a,b.byteLength));return{done:!1,value:ai.decode(b)}}}
class Pk{constructor(a,b){this.source=a instanceof Ii?a:t(a)&&q(a.stat)&&typeof a.fd==="number"?new Li(a,b):new Ii(a)}[Symbol.asyncIterator](){return this}next(){const a=this;return l(function*(){let b;return(b=yield a.readMetadataLength()).done||b.value===-1&&(b=yield a.readMetadataLength()).done||(b=yield a.readMetadata(b.value)).done?zi:b})}throw(a){const b=this;return l(function*(){return yield b.source.throw(a)})}return(a){const b=this;return l(function*(){return yield b.source.return(a)})}readMessage(a){const b=
this;return l(function*(){let c;if((c=yield b.next()).done)return null;if(a!=null&&c.value.headerType!==a)throw Error(Kk(a));return c.value})}readMessageBody(a){const b=this;return l(function*(){if(a<=0)return new Uint8Array(0);var c=yield b.source.read(a);c=u(Uint8Array,c);if(c.byteLength<a)throw Error(Nk(a,c.byteLength));return c.byteOffset%8===0&&c.byteOffset+c.byteLength<=c.buffer.byteLength?c:c.slice()})}readSchema(a=!1){const b=this;return l(function*(){const c=H.Schema;let d;const e=(d=yield b.readMessage(c))==
null?void 0:d.header();if(a&&!e)throw Error(Lk(c));return e})}readMetadataLength(){const a=this;return l(function*(){var b=yield a.source.read(4);let c;b=((c=b&&new lb(b))==null?void 0:c.v(0))||0;return{done:b===0,value:b}})}readMetadata(a){const b=this;return l(function*(){const c=yield b.source.read(a);if(!c)return zi;if(c.byteLength<a)throw Error(Mk(a,c.byteLength));return{done:!1,value:ai.decode(c)}})}}
class Qk extends Ok{constructor(a){super(new Uint8Array(0));this.U=!1;this.Ba=[];this.aa=this.ub=0;this.pa=a instanceof Ai?a:new Ai(a)}next(){var a=this.pa;if(!this.U)return this.U=!0,{done:!1,value:ai.fromJSON(a.schema,H.Schema)};if(this.aa<a.dictionaries.length)return a=a.dictionaries[this.aa++],this.Ba=a.data.columns,{done:!1,value:ai.fromJSON(a,H.DictionaryBatch)};if(this.ub<a.batches.length)return a=a.batches[this.ub++],this.Ba=a.columns,{done:!1,value:ai.fromJSON(a,H.RecordBatch)};this.Ba=[];
return zi}readMessageBody(){function a(b){return(b||[]).reduce((c,d)=>[...c,...(d.VALIDITY&&[d.VALIDITY]||[]),...(d.TYPE_ID&&[d.TYPE_ID]||[]),...(d.OFFSET&&[d.OFFSET]||[]),...(d.DATA&&[d.DATA]||[]),...a(d.children)],[])}return a(this.Ba)}readMessage(a){let b;if((b=this.next()).done)return null;if(a!=null&&b.value.headerType!==a)throw Error(Kk(a));return b.value}readSchema(){const a=H.Schema,b=this.readMessage(a),c=b==null?void 0:b.header();if(!b||!c)throw Error(Lk(a));return c}}const Rk=new Uint8Array(6);
for(let a=0;a<6;a+=1)Rk[a]="ARROW1".codePointAt(a);function Sk(a){for(let b=-1,c=Rk.length;++b<c;)if(Rk[b]!==a[0+b])return!1;return!0}const Tk=Rk.length,Uk=Tk+4,Vk=Tk*2+4;class Wk{constructor(){this.Tb=new Uint8Array([4,34,77,24]);this.Ra=7}Nb(a){const b=new Uint8Array([1,2,3,4,5,6,7,8]);a=a.encode(b);return this.Za(a)}Za(a){return this.Xa(a)&&this.Ya(a)&&(a[4]&192)>>6===1}Xa(a){return a.length>=this.Ra}Ya(a){return this.Tb.every((b,c)=>a[c]===b)}}
class Xk{constructor(){this.Vb=new Uint8Array([40,181,47,253]);this.Ra=6}Nb(a){const b=new Uint8Array([1,2,3,4,5,6,7,8]);a=a.encode(b);return this.Za(a)}Za(a){return this.Xa(a)&&this.Ya(a)}Xa(a){return a.length>=this.Ra}Ya(a){return this.Vb.every((b,c)=>a[c]===b)}}const Yk={[Cb.LZ4_FRAME]:new Wk,[Cb.ZSTD]:new Xk};class Zk{constructor(){this.registry={}}set(a,b){if((b==null?0:b.encode)&&typeof b.encode==="function"&&!Yk[a].Nb(b))throw Error(`Encoder for ${Cb[a]} is not valid.`);this.registry[a]=b}get(a){let b;return((b=this.registry)==null?void 0:b[a])||null}}const $k=new Zk;class al extends Di{constructor(a){super();this.u=a}get closed(){return this.u.closed}get schema(){return this.u.schema}get autoDestroy(){return this.u.autoDestroy}get dictionaries(){return this.u.dictionaries}get numDictionaries(){return this.u.numDictionaries}get numRecordBatches(){return this.u.numRecordBatches}get footer(){return this.u.isFile()?this.u.footer:null}isSync(){return this.u.isSync()}isAsync(){return this.u.isAsync()}isFile(){return this.u.isFile()}isStream(){return this.u.isStream()}next(){return this.u.next()}throw(a){return this.u.throw(a)}return(a){return this.u.return(a)}cancel(){return this.u.cancel()}reset(a){this.u.reset(a);
this.Ab=this.tb=void 0;return this}open(a){a=this.u.open(a);return t(a)&&q(a.then)?a.then(()=>this):this}readRecordBatch(a){return this.u.isFile()?this.u.readRecordBatch(a):null}[Symbol.iterator](){return this.u[Symbol.iterator]()}[Symbol.asyncIterator](){return this.u[Symbol.asyncIterator]()}toDOMStream(){return Ma(this.isSync()?{[Symbol.iterator]:()=>this}:{[Symbol.asyncIterator]:()=>this})}toNodeStream(){return Na(this.isSync()?{[Symbol.iterator]:()=>this}:{[Symbol.asyncIterator]:()=>this})}static throughNode(){throw Error('"throughNode" not available in this environment');
}static throughDOM(){throw Error('"throughDOM" not available in this environment');}static from(a){return a instanceof al?a:t(a)&&t(a.schema)?new bl(new cl(a)):t(a)&&q(a.stat)&&typeof a.fd==="number"?dl(a):t(a)&&q(a.then)?(()=>l(function*(){return yield al.from(yield a)}))():t(a)&&za(a.body)||za(a)||Aa(a)||t(a)&&q(a[Symbol.asyncIterator])?el(new Ii(a)):fl(new Gi(a))}static readAll(a){return a instanceof al?a.isSync()?gl(a):hl(a):t(a)&&t(a.schema)||ArrayBuffer.isView(a)||t(a)&&q(a[Symbol.iterator])||
t(a)&&"done"in a&&"value"in a?gl(a):hl(a)}}class bl extends al{constructor(a){super(a);this.u=a}readAll(){return[...this]}[Symbol.iterator](){return this.u[Symbol.iterator]()}[Symbol.asyncIterator](){const a=this;return new oa(function*(){yield new n(1,a[Symbol.iterator]())}())}}
class il extends al{constructor(a){super(a);this.u=a}readAll(){const a=this;return l(function*(){const b=[];var c;try{for(var d=ia(a);;){var e=yield d.next();if(e.done)break;b.push(e.value)}}catch(g){var f={error:g}}finally{try{e&&!e.done&&(c=d.return)&&(yield c.call(d))}finally{if(f)throw f.error;}}return b})}[Symbol.iterator](){throw Error("AsyncRecordBatchStreamReader is not Iterable");}[Symbol.asyncIterator](){return this.u[Symbol.asyncIterator]()}}
class jl extends bl{constructor(a){super(a);this.u=a}}class kl extends il{constructor(a){super(a);this.u=a}}function ll(a,b,c){const d=[],e=[];let f=0;for(const {offset:k,length:m}of a.buffers)if(m===0)d.push(new Uint8Array(0)),e.push(new Xh(f,0));else{var g=new lb(b.subarray(k,k+m));a=K(fb(g,0));g=g.bytes().subarray(8);a=a===-1?g:c.decode(g);d.push(a);f+=(f+7&-8)-f;e.push(new Xh(f,a.length));f+=a.length}return{Kb:d,buffers:e}}
function ml(a,b,c,d){return(new cj(c,b.H,b.buffers,a.dictionaries,a.schema.xa)).visitMany(d)}
function nl(a,b,c){if(b.compression!=null){const d=$k.get(b.compression.type);if((d==null?0:d.decode)&&typeof d.decode==="function"){const {Kb:e,buffers:f}=ll(b,c,d);c=ml(a,b,e,a.schema.fields);b=new Qh(b.length,b.H,f,null)}else throw Error("Record batch is compressed but codec not found");}else c=a.$a(b,c,a.schema.fields);b=Q({type:new se(a.schema.fields),length:b.length,children:c});return new Y(a.schema,b)}
function ol(a,b,c){const d=b.id,e=b.Oa;var f=a.schema;const g=a.dictionaries.get(d);f=f.dictionaries.get(d);if(b.data.compression!=null){const k=$k.get(b.data.compression.type);if((k==null?0:k.decode)&&typeof k.decode==="function"){const {Kb:m,buffers:p}=ll(b.data,c,k);a=ml(a,b.data,m,[f]);new di(new Qh(b.data.length,b.data.H,p,null),d,e)}else throw Error("Dictionary batch is compressed but codec not found");}else a=a.$a(b.data,c,[f]);return(g&&e?g.concat(new N(a)):new N(a)).memoize()}
class pl{get numDictionaries(){return this.aa}get numRecordBatches(){return this.S}constructor(a=new Map){this.closed=!1;this.autoDestroy=!0;this.S=this.aa=0;this.dictionaries=a}isSync(){return!1}isAsync(){return!1}isFile(){return!1}isStream(){return!1}reset(a){this.S=this.aa=0;this.schema=a;this.dictionaries=new Map;return this}$a(a,b,c){return(new $i(b,a.H,a.buffers,this.dictionaries,this.schema.xa)).visitMany(c)}}
class ql extends pl{constructor(a){super();this.A=t(a)&&t(a.schema)?new Qk(this.K=a):new Ok(this.K=a)}isSync(){return!0}isStream(){return!0}[Symbol.iterator](){return this}cancel(){!this.closed&&(this.closed=!0)&&(this.reset().A.return(),this.dictionaries=this.A=null)}open(a){this.closed||(this.autoDestroy=rl(this,a),this.schema||(this.schema=this.A.readSchema())||this.cancel());return this}throw(a){return!this.closed&&this.autoDestroy&&(this.closed=!0)?this.reset().A.throw(a):zi}return(a){return!this.closed&&
this.autoDestroy&&(this.closed=!0)?this.reset().A.return(a):zi}next(){if(this.closed)return zi;for(var a,b=this.A;a=this.ra();)if(a.isSchema())this.reset(a.header());else{if(a.isRecordBatch()){this.S++;var c=a.header();b=b.readMessageBody(a.bodyLength);return{done:!1,value:nl(this,c,b)}}a.isDictionaryBatch()&&(this.aa++,c=a.header(),a=b.readMessageBody(a.bodyLength),a=ol(this,c,a),this.dictionaries.set(c.id,a))}return this.schema&&this.S===0?(this.S++,{done:!1,value:new Jk(this.schema)}):this.return()}ra(){return this.A.readMessage(void 0)}}
class sl extends pl{constructor(a,b){super(b);this.A=new Pk(this.K=a)}isAsync(){return!0}isStream(){return!0}[Symbol.asyncIterator](){return this}cancel(){const a=this;return l(function*(){!a.closed&&(a.closed=!0)&&(yield a.reset().A.return(),a.A=null,a.dictionaries=null)})}open(a){const b=this;return l(function*(){b.closed||(b.autoDestroy=rl(b,a),b.schema||(b.schema=yield b.A.readSchema())||(yield b.cancel()));return b})}throw(a){const b=this;return l(function*(){return!b.closed&&b.autoDestroy&&
(b.closed=!0)?yield b.reset().A.throw(a):zi})}return(a){const b=this;return l(function*(){return!b.closed&&b.autoDestroy&&(b.closed=!0)?yield b.reset().A.return(a):zi})}next(){const a=this;return l(function*(){if(a.closed)return zi;for(var b,c=a.A;b=yield a.ra();)if(b.isSchema())yield a.reset(b.header());else{if(b.isRecordBatch()){a.S++;var d=b.header();c=yield c.readMessageBody(b.bodyLength);return{done:!1,value:nl(a,d,c)}}b.isDictionaryBatch()&&(a.aa++,d=b.header(),b=yield c.readMessageBody(b.bodyLength),
b=ol(a,d,b),a.dictionaries.set(d.id,b))}return a.schema&&a.S===0?(a.S++,{done:!1,value:new Jk(a.schema)}):yield a.return()})}ra(){const a=this;return l(function*(){return yield a.A.readMessage(void 0)})}}
class tl extends ql{get footer(){return this.m}get numDictionaries(){return this.m?this.m.numDictionaries:0}get numRecordBatches(){return this.m?this.m.numRecordBatches:0}constructor(a){super(a instanceof Ki?a:new Ki(a))}isSync(){return!0}isFile(){return!0}open(a){if(!this.closed&&!this.m){this.schema=(this.m=this.eb()).schema;for(const b of Ih(this.m))b&&this.cb(this.aa++)}return super.open(a)}readRecordBatch(a){if(this.closed)return null;this.m||this.open();var b;const c=(b=this.m)==null?void 0:
b.ia(a);return c&&this.K.seek(c.offset)&&(b=this.A.readMessage(H.RecordBatch),b==null?0:b.isRecordBatch())?(a=b.header(),b=this.A.readMessageBody(b.bodyLength),nl(this,a,b)):null}cb(a){var b;const c=(b=this.m)==null?void 0:b.Na(a);c&&this.K.seek(c.offset)&&(b=this.A.readMessage(H.DictionaryBatch),b==null?0:b.isDictionaryBatch())&&(a=b.header(),b=this.A.readMessageBody(b.bodyLength),b=ol(this,a,b),this.dictionaries.set(a.id,b))}eb(){var a=this.K;const b=a.size-Uk,c=a.v(b);a=a.ja(b-c,c);return Jh.decode(a)}ra(){this.m||
this.open();if(this.m&&this.S<this.numRecordBatches){let a;const b=(a=this.m)==null?void 0:a.ia(this.S);if(b&&this.K.seek(b.offset))return this.A.readMessage(void 0)}return null}}
class ul extends sl{get footer(){return this.m}get numDictionaries(){return this.m?this.m.numDictionaries:0}get numRecordBatches(){return this.m?this.m.numRecordBatches:0}constructor(a){var b=[];const c=typeof b[0]!=="number"?b.shift():void 0;b=b[0]instanceof Map?b.shift():void 0;super(a instanceof Li?a:new Li(a,c),b)}isFile(){return!0}isAsync(){return!0}open(a){const b=this,c=()=>super.open;return l(function*(){if(!b.closed&&!b.m){b.schema=(b.m=yield b.eb()).schema;for(const d of Ih(b.m))d&&(yield b.cb(b.aa++))}return yield c().call(b,
a)})}readRecordBatch(a){const b=this;return l(function*(){if(b.closed)return null;b.m||(yield b.open());var c,d=(c=b.m)==null?void 0:c.ia(a);return d&&(yield b.K.seek(d.offset))&&(d=yield b.A.readMessage(H.RecordBatch),d==null?0:d.isRecordBatch())?(c=d.header(),d=yield b.A.readMessageBody(d.bodyLength),nl(b,c,d)):null})}cb(a){const b=this;return l(function*(){var c,d=(c=b.m)==null?void 0:c.Na(a);d&&(yield b.K.seek(d.offset))&&(d=yield b.A.readMessage(H.DictionaryBatch),d==null?0:d.isDictionaryBatch())&&
(c=d.header(),d=yield b.A.readMessageBody(d.bodyLength),d=ol(b,c,d),b.dictionaries.set(c.id,d))})}eb(){const a=this;return l(function*(){var b=a.K;b.I&&(yield b.I);const c=b.size-Uk,d=yield b.v(c);b=yield b.ja(c-d,d);return Jh.decode(b)})}ra(){const a=this;return l(function*(){a.m||(yield a.open());if(a.m&&a.S<a.numRecordBatches){const b=a.m.ia(a.S);if(b&&(yield a.K.seek(b.offset)))return yield a.A.readMessage(void 0)}return null})}}
class cl extends ql{$a(a,b,c){return(new aj(b,a.H,a.buffers,this.dictionaries,this.schema.xa)).visitMany(c)}}function rl(a,b){return b&&typeof b.autoDestroy==="boolean"?b.autoDestroy:a.autoDestroy}function*gl(a){a=al.from(a);try{if(!a.open({autoDestroy:!1}).closed){do yield a;while(!a.reset().open().closed)}}finally{a.cancel()}}
function hl(a){return new oa(function*(){const b=yield new n(2,al.from(a));try{if(!(yield new n(2,b.open({autoDestroy:!1}))).closed){do yield new n(0,b);while(!(yield new n(2,b.reset().open())).closed)}}finally{yield new n(2,b.cancel())}}())}function fl(a){const b=a.peek(Tk+7&-8);return b&&b.byteLength>=4?Sk(b)?new jl(new tl(a.read())):new bl(new ql(a)):new bl(new ql(function*(){}()))}
function el(a){return l(function*(){const b=yield a.peek(Tk+7&-8);return b&&b.byteLength>=4?Sk(b)?new jl(new tl(yield a.read())):new il(new sl(a)):new il(new sl(function(){return new oa(function*(){}())}()))})}function dl(a){return l(function*(){const {size:b}=yield a.stat(),c=new Li(a,b);return b>=Vk&&Sk(yield c.ja(0,Tk+7&-8))?new kl(new ul(c)):new il(new sl(c))})};class vl extends Ue{static Ka(...a){const b=d=>d.flatMap(e=>Array.isArray(e)?b(e):e instanceof Y?e.data.children:e.data),c=new vl;c.visitMany(b(a));return c}constructor(){super();this.Ca=0;this.ab=[];this.Sa=[];this.Xb=[]}visit(a){if(a instanceof N)return this.visitMany(a.data),this;const b=a.type;if(!L.isDictionary(b)){const c=a.length;if(c>2147483647)throw new RangeError("Cannot write arrays larger than 2^31 - 1 in length");if(L.isUnion(b))this.H.push(new Vh(c,0));else{const d=a.nullCount;L.isNull(b)||
wl.call(this,d<=0?new Uint8Array(0):Og(a.offset,c,a.nullBitmap));this.H.push(new Vh(c,d))}}return super.visit(a)}visitNull(){return this}visitDictionary(a){return this.visit(a.clone(a.type.indices))}get H(){return this.ab}get buffers(){return this.Sa}get byteLength(){return this.Ca}get fa(){return this.Xb}}function wl(a){const b=a.byteLength+7&-8;this.buffers.push(a);this.fa.push(new Xh(this.Ca,b));this.Ca+=b;return this}function xl(a){return wl.call(this,a.values.subarray(0,a.length*a.stride))}
function yl(a){const b=a.length,c=a.values;a=a.valueOffsets;const d=K(a[0]);var e=K(a[b]);e=Math.min(e-d,c.byteLength-d);wl.call(this,Ja(-d,b+1,a));wl.call(this,c.subarray(d,d+e));return this}function zl(a){const b=a.length,c=a.valueOffsets;if(c){const {[0]:d,[b]:e}=c;wl.call(this,Ja(-d,b+1,c));return this.visit(a.children[0].slice(d,e-d))}return this.visit(a.children[0])}function Al(a){return this.visitMany(a.type.children.map((b,c)=>a.children[c]).filter(Boolean))[0]}h=vl.prototype;
h.visitBool=function(a){let b;return a.nullCount>=a.length?wl.call(this,new Uint8Array(0)):(b=a.values)instanceof Uint8Array?wl.call(this,Og(a.offset,a.length,b)):wl.call(this,Pg(a.values))};h.visitInt=xl;h.visitFloat=xl;h.visitUtf8=yl;h.visitLargeUtf8=yl;h.visitBinary=yl;h.visitLargeBinary=yl;h.visitFixedSizeBinary=xl;h.visitDate=xl;h.visitTimestamp=xl;h.visitTime=xl;h.visitDecimal=xl;h.visitList=zl;h.visitStruct=Al;
h.visitUnion=function(a){const b=a.type,c=a.length,d=a.typeIds,e=a.valueOffsets;wl.call(this,d);if(b.mode===x.Sparse)return Al.call(this,a);if(b.mode===x.Dense){if(a.offset<=0)return wl.call(this,e),Al.call(this,a);const f=new Int32Array(c),g=Object.create(null),k=Object.create(null);for(let m,p,r=-1;++r<c;){if((m=d[r])===void 0)continue;(p=g[m])===void 0&&(p=g[m]=e[r]);f[r]=e[r]-p;let T;k[m]=((T=k[m])!=null?T:0)+1}wl.call(this,f);this.visitMany(a.children.map((m,p)=>{p=b.typeIds[p];return m.slice(g[p],
Math.min(c,k[p]))}))}return this};h.visitInterval=xl;h.visitDuration=xl;h.visitFixedSizeList=zl;h.visitMap=zl;class Bl extends Ue{visit(a){return a==null?void 0:super.visit(a)}visitNull({typeId:a}){return{name:F[a].toLowerCase()}}visitInt({typeId:a,bitWidth:b,isSigned:c}){return{name:F[a].toLowerCase(),bitWidth:b,isSigned:c}}visitFloat({typeId:a,precision:b}){return{name:F[a].toLowerCase(),precision:y[b]}}visitBinary({typeId:a}){return{name:F[a].toLowerCase()}}visitLargeBinary({typeId:a}){return{name:F[a].toLowerCase()}}visitBool({typeId:a}){return{name:F[a].toLowerCase()}}visitUtf8({typeId:a}){return{name:F[a].toLowerCase()}}visitLargeUtf8({typeId:a}){return{name:F[a].toLowerCase()}}visitDecimal({typeId:a,
scale:b,precision:c,bitWidth:d}){return{name:F[a].toLowerCase(),scale:b,precision:c,bitWidth:d}}visitDate({typeId:a,unit:b}){return{name:F[a].toLowerCase(),unit:Ya[b]}}visitTime({typeId:a,unit:b,bitWidth:c}){return{name:F[a].toLowerCase(),unit:z[b],bitWidth:c}}visitTimestamp({typeId:a,timezone:b,unit:c}){return{name:F[a].toLowerCase(),unit:z[c],timezone:b}}visitInterval({typeId:a,unit:b}){return{name:F[a].toLowerCase(),unit:A[b]}}visitDuration({typeId:a,unit:b}){return{name:F[a].toLocaleLowerCase(),
unit:z[b]}}visitList({typeId:a}){return{name:F[a].toLowerCase()}}visitStruct({typeId:a}){return{name:F[a].toLowerCase()}}visitUnion({typeId:a,mode:b,typeIds:c}){return{name:F[a].toLowerCase(),mode:x[b].toUpperCase(),typeIds:[...c]}}visitDictionary(a){return this.visit(a.dictionary)}visitFixedSizeBinary({typeId:a,byteWidth:b}){return{name:F[a].toLowerCase(),byteWidth:b}}visitFixedSizeList({typeId:a,listSize:b}){return{name:F[a].toLowerCase(),listSize:b}}visitMap({typeId:a,keysSorted:b}){return{name:F[a].toLowerCase(),
keysSorted:b}}};class Cl extends Ue{static Ka(...a){const b=new Cl;return a.map(({schema:c,data:d})=>b.visitMany(c.fields,d.children))}visit({name:a},b){const c=b.length,d=b.offset,e=b.nullCount,f=b.nullBitmap,g=L.isDictionary(b.type)?b.type.indices:b.type,k=Object.assign([],b.buffers,{[sc.VALIDITY]:void 0});return Object.assign({},{name:a,count:c,VALIDITY:L.isNull(g)||L.isUnion(g)?void 0:e<=0?Array.from({length:c},()=>1):[...(new Qg(f,d,c,null,Ng))]},super.visit(b.clone(g,d,c,0,k)))}visitNull(){return{}}visitBool({values:a,
offset:b,length:c}){return{DATA:[...(new Qg(a,b,c,null,Mg))]}}visitInt(a){return{DATA:a.type.bitWidth<64?[...a.values]:[...Dl(a.values,2)]}}visitFloat(a){return{DATA:[...a.values]}}visitUtf8(a){return{DATA:[...(new N([a]))],OFFSET:[...a.valueOffsets]}}visitLargeUtf8(a){return{DATA:[...(new N([a]))],OFFSET:[...Dl(a.valueOffsets,2)]}}visitBinary(a){return{DATA:[...El(new N([a]))],OFFSET:[...a.valueOffsets]}}visitLargeBinary(a){return{DATA:[...El(new N([a]))],OFFSET:[...Dl(a.valueOffsets,2)]}}visitFixedSizeBinary(a){return{DATA:[...El(new N([a]))]}}visitDate(a){return{DATA:a.type.unit===
Ya.DAY?[...a.values]:[...Dl(a.values,2)]}}visitTimestamp(a){return{DATA:[...Dl(a.values,2)]}}visitTime(a){return{DATA:a.type.unit<z.MICROSECOND?[...a.values]:[...Dl(a.values,2)]}}visitDecimal(a){return{DATA:[...Dl(a.values,4)]}}visitList(a){return{OFFSET:[...a.valueOffsets],children:this.visitMany(a.type.children,a.children)}}visitStruct(a){return{children:this.visitMany(a.type.children,a.children)}}visitUnion(a){return{TYPE_ID:[...a.typeIds],OFFSET:a.type.mode===x.Dense?[...a.valueOffsets]:void 0,
children:this.visitMany(a.type.children,a.children)}}visitInterval(a){switch(a.type.unit){case A.YEAR_MONTH:return{DATA:[...a.values]};case A.DAY_TIME:return{DATA:Wi(a.values)};case A.MONTH_DAY_NANO:return{DATA:Xi(a.values,!0)}}}visitDuration(a){return{DATA:[...Dl(a.values,2)]}}visitFixedSizeList(a){return{children:this.visitMany(a.type.children,a.children)}}visitMap(a){return{OFFSET:[...a.valueOffsets],children:this.visitMany(a.type.children,a.children)}}}
function*El(a){for(const b of a)yield b.reduce((c,d)=>`${c}${("0"+(d&255).toString(16)).slice(-2)}`,"").toUpperCase()}function*Dl(a,b){a=new Uint32Array(a.buffer);for(let c=-1,d=a.length/b;++c<d;)yield`${Hc.new(a.subarray((c+0)*b,(c+1)*b),!1)}`};function Fl(a,b){a.sa&&(b=u(Uint8Array,b))&&b.byteLength>0&&(a.J.write(b),a.qa+=b.byteLength);return a}function Gl(a,b){return b>0?Fl(a,new Uint8Array(b)):a}
function Hl(a,b){let {byteLength:c,H:d,fa:e,buffers:f}=vl.Ka(b);if(a.P!=null){var g=f;b=$k.get(a.P.type);if(b==null||!b.encode||typeof b.encode!=="function")throw Error(`Codec for compression type "${Cb[a.P.type]}" has invalid encode method`);a=0;const p=[],r=[];for(const T of g){var k=u(Uint8Array,T);if(k.length===0)p.push(new Uint8Array(0),new Uint8Array(0)),r.push(new Xh(a,0));else{var m=b.encode(k);k=(g=m.length<k.length)?m:k;g=g?k.length:-1;m=new lb(new Uint8Array(8));m.$(0,BigInt(g));p.push(m.bytes(),
new Uint8Array(k));a+=(a+7&-8)-a;g=8+k.length;r.push(new Xh(a,g));a+=g}}({byteLength:c,fa:e,buffers:f}={byteLength:a+((a+7&-8)-a),fa:r,buffers:p})}return{byteLength:c,H:d,fa:e,buffers:f}}function Il(a,b){const c=a.P!=null?2:1,d=Array(c);for(let f=0;f<b.length;f+=c){var e=0;for(let g=-1;++g<c;)d[g]=b[f+g],e+=d[g].byteLength;if(e!==0){for(const g of d)Fl(a,g);e=(e+7&-8)-e;e>0&&Gl(a,e)}}return a}
class Jl extends Di{static throughNode(){throw Error('"throughNode" not available in this environment');}static throughDOM(){throw Error('"throughDOM" not available in this environment');}constructor(a){super();this.qa=0;this.sa=!1;this.P=null;this.J=new Fi;this.U=null;this.oa=[];this.Ea=[];this.Ga=new Map;this.Va=new Map;t(a)||(a={autoDestroy:!0,Rb:!1,va:null});this.Aa=typeof a.autoDestroy==="boolean"?a.autoDestroy:!0;this.ua=typeof a.Rb==="boolean"?a.Rb:!1;if(a.va!=null){if(this.ua)throw Error("Legacy IPC format does not support columnar compression. Use modern IPC format (writeLegacyIpcFormat=false).");
if(Object.values(Cb).includes(a.va))this.P=new ei(a.va);else{const b=Object.values(Cb).filter(c=>typeof c==="string");throw Error(`Unsupported compressionType: ${a.va} Available types: ${b.join(", ")}`);}}else this.P=null}toString(a=!1){return this.J.toString(a)}toUint8Array(a=!1){return this.J.toUint8Array(a)}writeAll(a){return t(a)&&q(a.then)?a.then(b=>this.writeAll(b)):t(a)&&q(a[Symbol.asyncIterator])?Kl(this,a):Ll(this,a)}get closed(){return this.J.closed}[Symbol.asyncIterator](){return this.J[Symbol.asyncIterator]()}toDOMStream(a){return this.J.toDOMStream(a)}toNodeStream(a){return this.J.toNodeStream(a)}close(){return this.reset().J.close()}abort(a){return this.reset().J.abort(a)}finish(){this.Aa?
this.close():this.reset(this.J,this.U);return this}reset(a=this.J,b=null){a===this.J||a instanceof Fi?this.J=a:(this.J=new Fi,a&&t(a)&&q(a.abort)&&q(a.getWriter)&&!ya(a)?this.toDOMStream({type:"bytes"}).pipeTo(a):a&&t(a)&&q(a.end)&&q(a.write)&&typeof a.writable==="boolean"&&!ya(a)&&Ci(this.toNodeStream({uc:!1}),a));this.sa&&this.U&&this.Ia(this.U);this.sa=!1;this.oa=[];this.Ea=[];this.Ga=new Map;this.Va=new Map;b&&uk(b,this.U)||(b==null?(this.qa=0,this.U=null):(this.sa=!0,this.U=b,this.fb(b)));return this}write(a){let b=
null;if(this.J){if(a==null||a instanceof Ck&&!(b=a.schema)||a instanceof Y&&!(b=a.schema))return this.finish()&&void 0}else throw Error("RecordBatchWriter is closed");if(b&&!uk(b,this.U)){if(this.sa&&this.Aa)return this.close();this.reset(this.J,b)}a instanceof Y?a instanceof Jk||this.Cb(a):a instanceof Ck?this.writeAll(a.batches):t(a)&&q(a[Symbol.iterator])&&this.writeAll(a)}Ja(a){const b=ai.encode(a),c=b.byteLength,d=this.ua?4:8,e=c+d+7&-8,f=e-c-d;a.headerType===H.RecordBatch?this.Ea.push(new Lh(e,
a.bodyLength,this.qa)):a.headerType===H.DictionaryBatch&&this.oa.push(new Lh(e,a.bodyLength,this.qa));this.ua||Fl(this,Int32Array.of(-1));Fl(this,Int32Array.of(e-d));c>0&&Fl(this,b);return Gl(this,f)}fb(a){this.Ja(ai.from(a))}Ia(){return this.ua?Fl(this,Int32Array.of(0)):Fl(this,Int32Array.of(-1,0))}Cb(a){const {byteLength:b,H:c,fa:d,buffers:e}=Hl(this,a);var f=new Qh(a.numRows,c,d,this.P);f=ai.from(f,b);Il(this.Ha(a).Ja(f),e)}ta(a,b,c=!1){const {byteLength:d,H:e,fa:f,buffers:g}=Hl(this,new N([a]));
a=new Qh(a.length,e,f,this.P);b=new di(a,b,c);b=ai.from(b,d);return Il(this.Ja(b),g)}Ha(a){for(const [b,c]of a.dictionaries){let d,e;a=(e=(d=c)==null?void 0:d.data)!=null?e:[];const f=this.Ga.get(b);let g;const k=(g=this.Va.get(b))!=null?g:0;if(!f||f.data[0]!==a[0])for(const [m,p]of a.entries())this.ta(p,b,m>0);else if(k<a.length)for(const m of a.slice(k))this.ta(m,b,!0);this.Ga.set(b,c);this.Va.set(b,a.length)}return this}}
class Ml extends Jl{static writeAll(a,b){const c=new Ml(b);return t(a)&&q(a.then)?a.then(d=>c.writeAll(d)):t(a)&&q(a[Symbol.asyncIterator])?Kl(c,a):Ll(c,a)}}
class Nl extends Jl{static writeAll(a,b){const c=new Nl(b);return t(a)&&q(a.then)?a.then(d=>c.writeAll(d)):t(a)&&q(a[Symbol.asyncIterator])?Kl(c,a):Ll(c,a)}constructor(a){super(a);this.Aa=!0;this.ua=!1}fb(){Gl(Fl(this,Rk),2)}ta(a,b,c=!1){if(!c&&this.Ga.has(b))throw Error("The Arrow File format does not support replacement dictionaries. ");return super.ta(a,b,c)}Ia(a){const b=Jh.encode(new Jh(a,w.V5,this.Ea,this.oa));a=Fl(Fl(super.Ia(a),b),Int32Array.of(b.byteLength));return Fl(a,Rk)}}
class Ol extends Jl{static writeAll(a){return(new Ol).writeAll(a)}constructor(){super();this.Aa=!0;this.ca=[];this.Fa=[]}Ja(){return this}Ia(){return this}fb(a){Fl(this,`{\n "schema": ${JSON.stringify({fields:a.fields.map(b=>Pl(b))},null,2)}`)}Ha(a){a.dictionaries.size>0&&this.Fa.push(a);return this}ta(a,b,c=!1){Fl(this,this.oa.length===0?" ":",\n ");Fl(this,Ql(a,b,c));this.oa.push(new Lh(0,0,0));return this}Cb(a){this.Ha(a);this.ca.push(a)}close(){if(this.Fa.length>0){Fl(this,',\n "dictionaries": [\n');
for(var a of this.Fa)super.Ha(a);Fl(this,"\n ]")}if(this.ca.length>0){for(let b=-1,c=this.ca.length;++b<c;){Fl(this,b===0?',\n "batches": [\n ':",\n ");a=this.ca[b];const [d]=Cl.Ka(a);a=JSON.stringify({count:a.numRows,columns:d},null,2);Fl(this,a);this.Ea.push(new Lh(0,0,0))}Fl(this,"\n ]")}this.U&&Fl(this,"\n}");this.Fa=[];this.ca=[];return super.close()}}function Ll(a,b){let c=b;b instanceof Ck&&(c=b.batches,a.reset(void 0,b.schema));for(const d of c)a.write(d);return a.finish()}
function Kl(a,b){return l(function*(){var c;try{for(var d=ia(b);;){var e=yield d.next();if(e.done)break;a.write(e.value)}}catch(g){var f={error:g}}finally{try{e&&!e.done&&(c=d.return)&&(yield c.call(d))}finally{if(f)throw f.error;}}return a.finish()})}function Pl({name:a,type:b,nullable:c}){const d=new Bl;return{name:a,nullable:c,type:d.visit(b),children:(b.children||[]).map(e=>Pl(e)),dictionary:L.isDictionary(b)?{id:b.id,isOrdered:b.isOrdered,indexType:d.visit(b.indices)}:void 0}}
function Ql(a,b,c=!1){const [d]=Cl.Ka(new Y({[b]:a}));return JSON.stringify({id:b,isDelta:c,data:{count:a.length,columns:d}},null,2)};function Rl(a,b){function c(g,k){let m,p,r=g.desiredSize||null;for(;!(p=k.next(e?r:null)).done;)if(ArrayBuffer.isView(p.value)&&(m=u(Uint8Array,p.value))&&(r!=null&&e&&(r=r-m.byteLength+1),p.value=m),g.enqueue(p.value),r!=null&&--r<=0)return;g.close()}let d=null;const e=(b==null?void 0:b.type)==="bytes"||!1,f=(b==null?void 0:b.highWaterMark)||16777216;return new ReadableStream(Object.assign({},b,{start(g){c(g,d||(d=a[Symbol.iterator]()))},pull(g){d?c(g,d):g.close()},cancel(){let g;((g=d)==null?0:
g.return)&&d.return();d=null}}),Object.assign({},{highWaterMark:e?f:void 0},b))}
function Sl(a,b){function c(g,k){return l(function*(){let m,p,r=g.desiredSize||null;for(;!(p=yield k.next(e?r:null)).done;)if(ArrayBuffer.isView(p.value)&&(m=u(Uint8Array,p.value))&&(r!=null&&e&&(r=r-m.byteLength+1),p.value=m),g.enqueue(p.value),r!=null&&--r<=0)return;g.close()})}let d=null;const e=(b==null?void 0:b.type)==="bytes"||!1,f=(b==null?void 0:b.highWaterMark)||16777216;return new ReadableStream(Object.assign({},b,{start(g){return l(function*(){yield c(g,d||(d=a[Symbol.asyncIterator]()))})},
pull(g){return l(function*(){d?yield c(g,d):g.close()})},cancel(){return l(function*(){let g;((g=d)==null?0:g.return)&&(yield d.return());d=null})}}),Object.assign({},{highWaterMark:e?f:void 0},b))};function Tl(a,b,c){c!=null&&(a.ma>=c.desiredSize&&++a.bb&&Ul(a,c,b.toVector()),b.finished&&((b.length>0||a.bb===0)&&++a.bb&&Ul(a,c,b.toVector()),!a.xb&&(a.xb=!0)&&Ul(a,c,null)))}function Ul(a,b,c){a.ma=0;a.na=null;c==null?b.close():b.enqueue(c)}
class Vl{constructor(a){this.bb=0;this.xb=!1;this.ma=0;var b=Object.assign({},a),c=a.readableStrategy,d=a.writableStrategy;a=a.queueingStrategy;a=a===void 0?"count":a;b=(delete b.readableStrategy,delete b.writableStrategy,delete b.queueingStrategy,b);this.na=null;this.ea=lj(b);this.ac=a!=="bytes"?Wl:Xl;({highWaterMark:c=a==="bytes"?16384:1E3}=Object.assign({},c));({highWaterMark:d=a==="bytes"?16384:1E3}=Object.assign({},d));this.readable=new ReadableStream({cancel:()=>{this.ea.clear()},pull:e=>{Tl(this,
this.ea,this.na=e)},start:e=>{Tl(this,this.ea,this.na=e)}},{highWaterMark:c,size:a!=="bytes"?Wl:Xl});this.writable=new WritableStream({abort:()=>{this.ea.clear()},write:()=>{Tl(this,this.ea,this.na)},close:()=>{Tl(this,this.ea.finish(),this.na)}},{highWaterMark:d,size:e=>{const f=this.ma;this.ma=this.ac(this.ea.append(e));return this.ma-f}})}}const Wl=a=>{let b;return(b=a==null?void 0:a.length)!=null?b:0},Xl=a=>{let b;return(b=a==null?void 0:a.byteLength)!=null?b:0};function Yl(a,b){function c(){return l(function*(){return yield(yield al.from(e)).open(b)})}function d(k,m){return l(function*(){let p=k.desiredSize,r;for(;!(r=yield m.next()).done;)if(k.enqueue(r.value),p!=null&&--p<=0)return;k.close()})}const e=new Fi;let f=null;const g=new ReadableStream({cancel(){return l(function*(){yield e.close()})},start(k){return l(function*(){yield d(k,f||(f=yield c()))})},pull(k){return l(function*(){f?yield d(k,f):k.close()})}});return{writable:new WritableStream(e,Object.assign({},
{highWaterMark:16384},a)),readable:g}};function Zl(a,b){function c(f){return l(function*(){let g,k=f.desiredSize;for(;g=yield e.read(k||null);)if(f.enqueue(g),k!=null&&(k-=g.byteLength)<=0)return;f.close()})}const d=new this(a),e=new Ii(d);b=new ReadableStream({cancel(){return l(function*(){yield e.cancel()})},pull(f){return l(function*(){yield c(f)})},start(f){return l(function*(){yield c(f)})}},Object.assign({},{highWaterMark:16384},b));return{writable:new WritableStream(d,a),readable:b}};function $l(a){a=al.from(a);return t(a)&&q(a.then)?a.then(b=>$l(b)):a.isAsync()?a.readAll().then(b=>new Ck(b)):new Ck(a.readAll())};const am=Object.assign({},Ic,Ti,Ug,bf,v,Lg,vc,Yi,{compareSchemas:uk,compareFields:function(a,b){return rk.compareFields(a,b)},compareTypes:vk});Ma=function(a,b){if(t(a)&&q(a[Symbol.asyncIterator]))return Sl(a,b);if(t(a)&&q(a[Symbol.iterator]))return Rl(a,b);throw Error("toDOMStream() must be called with an Iterable or AsyncIterable");};Ah.throughDOM=function(a){return new Vl(a)};al.throughDOM=Yl;jl.throughDOM=Yl;bl.throughDOM=Yl;Jl.throughDOM=Zl;Nl.throughDOM=Zl;Ml.throughDOM=Zl;var Z={};Z.AsyncByteQueue=Fi;Z.AsyncByteStream=Ii;Z.AsyncMessageReader=Pk;Z.AsyncRecordBatchFileReader=kl;Z.AsyncRecordBatchStreamReader=il;Z.Binary=gd;
Z.BinaryBuilder=dj;Z.Bool=wd;Z.BoolBuilder=fj;Z.BufferType=sc;Z.Builder=Ah;Z.ByteStream=Gi;Z.CompressionType=Cb;Z.Data=P;Z.DataType=L;Z.DateBuilder=gj;Z.DateDay=Id;Z.DateDayBuilder=hj;Z.DateMillisecond=Jd;Z.DateMillisecondBuilder=ij;Z.DateUnit=Ya;Z.Date_=Ed;Z.Decimal=Ad;Z.DecimalBuilder=jj;Z.DenseUnion=Ae;Z.DenseUnionBuilder=ck;Z.Dictionary=Pe;Z.DictionaryBuilder=kj;Z.Duration=ge;Z.DurationBuilder=wj;Z.DurationMicrosecond=me;Z.DurationMicrosecondBuilder=Bj;Z.DurationMillisecond=le;
Z.DurationMillisecondBuilder=Aj;Z.DurationNanosecond=ne;Z.DurationNanosecondBuilder=Cj;Z.DurationSecond=ke;Z.DurationSecondBuilder=xj;Z.Field=V;Z.FixedSizeBinary=Ce;Z.FixedSizeBinaryBuilder=mj;Z.FixedSizeList=Ge;Z.FixedSizeListBuilder=nj;Z.Float=$c;Z.Float16=dd;Z.Float16Builder=pj;Z.Float32=ed;Z.Float32Builder=qj;Z.Float64=fd;Z.Float64Builder=rj;Z.FloatBuilder=oj;Z.Int=Nc;Z.Int16=Tc;Z.Int16Builder=Fj;Z.Int32=Uc;Z.Int32Builder=Gj;Z.Int64=Vc;Z.Int64Builder=Hj;Z.Int8=Sc;Z.Int8Builder=Ej;
Z.IntBuilder=Dj;Z.Interval=$d;Z.IntervalBuilder=sj;Z.IntervalDayTime=de;Z.IntervalDayTimeBuilder=tj;Z.IntervalMonthDayNano=fe;Z.IntervalMonthDayNanoBuilder=vj;Z.IntervalUnit=A;Z.IntervalYearMonth=ee;Z.IntervalYearMonthBuilder=uj;Z.JSONMessageReader=Qk;Z.LargeBinary=kd;Z.LargeBinaryBuilder=ej;Z.LargeUtf8=sd;Z.LargeUtf8Builder=ek;Z.List=oe;Z.ListBuilder=Mj;Z.MapBuilder=Nj;Z.MapRow=ug;Z.Map_=Ke;Z.Message=ai;Z.MessageHeader=H;Z.MessageReader=Ok;Z.MetadataVersion=w;Z.Null=Mc;Z.NullBuilder=Oj;
Z.Precision=y;Z.RecordBatch=Y;Z.RecordBatchFileReader=jl;Z.RecordBatchFileWriter=Nl;Z.RecordBatchJSONWriter=Ol;Z.RecordBatchReader=al;Z.RecordBatchStreamReader=bl;Z.RecordBatchStreamWriter=Ml;Z.RecordBatchWriter=Jl;Z.Schema=U;Z.SparseUnion=Be;Z.SparseUnionBuilder=bk;Z.Struct=se;Z.StructBuilder=Pj;Z.StructRow=Rf;Z.Table=Ck;Z.Time=Kd;Z.TimeBuilder=Vj;Z.TimeMicrosecond=Qd;Z.TimeMicrosecondBuilder=Yj;Z.TimeMillisecond=Pd;Z.TimeMillisecondBuilder=Xj;Z.TimeNanosecond=Rd;Z.TimeNanosecondBuilder=Zj;
Z.TimeSecond=Od;Z.TimeSecondBuilder=Wj;Z.TimeUnit=z;Z.Timestamp=Sd;Z.TimestampBuilder=Qj;Z.TimestampMicrosecond=Yd;Z.TimestampMicrosecondBuilder=Tj;Z.TimestampMillisecond=Xd;Z.TimestampMillisecondBuilder=Sj;Z.TimestampNanosecond=Zd;Z.TimestampNanosecondBuilder=Uj;Z.TimestampSecond=Wd;Z.TimestampSecondBuilder=Rj;Z.Type=I;Z.Uint16=Xc;Z.Uint16Builder=Jj;Z.Uint32=Yc;Z.Uint32Builder=Kj;Z.Uint64=Zc;Z.Uint64Builder=Lj;Z.Uint8=Wc;Z.Uint8Builder=Ij;Z.Union=we;Z.UnionBuilder=ak;Z.UnionMode=x;Z.Utf8=od;
Z.Utf8Builder=dk;Z.Vector=N;Z.Visitor=Ue;
Z.builderThroughAsyncIterable=function(a){const {queueingStrategy:b="count"}=a,{highWaterMark:c=b!=="bytes"?Number.POSITIVE_INFINITY:16384}=a,d=b!=="bytes"?"length":"byteLength";return function(e){return new oa(function*(){let f=0;const g=lj(a);var k;try{for(var m=ia(e);;){var p=yield new n(2,m.next());if(p.done)break;g.append(p.value)[d]>=c&&++f&&(yield new n(0,g.toVector()))}}catch(T){var r={error:T}}finally{try{p&&!p.done&&(k=m.return)&&(yield new n(2,k.call(m)))}finally{if(r)throw r.error;}}if(g.finish().length>
0||f===0)yield new n(0,g.toVector())}())}};Z.builderThroughIterable=yk;Z.compressionRegistry=$k;Z.makeBuilder=lj;Z.makeData=Q;Z.makeTable=function(a){const b={};a=Object.entries(a);for(const [c,d]of a)b[c]=rh(d);return new Ck(b)};Z.makeVector=rh;Z.tableFromArrays=function(a){const b={};a=Object.entries(a);for(const [c,d]of a)b[c]=wk(d);return new Ck(b)};Z.tableFromIPC=$l;Z.tableFromJSON=function(a){a=wk(a);a=new Y(new U(a.type.children),a.data[0]);return new Ck(a)};
Z.tableToIPC=function(a,b="stream",c=null){return(b==="stream"?Ml:Nl).writeAll(a,{va:c}).toUint8Array(!0)};Z.util=am;Z.vectorFromArray=wk;Object.assign(arguments[0],Z);}.bind(this))));
//# sourceMappingURL=Arrow.es2015.min.js.map
</script><script>function render(changed=false){const table=Arrow.tableFromArrays({code:['0017','0023'],units:Int32Array.from(changed?[9,4]:[6,4])});const bytes=Arrow.tableToIPC(table,'file'),decoded=Arrow.tableFromIPC(bytes),codes=Array.from(decoded.getChild('code')),units=Array.from(decoded.getChild('units'));window.reading={rows:decoded.numRows,codes,units,total:units.reduce((a,b)=>a+b,0),bytes:bytes.byteLength};document.querySelector('#reading').textContent=JSON.stringify(reading,null,2);}document.querySelector('#change').onclick=()=>render(true);document.querySelector('#restore').onclick=()=>render();render();</script></html>