// 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. import { Run } from './run'; import { Field } from '../schema'; import { List } from '../type'; import { OffsetsBufferBuilder } from './buffer'; import { VariableWidthBuilder } from '../builder'; /** @ignore */ export class ListBuilder extends VariableWidthBuilder { constructor(opts) { super(opts); this._run = new Run(); this._offsets = new OffsetsBufferBuilder(); } addChild(child, name = '0') { if (this.numChildren > 0) { throw new Error('ListBuilder can only have one child.'); } this.children[this.numChildren] = child; this.type = new List(new Field(name, child.type, true)); return this.numChildren - 1; } clear() { this._run.clear(); return super.clear(); } _flushPending(pending) { const run = this._run; const offsets = this._offsets; const setValue = this._setValue; let index = 0, value; for ([index, value] of pending) { if (value === undefined) { offsets.set(index, 0); } else { offsets.set(index, value.length); setValue(this, index, run.bind(value)); } } } } //# sourceMappingURL=list.mjs.map