Spaces:
Running
Running
// 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 | |