Spaces:
Sleeping
Sleeping
File size: 3,557 Bytes
be5030f |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 |
"use strict";
// 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.
Object.defineProperty(exports, "__esModule", { value: true });
const schema_1 = require("./schema");
const vector_1 = require("./vector");
const chunked_1 = require("./vector/chunked");
class Column extends chunked_1.Chunked {
constructor(field, vectors = [], offsets) {
vectors = chunked_1.Chunked.flatten(...vectors);
super(field.type, vectors, offsets);
this._field = field;
if (vectors.length === 1 && !(this instanceof SingleChunkColumn)) {
return new SingleChunkColumn(field, vectors[0], this._chunkOffsets);
}
}
/** @nocollapse */
static new(field, data, ...rest) {
const chunks = chunked_1.Chunked.flatten(Array.isArray(data) ? [...data, ...rest] :
data instanceof vector_1.Vector ? [data, ...rest] :
[vector_1.Vector.new(data, ...rest)]);
if (typeof field === 'string') {
const type = chunks[0].data.type;
field = new schema_1.Field(field, type, true);
}
else if (!field.nullable && chunks.some(({ nullCount }) => nullCount > 0)) {
field = field.clone({ nullable: true });
}
return new Column(field, chunks);
}
get field() { return this._field; }
get name() { return this._field.name; }
get nullable() { return this._field.nullable; }
get metadata() { return this._field.metadata; }
clone(chunks = this._chunks) {
return new Column(this._field, chunks);
}
getChildAt(index) {
if (index < 0 || index >= this.numChildren) {
return null;
}
let columns = this._children || (this._children = []);
let column, field, chunks;
if (column = columns[index]) {
return column;
}
if (field = (this.type.children || [])[index]) {
chunks = this._chunks
.map((vector) => vector.getChildAt(index))
.filter((vec) => vec != null);
if (chunks.length > 0) {
return (columns[index] = new Column(field, chunks));
}
}
return null;
}
}
exports.Column = Column;
/** @ignore */
class SingleChunkColumn extends Column {
constructor(field, vector, offsets) {
super(field, [vector], offsets);
this._chunk = vector;
}
search(index, then) {
return then ? then(this, 0, index) : [0, index];
}
isValid(index) {
return this._chunk.isValid(index);
}
get(index) {
return this._chunk.get(index);
}
set(index, value) {
this._chunk.set(index, value);
}
indexOf(element, offset) {
return this._chunk.indexOf(element, offset);
}
}
//# sourceMappingURL=column.js.map
|