Spaces:
Runtime error
Runtime error
| // 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 { Vector } from '../vector.mjs'; | |
| import { Visitor } from '../visitor.mjs'; | |
| import { encodeUtf8 } from '../util/utf8.mjs'; | |
| import { float64ToUint16 } from '../util/math.mjs'; | |
| import { UnionMode, Precision, DateUnit, TimeUnit, IntervalUnit } from '../enum.mjs'; | |
| /** @ignore */ | |
| export class SetVisitor extends Visitor { | |
| } | |
| /** @ignore */ | |
| function wrapSet(fn) { | |
| return (data, _1, _2) => { | |
| if (data.setValid(_1, _2 != null)) { | |
| return fn(data, _1, _2); | |
| } | |
| }; | |
| } | |
| /** @ignore */ | |
| export const setEpochMsToDays = (data, index, epochMs) => { data[index] = Math.trunc(epochMs / 86400000); }; | |
| /** @ignore */ | |
| export const setEpochMsToMillisecondsLong = (data, index, epochMs) => { | |
| data[index] = Math.trunc(epochMs % 4294967296); | |
| data[index + 1] = Math.trunc(epochMs / 4294967296); | |
| }; | |
| /** @ignore */ | |
| export const setEpochMsToMicrosecondsLong = (data, index, epochMs) => { | |
| data[index] = Math.trunc((epochMs * 1000) % 4294967296); | |
| data[index + 1] = Math.trunc((epochMs * 1000) / 4294967296); | |
| }; | |
| /** @ignore */ | |
| export const setEpochMsToNanosecondsLong = (data, index, epochMs) => { | |
| data[index] = Math.trunc((epochMs * 1000000) % 4294967296); | |
| data[index + 1] = Math.trunc((epochMs * 1000000) / 4294967296); | |
| }; | |
| /** @ignore */ | |
| export const setVariableWidthBytes = (values, valueOffsets, index, value) => { | |
| if (index + 1 < valueOffsets.length) { | |
| const { [index]: x, [index + 1]: y } = valueOffsets; | |
| values.set(value.subarray(0, y - x), x); | |
| } | |
| }; | |
| /** @ignore */ | |
| const setBool = ({ offset, values }, index, val) => { | |
| const idx = offset + index; | |
| val ? (values[idx >> 3] |= (1 << (idx % 8))) // true | |
| : (values[idx >> 3] &= ~(1 << (idx % 8))); // false | |
| }; | |
| /** @ignore */ | |
| export const setInt = ({ values }, index, value) => { values[index] = value; }; | |
| /** @ignore */ | |
| export const setFloat = ({ values }, index, value) => { values[index] = value; }; | |
| /** @ignore */ | |
| export const setFloat16 = ({ values }, index, value) => { values[index] = float64ToUint16(value); }; | |
| /* istanbul ignore next */ | |
| /** @ignore */ | |
| export const setAnyFloat = (data, index, value) => { | |
| switch (data.type.precision) { | |
| case Precision.HALF: | |
| return setFloat16(data, index, value); | |
| case Precision.SINGLE: | |
| case Precision.DOUBLE: | |
| return setFloat(data, index, value); | |
| } | |
| }; | |
| /** @ignore */ | |
| export const setDateDay = ({ values }, index, value) => { setEpochMsToDays(values, index, value.valueOf()); }; | |
| /** @ignore */ | |
| export const setDateMillisecond = ({ values }, index, value) => { setEpochMsToMillisecondsLong(values, index * 2, value.valueOf()); }; | |
| /** @ignore */ | |
| export const setFixedSizeBinary = ({ stride, values }, index, value) => { values.set(value.subarray(0, stride), stride * index); }; | |
| /** @ignore */ | |
| const setBinary = ({ values, valueOffsets }, index, value) => setVariableWidthBytes(values, valueOffsets, index, value); | |
| /** @ignore */ | |
| const setUtf8 = ({ values, valueOffsets }, index, value) => { | |
| setVariableWidthBytes(values, valueOffsets, index, encodeUtf8(value)); | |
| }; | |
| /* istanbul ignore next */ | |
| export const setDate = (data, index, value) => { | |
| data.type.unit === DateUnit.DAY | |
| ? setDateDay(data, index, value) | |
| : setDateMillisecond(data, index, value); | |
| }; | |
| /** @ignore */ | |
| export const setTimestampSecond = ({ values }, index, value) => setEpochMsToMillisecondsLong(values, index * 2, value / 1000); | |
| /** @ignore */ | |
| export const setTimestampMillisecond = ({ values }, index, value) => setEpochMsToMillisecondsLong(values, index * 2, value); | |
| /** @ignore */ | |
| export const setTimestampMicrosecond = ({ values }, index, value) => setEpochMsToMicrosecondsLong(values, index * 2, value); | |
| /** @ignore */ | |
| export const setTimestampNanosecond = ({ values }, index, value) => setEpochMsToNanosecondsLong(values, index * 2, value); | |
| /* istanbul ignore next */ | |
| /** @ignore */ | |
| export const setTimestamp = (data, index, value) => { | |
| switch (data.type.unit) { | |
| case TimeUnit.SECOND: return setTimestampSecond(data, index, value); | |
| case TimeUnit.MILLISECOND: return setTimestampMillisecond(data, index, value); | |
| case TimeUnit.MICROSECOND: return setTimestampMicrosecond(data, index, value); | |
| case TimeUnit.NANOSECOND: return setTimestampNanosecond(data, index, value); | |
| } | |
| }; | |
| /** @ignore */ | |
| export const setTimeSecond = ({ values }, index, value) => { values[index] = value; }; | |
| /** @ignore */ | |
| export const setTimeMillisecond = ({ values }, index, value) => { values[index] = value; }; | |
| /** @ignore */ | |
| export const setTimeMicrosecond = ({ values }, index, value) => { values[index] = value; }; | |
| /** @ignore */ | |
| export const setTimeNanosecond = ({ values }, index, value) => { values[index] = value; }; | |
| /* istanbul ignore next */ | |
| /** @ignore */ | |
| export const setTime = (data, index, value) => { | |
| switch (data.type.unit) { | |
| case TimeUnit.SECOND: return setTimeSecond(data, index, value); | |
| case TimeUnit.MILLISECOND: return setTimeMillisecond(data, index, value); | |
| case TimeUnit.MICROSECOND: return setTimeMicrosecond(data, index, value); | |
| case TimeUnit.NANOSECOND: return setTimeNanosecond(data, index, value); | |
| } | |
| }; | |
| /** @ignore */ | |
| export const setDecimal = ({ values, stride }, index, value) => { values.set(value.subarray(0, stride), stride * index); }; | |
| /** @ignore */ | |
| const setList = (data, index, value) => { | |
| const values = data.children[0]; | |
| const valueOffsets = data.valueOffsets; | |
| const set = instance.getVisitFn(values); | |
| if (Array.isArray(value)) { | |
| for (let idx = -1, itr = valueOffsets[index], end = valueOffsets[index + 1]; itr < end;) { | |
| set(values, itr++, value[++idx]); | |
| } | |
| } | |
| else { | |
| for (let idx = -1, itr = valueOffsets[index], end = valueOffsets[index + 1]; itr < end;) { | |
| set(values, itr++, value.get(++idx)); | |
| } | |
| } | |
| }; | |
| /** @ignore */ | |
| const setMap = (data, index, value) => { | |
| const values = data.children[0]; | |
| const { valueOffsets } = data; | |
| const set = instance.getVisitFn(values); | |
| let { [index]: idx, [index + 1]: end } = valueOffsets; | |
| const entries = value instanceof Map ? value.entries() : Object.entries(value); | |
| for (const val of entries) { | |
| set(values, idx, val); | |
| if (++idx >= end) | |
| break; | |
| } | |
| }; | |
| /** @ignore */ const _setStructArrayValue = (o, v) => (set, c, _, i) => c && set(c, o, v[i]); | |
| /** @ignore */ const _setStructVectorValue = (o, v) => (set, c, _, i) => c && set(c, o, v.get(i)); | |
| /** @ignore */ const _setStructMapValue = (o, v) => (set, c, f, _) => c && set(c, o, v.get(f.name)); | |
| /** @ignore */ const _setStructObjectValue = (o, v) => (set, c, f, _) => c && set(c, o, v[f.name]); | |
| /** @ignore */ | |
| const setStruct = (data, index, value) => { | |
| const childSetters = data.type.children.map((f) => instance.getVisitFn(f.type)); | |
| const set = value instanceof Map ? _setStructMapValue(index, value) : | |
| value instanceof Vector ? _setStructVectorValue(index, value) : | |
| Array.isArray(value) ? _setStructArrayValue(index, value) : | |
| _setStructObjectValue(index, value); | |
| // eslint-disable-next-line unicorn/no-array-for-each | |
| data.type.children.forEach((f, i) => set(childSetters[i], data.children[i], f, i)); | |
| }; | |
| /* istanbul ignore next */ | |
| /** @ignore */ | |
| const setUnion = (data, index, value) => { | |
| data.type.mode === UnionMode.Dense ? | |
| setDenseUnion(data, index, value) : | |
| setSparseUnion(data, index, value); | |
| }; | |
| /** @ignore */ | |
| const setDenseUnion = (data, index, value) => { | |
| const childIndex = data.type.typeIdToChildIndex[data.typeIds[index]]; | |
| const child = data.children[childIndex]; | |
| instance.visit(child, data.valueOffsets[index], value); | |
| }; | |
| /** @ignore */ | |
| const setSparseUnion = (data, index, value) => { | |
| const childIndex = data.type.typeIdToChildIndex[data.typeIds[index]]; | |
| const child = data.children[childIndex]; | |
| instance.visit(child, index, value); | |
| }; | |
| /** @ignore */ | |
| const setDictionary = (data, index, value) => { | |
| var _a; | |
| (_a = data.dictionary) === null || _a === void 0 ? void 0 : _a.set(data.values[index], value); | |
| }; | |
| /* istanbul ignore next */ | |
| /** @ignore */ | |
| export const setIntervalValue = (data, index, value) => { | |
| (data.type.unit === IntervalUnit.DAY_TIME) | |
| ? setIntervalDayTime(data, index, value) | |
| : setIntervalYearMonth(data, index, value); | |
| }; | |
| /** @ignore */ | |
| export const setIntervalDayTime = ({ values }, index, value) => { values.set(value.subarray(0, 2), 2 * index); }; | |
| /** @ignore */ | |
| export const setIntervalYearMonth = ({ values }, index, value) => { values[index] = (value[0] * 12) + (value[1] % 12); }; | |
| /** @ignore */ | |
| const setFixedSizeList = (data, index, value) => { | |
| const { stride } = data; | |
| const child = data.children[0]; | |
| const set = instance.getVisitFn(child); | |
| if (Array.isArray(value)) { | |
| for (let idx = -1, offset = index * stride; ++idx < stride;) { | |
| set(child, offset + idx, value[idx]); | |
| } | |
| } | |
| else { | |
| for (let idx = -1, offset = index * stride; ++idx < stride;) { | |
| set(child, offset + idx, value.get(idx)); | |
| } | |
| } | |
| }; | |
| SetVisitor.prototype.visitBool = wrapSet(setBool); | |
| SetVisitor.prototype.visitInt = wrapSet(setInt); | |
| SetVisitor.prototype.visitInt8 = wrapSet(setInt); | |
| SetVisitor.prototype.visitInt16 = wrapSet(setInt); | |
| SetVisitor.prototype.visitInt32 = wrapSet(setInt); | |
| SetVisitor.prototype.visitInt64 = wrapSet(setInt); | |
| SetVisitor.prototype.visitUint8 = wrapSet(setInt); | |
| SetVisitor.prototype.visitUint16 = wrapSet(setInt); | |
| SetVisitor.prototype.visitUint32 = wrapSet(setInt); | |
| SetVisitor.prototype.visitUint64 = wrapSet(setInt); | |
| SetVisitor.prototype.visitFloat = wrapSet(setAnyFloat); | |
| SetVisitor.prototype.visitFloat16 = wrapSet(setFloat16); | |
| SetVisitor.prototype.visitFloat32 = wrapSet(setFloat); | |
| SetVisitor.prototype.visitFloat64 = wrapSet(setFloat); | |
| SetVisitor.prototype.visitUtf8 = wrapSet(setUtf8); | |
| SetVisitor.prototype.visitBinary = wrapSet(setBinary); | |
| SetVisitor.prototype.visitFixedSizeBinary = wrapSet(setFixedSizeBinary); | |
| SetVisitor.prototype.visitDate = wrapSet(setDate); | |
| SetVisitor.prototype.visitDateDay = wrapSet(setDateDay); | |
| SetVisitor.prototype.visitDateMillisecond = wrapSet(setDateMillisecond); | |
| SetVisitor.prototype.visitTimestamp = wrapSet(setTimestamp); | |
| SetVisitor.prototype.visitTimestampSecond = wrapSet(setTimestampSecond); | |
| SetVisitor.prototype.visitTimestampMillisecond = wrapSet(setTimestampMillisecond); | |
| SetVisitor.prototype.visitTimestampMicrosecond = wrapSet(setTimestampMicrosecond); | |
| SetVisitor.prototype.visitTimestampNanosecond = wrapSet(setTimestampNanosecond); | |
| SetVisitor.prototype.visitTime = wrapSet(setTime); | |
| SetVisitor.prototype.visitTimeSecond = wrapSet(setTimeSecond); | |
| SetVisitor.prototype.visitTimeMillisecond = wrapSet(setTimeMillisecond); | |
| SetVisitor.prototype.visitTimeMicrosecond = wrapSet(setTimeMicrosecond); | |
| SetVisitor.prototype.visitTimeNanosecond = wrapSet(setTimeNanosecond); | |
| SetVisitor.prototype.visitDecimal = wrapSet(setDecimal); | |
| SetVisitor.prototype.visitList = wrapSet(setList); | |
| SetVisitor.prototype.visitStruct = wrapSet(setStruct); | |
| SetVisitor.prototype.visitUnion = wrapSet(setUnion); | |
| SetVisitor.prototype.visitDenseUnion = wrapSet(setDenseUnion); | |
| SetVisitor.prototype.visitSparseUnion = wrapSet(setSparseUnion); | |
| SetVisitor.prototype.visitDictionary = wrapSet(setDictionary); | |
| SetVisitor.prototype.visitInterval = wrapSet(setIntervalValue); | |
| SetVisitor.prototype.visitIntervalDayTime = wrapSet(setIntervalDayTime); | |
| SetVisitor.prototype.visitIntervalYearMonth = wrapSet(setIntervalYearMonth); | |
| SetVisitor.prototype.visitFixedSizeList = wrapSet(setFixedSizeList); | |
| SetVisitor.prototype.visitMap = wrapSet(setMap); | |
| /** @ignore */ | |
| export const instance = new SetVisitor(); | |
| //# sourceMappingURL=set.mjs.map | |