@apache-arrow/esnext-esm
Advanced tools
Comparing version 0.17.0 to 2.0.0
@@ -30,23 +30,23 @@ /// <reference types="flatbuffers" /> | ||
}>(source: T, index: number): number; | ||
clampIndex<T extends { | ||
clampIndex<T_1 extends { | ||
length: number; | ||
stride?: number | undefined; | ||
}, N extends (source: T, index: number) => any = (source: T, index: number) => any>(source: T, index: number, then: N): ReturnType<N>; | ||
clampRange<T extends { | ||
}, N extends (source: T_1, index: number) => any = (source: T_1, index: number) => any>(source: T_1, index: number, then: N): ReturnType<N>; | ||
clampRange<T_2 extends { | ||
length: number; | ||
stride?: number | undefined; | ||
}>(source: T, begin: number | undefined, end: number | undefined): [number, number]; | ||
clampRange<T extends { | ||
}>(source: T_2, begin: number | undefined, end: number | undefined): [number, number]; | ||
clampRange<T_3 extends { | ||
length: number; | ||
stride?: number | undefined; | ||
}, N extends (source: T, offset: number, length: number) => any = (source: T, offset: number, length: number) => any>(source: T, begin: number | undefined, end: number | undefined, then: N): ReturnType<N>; | ||
createElementComparator(search: any): (value: any) => boolean; | ||
}, N_1 extends (source: T_3, offset: number, length: number) => any = (source: T_3, offset: number, length: number) => any>(source: T_3, begin: number | undefined, end: number | undefined, then: N_1): ReturnType<N_1>; | ||
createElementComparator(search: any): ((value: any) => boolean) | (() => boolean); | ||
memcpy<TTarget extends ArrayBufferView, TSource extends ArrayBufferView>(target: TTarget, source: TSource, targetByteOffset?: number, sourceByteLength?: number): TTarget; | ||
joinUint8Arrays(chunks: Uint8Array[], size?: number | null | undefined): [Uint8Array, Uint8Array[], number]; | ||
toArrayBufferView<T extends import("./interfaces").TypedArray>(ArrayBufferViewCtor: import("./interfaces").TypedArrayConstructor<T>, input: util_buffer_.ArrayBufferViewInput): T; | ||
toArrayBufferView<T extends import("./interfaces").BigIntArray>(ArrayBufferViewCtor: import("./interfaces").BigIntArrayConstructor<T>, input: util_buffer_.ArrayBufferViewInput): T; | ||
toArrayBufferViewIterator<T extends import("./interfaces").TypedArray>(ArrayCtor: import("./interfaces").TypedArrayConstructor<T>, source: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined): IterableIterator<T>; | ||
toArrayBufferViewAsyncIterator<T extends import("./interfaces").TypedArray>(ArrayCtor: import("./interfaces").TypedArrayConstructor<T>, source: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | null | undefined): AsyncIterableIterator<T>; | ||
toArrayBufferView<T_4 extends import("./interfaces").TypedArray>(ArrayBufferViewCtor: import("./interfaces").TypedArrayConstructor<T_4>, input: util_buffer_.ArrayBufferViewInput): T_4; | ||
toArrayBufferView<T_5 extends import("./interfaces").BigIntArray>(ArrayBufferViewCtor: import("./interfaces").BigIntArrayConstructor<T_5>, input: util_buffer_.ArrayBufferViewInput): T_5; | ||
toArrayBufferViewIterator<T_6 extends import("./interfaces").TypedArray>(ArrayCtor: import("./interfaces").TypedArrayConstructor<T_6>, source: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined): Generator<T_6, T_6, number | undefined>; | ||
toArrayBufferViewAsyncIterator<T_7 extends import("./interfaces").TypedArray>(ArrayCtor: import("./interfaces").TypedArrayConstructor<T_7>, source: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | null | undefined): AsyncGenerator<T_7, T_7, number | undefined>; | ||
rebaseValueOffsets(offset: number, length: number, valueOffsets: Int32Array): Int32Array; | ||
compareArrayLike<T extends ArrayLike<any>>(a: T, b: T): boolean; | ||
compareArrayLike<T_8 extends ArrayLike<any>>(a: T_8, b: T_8): boolean; | ||
toInt8Array: (input: util_buffer_.ArrayBufferViewInput) => Int8Array; | ||
@@ -63,20 +63,20 @@ toInt16Array: (input: util_buffer_.ArrayBufferViewInput) => Int16Array; | ||
toUint8ClampedArray: (input: util_buffer_.ArrayBufferViewInput) => Uint8ClampedArray; | ||
toInt8ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => IterableIterator<Int8Array>; | ||
toInt16ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => IterableIterator<Int16Array>; | ||
toInt32ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => IterableIterator<Int32Array>; | ||
toUint8ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => IterableIterator<Uint8Array>; | ||
toUint16ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => IterableIterator<Uint16Array>; | ||
toUint32ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => IterableIterator<Uint32Array>; | ||
toFloat32ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => IterableIterator<Float32Array>; | ||
toFloat64ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => IterableIterator<Float64Array>; | ||
toUint8ClampedArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => IterableIterator<Uint8ClampedArray>; | ||
toInt8ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncIterableIterator<Int8Array>; | ||
toInt16ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncIterableIterator<Int16Array>; | ||
toInt32ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncIterableIterator<Int32Array>; | ||
toUint8ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncIterableIterator<Uint8Array>; | ||
toUint16ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncIterableIterator<Uint16Array>; | ||
toUint32ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncIterableIterator<Uint32Array>; | ||
toFloat32ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncIterableIterator<Float32Array>; | ||
toFloat64ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncIterableIterator<Float64Array>; | ||
toUint8ClampedArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncIterableIterator<Uint8ClampedArray>; | ||
toInt8ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => Generator<Int8Array, Int8Array, number | undefined>; | ||
toInt16ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => Generator<Int16Array, Int16Array, number | undefined>; | ||
toInt32ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => Generator<Int32Array, Int32Array, number | undefined>; | ||
toUint8ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => Generator<Uint8Array, Uint8Array, number | undefined>; | ||
toUint16ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => Generator<Uint16Array, Uint16Array, number | undefined>; | ||
toUint32ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => Generator<Uint32Array, Uint32Array, number | undefined>; | ||
toFloat32ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => Generator<Float32Array, Float32Array, number | undefined>; | ||
toFloat64ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => Generator<Float64Array, Float64Array, number | undefined>; | ||
toUint8ClampedArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<util_buffer_.ArrayBufferViewInput> | null | undefined) => Generator<Uint8ClampedArray, Uint8ClampedArray, number | undefined>; | ||
toInt8ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncGenerator<Int8Array, Int8Array, number | undefined>; | ||
toInt16ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncGenerator<Int16Array, Int16Array, number | undefined>; | ||
toInt32ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncGenerator<Int32Array, Int32Array, number | undefined>; | ||
toUint8ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncGenerator<Uint8Array, Uint8Array, number | undefined>; | ||
toUint16ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncGenerator<Uint16Array, Uint16Array, number | undefined>; | ||
toUint32ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncGenerator<Uint32Array, Uint32Array, number | undefined>; | ||
toFloat32ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncGenerator<Float32Array, Float32Array, number | undefined>; | ||
toFloat64ArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncGenerator<Float64Array, Float64Array, number | undefined>; | ||
toUint8ClampedArrayAsyncIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorYieldResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | IteratorReturnResult<any> | ReadableStreamReadValueResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadDoneResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | AsyncIterable<util_buffer_.ArrayBufferViewInput> | Iterable<util_buffer_.ArrayBufferViewInput> | PromiseLike<util_buffer_.ArrayBufferViewInput> | null | undefined) => AsyncGenerator<Uint8ClampedArray, Uint8ClampedArray, number | undefined>; | ||
uint16ToFloat64(h: number): number; | ||
@@ -89,3 +89,3 @@ float64ToUint16(d: number): number; | ||
packBools(values: Iterable<any>): Uint8Array; | ||
iterateBits<T>(bytes: Uint8Array, begin: number, length: number, context: any, get: (context: any, index: number, byte: number, bit: number) => T): IterableIterator<T>; | ||
iterateBits<T_9>(bytes: Uint8Array, begin: number, length: number, context: any, get: (context: any, index: number, byte: number, bit: number) => T_9): Generator<T_9, void, unknown>; | ||
popcnt_bit_range(data: Uint8Array, lhs: number, rhs: number): number; | ||
@@ -99,5 +99,5 @@ popcnt_array(arr: ArrayBufferView, byteOffset?: number | undefined, byteLength?: number | undefined): number; | ||
isArrowBigNumSymbol: typeof util_bn_.isArrowBigNumSymbol; | ||
bignumToString: <T extends util_bn_.BN<Int8Array | Uint8Array | Uint8ClampedArray | Int16Array | Uint16Array | Int32Array | Uint32Array>>(a: T) => string; | ||
bignumToBigInt: <T extends util_bn_.BN<Int8Array | Uint8Array | Uint8ClampedArray | Int16Array | Uint16Array | Int32Array | Uint32Array>>(a: T) => bigint; | ||
bignumToString: <T_10 extends util_bn_.BN<Int8Array | Uint8Array | Uint8ClampedArray | Int16Array | Uint16Array | Int32Array | Uint32Array>>(a: T_10) => string; | ||
bignumToBigInt: <T_11 extends util_bn_.BN<Int8Array | Uint8Array | Uint8ClampedArray | Int16Array | Uint16Array | Int32Array | Uint32Array>>(a: T_11) => bigint; | ||
BN: typeof util_bn_.BN; | ||
}; |
@@ -192,25 +192,25 @@ import { Data } from './data'; | ||
toVector(): V<T>; | ||
readonly ArrayType: any; | ||
readonly nullCount: number; | ||
readonly numChildren: number; | ||
get ArrayType(): any; | ||
get nullCount(): number; | ||
get numChildren(): number; | ||
/** | ||
* @returns The aggregate length (in bytes) of the values that have been written. | ||
*/ | ||
readonly byteLength: number; | ||
get byteLength(): number; | ||
/** | ||
* @returns The aggregate number of rows that have been reserved to write new values. | ||
*/ | ||
readonly reservedLength: number; | ||
get reservedLength(): number; | ||
/** | ||
* @returns The aggregate length (in bytes) that has been reserved to write new values. | ||
*/ | ||
readonly reservedByteLength: number; | ||
get reservedByteLength(): number; | ||
protected _offsets: DataBufferBuilder<Int32Array>; | ||
readonly valueOffsets: Int32Array | null; | ||
get valueOffsets(): Int32Array | null; | ||
protected _values: BufferBuilder<T['TArray'], any>; | ||
readonly values: T["TArray"]; | ||
get values(): T["TArray"] | null; | ||
protected _nulls: BitmapBufferBuilder; | ||
readonly nullBitmap: Uint8Array | null; | ||
get nullBitmap(): Uint8Array | null; | ||
protected _typeIds: DataBufferBuilder<Int8Array>; | ||
readonly typeIds: Int8Array | null; | ||
get typeIds(): Int8Array | null; | ||
protected _isValid: (value: T['TValue'] | TNull) => boolean; | ||
@@ -217,0 +217,0 @@ protected _setValue: (inst: Builder<T>, index: number, value: T['TValue']) => void; |
@@ -6,5 +6,5 @@ import { Binary } from '../type'; | ||
constructor(opts: BuilderOptions<Binary, TNull>); | ||
readonly byteLength: number; | ||
get byteLength(): number; | ||
setValue(index: number, value: Uint8Array): void; | ||
protected _flushPending(pending: Map<number, Uint8Array | undefined>, pendingLength: number): void; | ||
} |
@@ -17,5 +17,5 @@ import { TypedArray, TypedArrayConstructor, BigIntArray, BigIntArrayConstructor } from '../interfaces'; | ||
readonly BYTES_PER_ELEMENT: number; | ||
readonly byteLength: number; | ||
readonly reservedLength: number; | ||
readonly reservedByteLength: number; | ||
get byteLength(): number; | ||
get reservedLength(): number; | ||
get reservedByteLength(): number; | ||
set(index: number, value: TValue): this; | ||
@@ -38,3 +38,3 @@ append(value: TValue): this; | ||
numValid: number; | ||
readonly numInvalid: number; | ||
get numInvalid(): number; | ||
get(idx: number): number; | ||
@@ -55,3 +55,3 @@ set(idx: number, val: number): this; | ||
protected _ArrayType64: BigIntArrayConstructor<R>; | ||
readonly ArrayType64: BigIntArrayConstructor<R>; | ||
get ArrayType64(): BigIntArrayConstructor<R>; | ||
set(index: number, value: DataValue<T>): this; | ||
@@ -58,0 +58,0 @@ protected _resize(newLength: number): T; |
@@ -19,8 +19,8 @@ import { Vector } from '../vector'; | ||
constructor({ 'type': type, 'nullValues': nulls, 'dictionaryHashFunction': hashFn }: DictionaryBuilderOptions<T, TNull>); | ||
readonly values: T["indices"]["TArray"]; | ||
readonly nullCount: number; | ||
readonly nullBitmap: Uint8Array | null; | ||
readonly byteLength: number; | ||
readonly reservedLength: number; | ||
readonly reservedByteLength: number; | ||
get values(): T["indices"]["TArray"] | null; | ||
get nullCount(): number; | ||
get nullBitmap(): Uint8Array | null; | ||
get byteLength(): number; | ||
get reservedLength(): number; | ||
get reservedByteLength(): number; | ||
isValid(value: T['TValue'] | TNull): boolean; | ||
@@ -27,0 +27,0 @@ setValid(index: number, valid: boolean): boolean; |
@@ -21,3 +21,3 @@ import { WideBufferBuilder } from './buffer'; | ||
constructor(options: BuilderOptions<Int64, TNull>); | ||
readonly values64: BigInt64Array; | ||
get values64(): BigInt64Array; | ||
isValid(value: Int32Array | bigint | TNull): boolean; | ||
@@ -38,4 +38,4 @@ } | ||
constructor(options: BuilderOptions<Uint64, TNull>); | ||
readonly values64: BigUint64Array; | ||
get values64(): BigUint64Array; | ||
isValid(value: Uint32Array | bigint | TNull): boolean; | ||
} |
@@ -6,3 +6,3 @@ import { Vector } from '../vector'; | ||
protected _values: ArrayLike<T['TValue'] | TNull>; | ||
readonly length: number; | ||
get length(): number; | ||
get(index: number): TNull | T["TValue"]; | ||
@@ -9,0 +9,0 @@ clear(): this; |
@@ -11,3 +11,3 @@ import { DataBufferBuilder } from './buffer'; | ||
constructor(options: UnionBuilderOptions<T, TNull>); | ||
readonly typeIdToChildIndex: { | ||
get typeIdToChildIndex(): { | ||
[key: number]: number; | ||
@@ -14,0 +14,0 @@ }; |
@@ -6,5 +6,5 @@ import { Utf8 } from '../type'; | ||
constructor(opts: BuilderOptions<Utf8, TNull>); | ||
readonly byteLength: number; | ||
get byteLength(): number; | ||
setValue(index: number, value: string): void; | ||
protected _flushPending(pending: Map<number, Uint8Array | undefined>, pendingLength: number): void; | ||
} |
@@ -22,2 +22,2 @@ import { DataType } from '../type'; | ||
*/ | ||
export declare function createIsValidFunction<T extends DataType = any, TNull = any>(nullValues?: ReadonlyArray<TNull>): (value: any) => boolean; | ||
export declare function createIsValidFunction<T extends DataType = any, TNull = any>(nullValues?: ReadonlyArray<TNull>): (value: T['TValue'] | TNull) => boolean; |
@@ -9,3 +9,2 @@ import { Data } from './data'; | ||
export interface Column<T extends DataType = any> { | ||
typeId: T['TType']; | ||
concat(...others: Vector<T>[]): Column<T>; | ||
@@ -16,2 +15,3 @@ slice(begin?: number, end?: number): Column<T>; | ||
export declare class Column<T extends DataType = any> extends Chunked<T> implements Clonable<Column<T>>, Sliceable<Column<T>>, Applicative<T, Column<T>> { | ||
static new<T extends DataType>(data: Data<T>, ...args: VectorCtorArgs<V<T>>): Column<T>; | ||
static new<T extends DataType>(field: string | Field<T>, ...chunks: (Vector<T> | Vector<T>[])[]): Column<T>; | ||
@@ -22,7 +22,7 @@ static new<T extends DataType>(field: string | Field<T>, data: Data<T>, ...args: VectorCtorArgs<V<T>>): Column<T>; | ||
protected _children?: Column[]; | ||
readonly field: Field<T>; | ||
readonly name: string; | ||
readonly nullable: boolean; | ||
readonly metadata: Map<string, string>; | ||
get field(): Field<T>; | ||
get name(): string; | ||
get nullable(): boolean; | ||
get metadata(): Map<string, string>; | ||
getChildAt<R extends DataType = any>(index: number): Column<R> | null; | ||
} |
@@ -30,3 +30,8 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
/** @nocollapse */ | ||
static new(field, data, ...rest) { | ||
static new(...args) { | ||
let [field, data, ...rest] = args; | ||
if (typeof field !== 'string' && !(field instanceof Field)) { | ||
data = field; | ||
field = ''; | ||
} | ||
const chunks = Chunked.flatten(Array.isArray(data) ? [...data, ...rest] : | ||
@@ -33,0 +38,0 @@ data instanceof Vector ? [data, ...rest] : |
@@ -55,3 +55,3 @@ import { Vector } from '../vector'; | ||
constructor(...children: Predicate[]); | ||
bind(batch: RecordBatch): (idx: number, batch: RecordBatch<any>) => boolean; | ||
bind(batch: RecordBatch): (idx: number, batch: RecordBatch) => boolean; | ||
} | ||
@@ -61,3 +61,3 @@ /** @ignore */ | ||
constructor(...children: Predicate[]); | ||
bind(batch: RecordBatch): (idx: number, batch: RecordBatch<any>) => boolean; | ||
bind(batch: RecordBatch): (idx: number, batch: RecordBatch) => boolean; | ||
} | ||
@@ -78,3 +78,3 @@ /** @ignore */ | ||
protected _bindColLit(batch: RecordBatch, col: Col, lit: Literal): PredicateFunc; | ||
protected _bindLitCol(batch: RecordBatch, lit: Literal, col: Col): (idx: number, cols: RecordBatch<any>) => boolean; | ||
protected _bindLitCol(batch: RecordBatch, lit: Literal, col: Col): (idx: number, cols: RecordBatch) => boolean; | ||
} | ||
@@ -86,3 +86,3 @@ /** @ignore */ | ||
protected _bindColLit(batch: RecordBatch, col: Col, lit: Literal): PredicateFunc; | ||
protected _bindLitCol(batch: RecordBatch, lit: Literal, col: Col): (idx: number, cols: RecordBatch<any>) => boolean; | ||
protected _bindLitCol(batch: RecordBatch, lit: Literal, col: Col): (idx: number, cols: RecordBatch) => boolean; | ||
} | ||
@@ -93,3 +93,3 @@ /** @ignore */ | ||
constructor(child: Predicate); | ||
bind(batch: RecordBatch): (idx: number, batch: RecordBatch<any>) => boolean; | ||
bind(batch: RecordBatch): (idx: number, batch: RecordBatch) => boolean; | ||
} | ||
@@ -96,0 +96,0 @@ /** @ignore */ |
@@ -39,8 +39,8 @@ import { Vector } from './vector'; | ||
readonly valueOffsets: Buffers<T>[BufferType.OFFSET]; | ||
readonly typeId: T['TType']; | ||
readonly ArrayType: T['ArrayType']; | ||
readonly buffers: Buffers<T>; | ||
readonly byteLength: number; | ||
get typeId(): T['TType']; | ||
get ArrayType(): T['ArrayType']; | ||
get buffers(): Buffers<T>; | ||
get byteLength(): number; | ||
protected _nullCount: number | kUnknownNullCount; | ||
readonly nullCount: number; | ||
get nullCount(): number; | ||
constructor(type: T, offset: number, length: number, nullCount?: number, buffers?: Partial<Buffers<T>> | Data<T>, childData?: (Data | Vector)[], dictionary?: Vector); | ||
@@ -77,5 +77,5 @@ clone<R extends DataType>(type: R, offset?: number, length?: number, nullCount?: number, buffers?: Buffers<R>, childData?: (Data | Vector)[]): Data<R>; | ||
/** @nocollapse */ | ||
static Binary<T extends Binary>(type: T, offset: number, length: number, nullCount: number, nullBitmap: NullBuffer, valueOffsets: ValueOffsetsBuffer, data: Uint8Array): Data<T>; | ||
static Binary<T extends Binary>(type: T, offset: number, length: number, nullCount: number, nullBitmap: NullBuffer, valueOffsets: ValueOffsetsBuffer, data: DataBuffer<T>): Data<T>; | ||
/** @nocollapse */ | ||
static Utf8<T extends Utf8>(type: T, offset: number, length: number, nullCount: number, nullBitmap: NullBuffer, valueOffsets: ValueOffsetsBuffer, data: Uint8Array): Data<T>; | ||
static Utf8<T extends Utf8>(type: T, offset: number, length: number, nullCount: number, nullBitmap: NullBuffer, valueOffsets: ValueOffsetsBuffer, data: DataBuffer<T>): Data<T>; | ||
/** @nocollapse */ | ||
@@ -82,0 +82,0 @@ static List<T extends List>(type: T, offset: number, length: number, nullCount: number, nullBitmap: NullBuffer, valueOffsets: ValueOffsetsBuffer, child: Data<T['valueType']> | Vector<T['valueType']>): Data<T>; |
@@ -73,3 +73,3 @@ import { Data } from './data'; | ||
/** @ignore */ | ||
export declare type VectorCtorType<T extends VectorType<R>, R extends DataType = any, TCtor extends new (data: Data<R>, ...args: VectorCtorArgs<T, R>) => T = new (data: Data<R>, ...args: VectorCtorArgs<T, R>) => T> = TCtor extends new (data: Data<R>, ...args: VectorCtorArgs<T, R>) => T ? TCtor : never; | ||
export declare type VectorCtorType<T extends VectorType<R>, R extends DataType = any, TCtor extends new (type: R, data?: Data<R>[], offsets?: Uint32Array) => T = new (type: R, data?: Data<R>[], offsets?: Uint32Array) => T> = TCtor extends new (type: R, data?: Data<R>[], offsets?: Uint32Array) => T ? TCtor : never; | ||
/** @ignore */ | ||
@@ -82,3 +82,3 @@ export declare type BuilderCtorType<T extends BuilderType<R, any>, R extends DataType = any, TCtor extends new (options: BuilderOptions<R, any>) => T = new (options: BuilderOptions<R, any>) => T> = TCtor extends new (options: BuilderOptions<R, any>) => T ? TCtor : never; | ||
/** @ignore */ | ||
export declare type VectorCtor<T extends Type | DataType | VectorType> = T extends VectorType ? VectorCtorType<T> : T extends Type ? VectorCtorType<VectorType<T>> : T extends DataType ? VectorCtorType<VectorType<T['TType']>> : VectorCtorType<vecs.BaseVector>; | ||
export declare type VectorCtor<T extends Type | DataType | VectorType> = T extends VectorType ? VectorCtorType<VectorType<T['TType']>> : T extends Type ? VectorCtorType<VectorType<T>> : T extends DataType ? VectorCtorType<VectorType<T['TType']>> : VectorCtorType<vecs.BaseVector<any>>; | ||
/** @ignore */ | ||
@@ -90,3 +90,3 @@ export declare type BuilderCtor<T extends Type | DataType = any> = T extends Type ? BuilderCtorType<BuilderType<T>> : T extends DataType ? BuilderCtorType<BuilderType<T>> : BuilderCtorType<builders.Builder>; | ||
declare type TypeToVector<T extends Type> = { | ||
[key: number]: any; | ||
[key: number]: vecs.Vector<any>; | ||
[Type.Null]: vecs.NullVector; | ||
@@ -138,46 +138,46 @@ [Type.Bool]: vecs.BoolVector; | ||
declare type DataTypeToVector<T extends DataType = any> = { | ||
[key: number]: any; | ||
[Type.Null]: T extends type.Null ? vecs.NullVector : vecs.BaseVector<T>; | ||
[Type.Bool]: T extends type.Bool ? vecs.BoolVector : vecs.BaseVector<T>; | ||
[Type.Int8]: T extends type.Int8 ? vecs.Int8Vector : vecs.BaseVector<T>; | ||
[Type.Int16]: T extends type.Int16 ? vecs.Int16Vector : vecs.BaseVector<T>; | ||
[Type.Int32]: T extends type.Int32 ? vecs.Int32Vector : vecs.BaseVector<T>; | ||
[Type.Int64]: T extends type.Int64 ? vecs.Int64Vector : vecs.BaseVector<T>; | ||
[Type.Uint8]: T extends type.Uint8 ? vecs.Uint8Vector : vecs.BaseVector<T>; | ||
[Type.Uint16]: T extends type.Uint16 ? vecs.Uint16Vector : vecs.BaseVector<T>; | ||
[Type.Uint32]: T extends type.Uint32 ? vecs.Uint32Vector : vecs.BaseVector<T>; | ||
[Type.Uint64]: T extends type.Uint64 ? vecs.Uint64Vector : vecs.BaseVector<T>; | ||
[Type.Int]: T extends type.Int ? vecs.IntVector : vecs.BaseVector<T>; | ||
[Type.Float16]: T extends type.Float16 ? vecs.Float16Vector : vecs.BaseVector<T>; | ||
[Type.Float32]: T extends type.Float32 ? vecs.Float32Vector : vecs.BaseVector<T>; | ||
[Type.Float64]: T extends type.Float64 ? vecs.Float64Vector : vecs.BaseVector<T>; | ||
[Type.Float]: T extends type.Float ? vecs.FloatVector : vecs.BaseVector<T>; | ||
[Type.Utf8]: T extends type.Utf8 ? vecs.Utf8Vector : vecs.BaseVector<T>; | ||
[Type.Binary]: T extends type.Binary ? vecs.BinaryVector : vecs.BaseVector<T>; | ||
[Type.FixedSizeBinary]: T extends type.FixedSizeBinary ? vecs.FixedSizeBinaryVector : vecs.BaseVector<T>; | ||
[Type.Date]: T extends type.Date_ ? vecs.DateVector : vecs.BaseVector<T>; | ||
[Type.DateDay]: T extends type.DateDay ? vecs.DateDayVector : vecs.BaseVector<T>; | ||
[Type.DateMillisecond]: T extends type.DateMillisecond ? vecs.DateMillisecondVector : vecs.BaseVector<T>; | ||
[Type.Timestamp]: T extends type.Timestamp ? vecs.TimestampVector : vecs.BaseVector<T>; | ||
[Type.TimestampSecond]: T extends type.TimestampSecond ? vecs.TimestampSecondVector : vecs.BaseVector<T>; | ||
[Type.TimestampMillisecond]: T extends type.TimestampMillisecond ? vecs.TimestampMillisecondVector : vecs.BaseVector<T>; | ||
[Type.TimestampMicrosecond]: T extends type.TimestampMicrosecond ? vecs.TimestampMicrosecondVector : vecs.BaseVector<T>; | ||
[Type.TimestampNanosecond]: T extends type.TimestampNanosecond ? vecs.TimestampNanosecondVector : vecs.BaseVector<T>; | ||
[Type.Time]: T extends type.Time ? vecs.TimeVector : vecs.BaseVector<T>; | ||
[Type.TimeSecond]: T extends type.TimeSecond ? vecs.TimeSecondVector : vecs.BaseVector<T>; | ||
[Type.TimeMillisecond]: T extends type.TimeMillisecond ? vecs.TimeMillisecondVector : vecs.BaseVector<T>; | ||
[Type.TimeMicrosecond]: T extends type.TimeMicrosecond ? vecs.TimeMicrosecondVector : vecs.BaseVector<T>; | ||
[Type.TimeNanosecond]: T extends type.TimeNanosecond ? vecs.TimeNanosecondVector : vecs.BaseVector<T>; | ||
[Type.Decimal]: T extends type.Decimal ? vecs.DecimalVector : vecs.BaseVector<T>; | ||
[Type.Union]: T extends type.Union ? vecs.UnionVector : vecs.BaseVector<T>; | ||
[Type.DenseUnion]: T extends type.DenseUnion ? vecs.DenseUnionVector : vecs.BaseVector<T>; | ||
[Type.SparseUnion]: T extends type.SparseUnion ? vecs.SparseUnionVector : vecs.BaseVector<T>; | ||
[Type.Interval]: T extends type.Interval ? vecs.IntervalVector : vecs.BaseVector<T>; | ||
[Type.IntervalDayTime]: T extends type.IntervalDayTime ? vecs.IntervalDayTimeVector : vecs.BaseVector<T>; | ||
[Type.IntervalYearMonth]: T extends type.IntervalYearMonth ? vecs.IntervalYearMonthVector : vecs.BaseVector<T>; | ||
[Type.Map]: T extends type.Map_ ? vecs.MapVector<T['keyType'], T['valueType']> : vecs.BaseVector<T>; | ||
[Type.List]: T extends type.List ? vecs.ListVector<T['valueType']> : vecs.BaseVector<T>; | ||
[Type.Struct]: T extends type.Struct ? vecs.StructVector<T['dataTypes']> : vecs.BaseVector<T>; | ||
[Type.Dictionary]: T extends type.Dictionary ? vecs.DictionaryVector<T['valueType'], T['indices']> : vecs.BaseVector<T>; | ||
[Type.FixedSizeList]: T extends type.FixedSizeList ? vecs.FixedSizeListVector<T['valueType']> : vecs.BaseVector<T>; | ||
[key: number]: vecs.Vector<any>; | ||
[Type.Null]: T extends type.Null ? vecs.NullVector : never; | ||
[Type.Bool]: T extends type.Bool ? vecs.BoolVector : never; | ||
[Type.Int8]: T extends type.Int8 ? vecs.Int8Vector : never; | ||
[Type.Int16]: T extends type.Int16 ? vecs.Int16Vector : never; | ||
[Type.Int32]: T extends type.Int32 ? vecs.Int32Vector : never; | ||
[Type.Int64]: T extends type.Int64 ? vecs.Int64Vector : never; | ||
[Type.Uint8]: T extends type.Uint8 ? vecs.Uint8Vector : never; | ||
[Type.Uint16]: T extends type.Uint16 ? vecs.Uint16Vector : never; | ||
[Type.Uint32]: T extends type.Uint32 ? vecs.Uint32Vector : never; | ||
[Type.Uint64]: T extends type.Uint64 ? vecs.Uint64Vector : never; | ||
[Type.Int]: T extends type.Int ? vecs.IntVector : never; | ||
[Type.Float16]: T extends type.Float16 ? vecs.Float16Vector : never; | ||
[Type.Float32]: T extends type.Float32 ? vecs.Float32Vector : never; | ||
[Type.Float64]: T extends type.Float64 ? vecs.Float64Vector : never; | ||
[Type.Float]: T extends type.Float ? vecs.FloatVector : never; | ||
[Type.Utf8]: T extends type.Utf8 ? vecs.Utf8Vector : never; | ||
[Type.Binary]: T extends type.Binary ? vecs.BinaryVector : never; | ||
[Type.FixedSizeBinary]: T extends type.FixedSizeBinary ? vecs.FixedSizeBinaryVector : never; | ||
[Type.Date]: T extends type.Date_ ? vecs.DateVector : never; | ||
[Type.DateDay]: T extends type.DateDay ? vecs.DateDayVector : never; | ||
[Type.DateMillisecond]: T extends type.DateMillisecond ? vecs.DateMillisecondVector : never; | ||
[Type.Timestamp]: T extends type.Timestamp ? vecs.TimestampVector : never; | ||
[Type.TimestampSecond]: T extends type.TimestampSecond ? vecs.TimestampSecondVector : never; | ||
[Type.TimestampMillisecond]: T extends type.TimestampMillisecond ? vecs.TimestampMillisecondVector : never; | ||
[Type.TimestampMicrosecond]: T extends type.TimestampMicrosecond ? vecs.TimestampMicrosecondVector : never; | ||
[Type.TimestampNanosecond]: T extends type.TimestampNanosecond ? vecs.TimestampNanosecondVector : never; | ||
[Type.Time]: T extends type.Time ? vecs.TimeVector : never; | ||
[Type.TimeSecond]: T extends type.TimeSecond ? vecs.TimeSecondVector : never; | ||
[Type.TimeMillisecond]: T extends type.TimeMillisecond ? vecs.TimeMillisecondVector : never; | ||
[Type.TimeMicrosecond]: T extends type.TimeMicrosecond ? vecs.TimeMicrosecondVector : never; | ||
[Type.TimeNanosecond]: T extends type.TimeNanosecond ? vecs.TimeNanosecondVector : never; | ||
[Type.Decimal]: T extends type.Decimal ? vecs.DecimalVector : never; | ||
[Type.Union]: T extends type.Union ? vecs.UnionVector : never; | ||
[Type.DenseUnion]: T extends type.DenseUnion ? vecs.DenseUnionVector : never; | ||
[Type.SparseUnion]: T extends type.SparseUnion ? vecs.SparseUnionVector : never; | ||
[Type.Interval]: T extends type.Interval ? vecs.IntervalVector : never; | ||
[Type.IntervalDayTime]: T extends type.IntervalDayTime ? vecs.IntervalDayTimeVector : never; | ||
[Type.IntervalYearMonth]: T extends type.IntervalYearMonth ? vecs.IntervalYearMonthVector : never; | ||
[Type.Map]: T extends type.Map_ ? vecs.MapVector<T['keyType'], T['valueType']> : never; | ||
[Type.List]: T extends type.List ? vecs.ListVector<T['valueType']> : never; | ||
[Type.Struct]: T extends type.Struct ? vecs.StructVector<T['dataTypes']> : never; | ||
[Type.Dictionary]: T extends type.Dictionary ? vecs.DictionaryVector<T['valueType'], T['indices']> : never; | ||
[Type.FixedSizeList]: T extends type.FixedSizeList ? vecs.FixedSizeListVector<T['valueType']> : never; | ||
}[T['TType']]; | ||
@@ -281,46 +281,46 @@ /** @ignore */ | ||
[key: number]: builders.Builder<any, TNull>; | ||
[Type.Null]: T extends type.Null ? builders.NullBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Bool]: T extends type.Bool ? builders.BoolBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Int8]: T extends type.Int8 ? builders.Int8Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Int16]: T extends type.Int16 ? builders.Int16Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Int32]: T extends type.Int32 ? builders.Int32Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Int64]: T extends type.Int64 ? builders.Int64Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Uint8]: T extends type.Uint8 ? builders.Uint8Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Uint16]: T extends type.Uint16 ? builders.Uint16Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Uint32]: T extends type.Uint32 ? builders.Uint32Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Uint64]: T extends type.Uint64 ? builders.Uint64Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Int]: T extends type.Int ? builders.IntBuilder<T, TNull> : builders.Builder<any, TNull>; | ||
[Type.Float16]: T extends type.Float16 ? builders.Float16Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Float32]: T extends type.Float32 ? builders.Float32Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Float64]: T extends type.Float64 ? builders.Float64Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Float]: T extends type.Float ? builders.FloatBuilder<T, TNull> : builders.Builder<any, TNull>; | ||
[Type.Utf8]: T extends type.Utf8 ? builders.Utf8Builder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Binary]: T extends type.Binary ? builders.BinaryBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.FixedSizeBinary]: T extends type.FixedSizeBinary ? builders.FixedSizeBinaryBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Date]: T extends type.Date_ ? builders.DateBuilder<T, TNull> : builders.Builder<any, TNull>; | ||
[Type.DateDay]: T extends type.DateDay ? builders.DateDayBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.DateMillisecond]: T extends type.DateMillisecond ? builders.DateMillisecondBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Timestamp]: T extends type.Timestamp ? builders.TimestampBuilder<T, TNull> : builders.Builder<any, TNull>; | ||
[Type.TimestampSecond]: T extends type.TimestampSecond ? builders.TimestampSecondBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.TimestampMillisecond]: T extends type.TimestampMillisecond ? builders.TimestampMillisecondBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.TimestampMicrosecond]: T extends type.TimestampMicrosecond ? builders.TimestampMicrosecondBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.TimestampNanosecond]: T extends type.TimestampNanosecond ? builders.TimestampNanosecondBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Time]: T extends type.Time ? builders.TimeBuilder<T, TNull> : builders.Builder<any, TNull>; | ||
[Type.TimeSecond]: T extends type.TimeSecond ? builders.TimeSecondBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.TimeMillisecond]: T extends type.TimeMillisecond ? builders.TimeMillisecondBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.TimeMicrosecond]: T extends type.TimeMicrosecond ? builders.TimeMicrosecondBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.TimeNanosecond]: T extends type.TimeNanosecond ? builders.TimeNanosecondBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Decimal]: T extends type.Decimal ? builders.DecimalBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Union]: T extends type.Union ? builders.UnionBuilder<T, TNull> : builders.Builder<any, TNull>; | ||
[Type.DenseUnion]: T extends type.DenseUnion ? builders.DenseUnionBuilder<T, TNull> : builders.Builder<any, TNull>; | ||
[Type.SparseUnion]: T extends type.SparseUnion ? builders.SparseUnionBuilder<T, TNull> : builders.Builder<any, TNull>; | ||
[Type.Interval]: T extends type.Interval ? builders.IntervalBuilder<T, TNull> : builders.Builder<any, TNull>; | ||
[Type.IntervalDayTime]: T extends type.IntervalDayTime ? builders.IntervalDayTimeBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.IntervalYearMonth]: T extends type.IntervalYearMonth ? builders.IntervalYearMonthBuilder<TNull> : builders.Builder<any, TNull>; | ||
[Type.Map]: T extends type.Map_ ? builders.MapBuilder<T['keyType'], T['valueType'], TNull> : builders.Builder<any, TNull>; | ||
[Type.List]: T extends type.List ? builders.ListBuilder<T['valueType'], TNull> : builders.Builder<any, TNull>; | ||
[Type.Struct]: T extends type.Struct ? builders.StructBuilder<T['dataTypes'], TNull> : builders.Builder<any, TNull>; | ||
[Type.Dictionary]: T extends type.Dictionary ? builders.DictionaryBuilder<T, TNull> : builders.Builder<any, TNull>; | ||
[Type.FixedSizeList]: T extends type.FixedSizeList ? builders.FixedSizeListBuilder<T['valueType'], TNull> : builders.Builder<any, TNull>; | ||
[Type.Null]: T extends type.Null ? builders.NullBuilder<TNull> : never; | ||
[Type.Bool]: T extends type.Bool ? builders.BoolBuilder<TNull> : never; | ||
[Type.Int8]: T extends type.Int8 ? builders.Int8Builder<TNull> : never; | ||
[Type.Int16]: T extends type.Int16 ? builders.Int16Builder<TNull> : never; | ||
[Type.Int32]: T extends type.Int32 ? builders.Int32Builder<TNull> : never; | ||
[Type.Int64]: T extends type.Int64 ? builders.Int64Builder<TNull> : never; | ||
[Type.Uint8]: T extends type.Uint8 ? builders.Uint8Builder<TNull> : never; | ||
[Type.Uint16]: T extends type.Uint16 ? builders.Uint16Builder<TNull> : never; | ||
[Type.Uint32]: T extends type.Uint32 ? builders.Uint32Builder<TNull> : never; | ||
[Type.Uint64]: T extends type.Uint64 ? builders.Uint64Builder<TNull> : never; | ||
[Type.Int]: T extends type.Int ? builders.IntBuilder<T, TNull> : never; | ||
[Type.Float16]: T extends type.Float16 ? builders.Float16Builder<TNull> : never; | ||
[Type.Float32]: T extends type.Float32 ? builders.Float32Builder<TNull> : never; | ||
[Type.Float64]: T extends type.Float64 ? builders.Float64Builder<TNull> : never; | ||
[Type.Float]: T extends type.Float ? builders.FloatBuilder<T, TNull> : never; | ||
[Type.Utf8]: T extends type.Utf8 ? builders.Utf8Builder<TNull> : never; | ||
[Type.Binary]: T extends type.Binary ? builders.BinaryBuilder<TNull> : never; | ||
[Type.FixedSizeBinary]: T extends type.FixedSizeBinary ? builders.FixedSizeBinaryBuilder<TNull> : never; | ||
[Type.Date]: T extends type.Date_ ? builders.DateBuilder<T, TNull> : never; | ||
[Type.DateDay]: T extends type.DateDay ? builders.DateDayBuilder<TNull> : never; | ||
[Type.DateMillisecond]: T extends type.DateMillisecond ? builders.DateMillisecondBuilder<TNull> : never; | ||
[Type.Timestamp]: T extends type.Timestamp ? builders.TimestampBuilder<T, TNull> : never; | ||
[Type.TimestampSecond]: T extends type.TimestampSecond ? builders.TimestampSecondBuilder<TNull> : never; | ||
[Type.TimestampMillisecond]: T extends type.TimestampMillisecond ? builders.TimestampMillisecondBuilder<TNull> : never; | ||
[Type.TimestampMicrosecond]: T extends type.TimestampMicrosecond ? builders.TimestampMicrosecondBuilder<TNull> : never; | ||
[Type.TimestampNanosecond]: T extends type.TimestampNanosecond ? builders.TimestampNanosecondBuilder<TNull> : never; | ||
[Type.Time]: T extends type.Time ? builders.TimeBuilder<T, TNull> : never; | ||
[Type.TimeSecond]: T extends type.TimeSecond ? builders.TimeSecondBuilder<TNull> : never; | ||
[Type.TimeMillisecond]: T extends type.TimeMillisecond ? builders.TimeMillisecondBuilder<TNull> : never; | ||
[Type.TimeMicrosecond]: T extends type.TimeMicrosecond ? builders.TimeMicrosecondBuilder<TNull> : never; | ||
[Type.TimeNanosecond]: T extends type.TimeNanosecond ? builders.TimeNanosecondBuilder<TNull> : never; | ||
[Type.Decimal]: T extends type.Decimal ? builders.DecimalBuilder<TNull> : never; | ||
[Type.Union]: T extends type.Union ? builders.UnionBuilder<T, TNull> : never; | ||
[Type.DenseUnion]: T extends type.DenseUnion ? builders.DenseUnionBuilder<T, TNull> : never; | ||
[Type.SparseUnion]: T extends type.SparseUnion ? builders.SparseUnionBuilder<T, TNull> : never; | ||
[Type.Interval]: T extends type.Interval ? builders.IntervalBuilder<T, TNull> : never; | ||
[Type.IntervalDayTime]: T extends type.IntervalDayTime ? builders.IntervalDayTimeBuilder<TNull> : never; | ||
[Type.IntervalYearMonth]: T extends type.IntervalYearMonth ? builders.IntervalYearMonthBuilder<TNull> : never; | ||
[Type.Map]: T extends type.Map_ ? builders.MapBuilder<T['keyType'], T['valueType'], TNull> : never; | ||
[Type.List]: T extends type.List ? builders.ListBuilder<T['valueType'], TNull> : never; | ||
[Type.Struct]: T extends type.Struct ? builders.StructBuilder<T['dataTypes'], TNull> : never; | ||
[Type.Dictionary]: T extends type.Dictionary ? builders.DictionaryBuilder<T, TNull> : never; | ||
[Type.FixedSizeList]: T extends type.FixedSizeList ? builders.FixedSizeListBuilder<T['valueType'], TNull> : never; | ||
}[T['TType']]; | ||
export {}; |
/// <reference types="node" /> | ||
import { ArrayBufferViewInput } from '../util/buffer'; | ||
import { ReadableDOMStreamOptions } from './interfaces'; | ||
declare type Uint8ArrayGenerator = Generator<Uint8Array, null, { | ||
cmd: 'peek' | 'read'; | ||
size: number; | ||
}>; | ||
declare type AsyncUint8ArrayGenerator = AsyncGenerator<Uint8Array, null, { | ||
cmd: 'peek' | 'read'; | ||
size: number; | ||
}>; | ||
declare const _default: { | ||
fromIterable<T extends ArrayBufferViewInput>(source: T | Iterable<T>): IterableIterator<Uint8Array>; | ||
fromAsyncIterable<T extends ArrayBufferViewInput>(source: AsyncIterable<T> | PromiseLike<T>): AsyncIterableIterator<Uint8Array>; | ||
fromDOMStream<T extends ArrayBufferViewInput>(source: ReadableStream<T>): AsyncIterableIterator<Uint8Array>; | ||
fromNodeStream(stream: NodeJS.ReadableStream): AsyncIterableIterator<Uint8Array>; | ||
toDOMStream<T>(source: Iterable<T> | AsyncIterable<T>, options?: ReadableDOMStreamOptions | undefined): ReadableStream<T>; | ||
toNodeStream<T>(source: Iterable<T> | AsyncIterable<T>, options?: import("stream").ReadableOptions | undefined): import("stream").Readable; | ||
fromIterable<T extends ArrayBufferViewInput>(source: T | Iterable<T>): Uint8ArrayGenerator; | ||
fromAsyncIterable<T_1 extends ArrayBufferViewInput>(source: AsyncIterable<T_1> | PromiseLike<T_1>): AsyncUint8ArrayGenerator; | ||
fromDOMStream<T_2 extends ArrayBufferViewInput>(source: ReadableStream<T_2>): AsyncUint8ArrayGenerator; | ||
fromNodeStream(stream: NodeJS.ReadableStream): AsyncUint8ArrayGenerator; | ||
toDOMStream<T_3>(source: Iterable<T_3> | AsyncIterable<T_3>, options?: ReadableDOMStreamOptions | undefined): ReadableStream<T_3>; | ||
toNodeStream<T_4>(source: Iterable<T_4> | AsyncIterable<T_4>, options?: import("stream").ReadableOptions | undefined): import('stream').Readable; | ||
}; | ||
/** @ignore */ | ||
export default _default; |
@@ -81,4 +81,5 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
finally { | ||
(threw === false) && (typeof it.return === 'function') && (it.return()); | ||
(threw === false) && (typeof it.return === 'function') && (it.return(null)); | ||
} | ||
return null; | ||
} | ||
@@ -98,3 +99,3 @@ /** @ignore */ | ||
// Yield so the caller can inject the read command before creating the source AsyncIterator | ||
({ cmd, size } = yield null); | ||
({ cmd, size } = (yield null)); | ||
// initialize the iterator | ||
@@ -125,4 +126,5 @@ let it = toUint8ArrayAsyncIterator(source)[Symbol.asyncIterator](); | ||
finally { | ||
(threw === false) && (typeof it.return === 'function') && (await it.return()); | ||
(threw === false) && (typeof it.return === 'function') && (await it.return(new Uint8Array(0))); | ||
} | ||
return null; | ||
} | ||
@@ -174,2 +176,3 @@ // All this manual Uint8Array chunk management can be avoided if/when engines | ||
} | ||
return null; | ||
} | ||
@@ -285,3 +288,4 @@ /** @ignore */ | ||
if (stream['isTTY']) { | ||
return yield new Uint8Array(0); | ||
yield new Uint8Array(0); | ||
return null; | ||
} | ||
@@ -332,2 +336,3 @@ try { | ||
} | ||
return null; | ||
function cleanup(events, err) { | ||
@@ -334,0 +339,0 @@ buffer = buffers = null; |
@@ -22,5 +22,5 @@ /// <reference types="node" /> | ||
constructor(_json: ArrowJSONLike); | ||
readonly schema: any; | ||
readonly batches: any[]; | ||
readonly dictionaries: any[]; | ||
get schema(): any; | ||
get batches(): any[]; | ||
get dictionaries(): any[]; | ||
} | ||
@@ -83,3 +83,3 @@ /** @ignore */ | ||
constructor(); | ||
readonly closed: Promise<void>; | ||
get closed(): Promise<void>; | ||
cancel(reason?: any): Promise<void>; | ||
@@ -86,0 +86,0 @@ write(value: TWritable): void; |
@@ -21,3 +21,3 @@ /// <reference types="node" /> | ||
[Symbol.iterator](): this; | ||
next(value?: any): IteratorResult<Uint8Array>; | ||
next(value?: any): IteratorResult<Uint8Array, null>; | ||
throw(value?: any): any; | ||
@@ -33,6 +33,6 @@ return(value?: any): any; | ||
[Symbol.asyncIterator](): this; | ||
next(value?: any): Promise<IteratorResult<Uint8Array>>; | ||
next(value?: any): Promise<IteratorResult<Uint8Array, null>>; | ||
throw(value?: any): Promise<any>; | ||
return(value?: any): Promise<any>; | ||
readonly closed: Promise<void>; | ||
get closed(): Promise<void>; | ||
cancel(reason?: any): Promise<void>; | ||
@@ -39,0 +39,0 @@ peek(size?: number | null): Promise<Uint8Array | null>; |
@@ -19,4 +19,4 @@ import * as File_ from '../../fb/File'; | ||
protected _dictionaryBatches: FileBlock[]; | ||
readonly numRecordBatches: number; | ||
readonly numDictionaries: number; | ||
get numRecordBatches(): number; | ||
get numDictionaries(): number; | ||
constructor(schema: Schema, version?: MetadataVersion, recordBatches?: FileBlock[], dictionaryBatches?: FileBlock[]); | ||
@@ -23,0 +23,0 @@ recordBatches(): Iterable<FileBlock>; |
@@ -118,2 +118,7 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
export class FileBlock { | ||
constructor(metaDataLength, bodyLength, offset) { | ||
this.metaDataLength = metaDataLength; | ||
this.offset = typeof offset === 'number' ? offset : offset.low; | ||
this.bodyLength = typeof bodyLength === 'number' ? bodyLength : bodyLength.low; | ||
} | ||
/** @nocollapse */ | ||
@@ -130,9 +135,4 @@ static decode(block) { | ||
} | ||
constructor(metaDataLength, bodyLength, offset) { | ||
this.metaDataLength = metaDataLength; | ||
this.offset = typeof offset === 'number' ? offset : offset.low; | ||
this.bodyLength = typeof bodyLength === 'number' ? bodyLength : bodyLength.low; | ||
} | ||
} | ||
//# sourceMappingURL=file.mjs.map |
@@ -34,6 +34,6 @@ import { flatbuffers } from 'flatbuffers'; | ||
protected _version: MetadataVersion; | ||
readonly type: T; | ||
readonly version: MetadataVersion; | ||
readonly headerType: T; | ||
readonly bodyLength: number; | ||
get type(): T; | ||
get version(): MetadataVersion; | ||
get headerType(): T; | ||
get bodyLength(): number; | ||
protected _createHeader: MessageHeaderDecoder; | ||
@@ -54,5 +54,5 @@ header(): T extends MessageHeader.Schema ? Schema<any> : T extends MessageHeader.RecordBatch ? RecordBatch : T extends MessageHeader.DictionaryBatch ? DictionaryBatch : never; | ||
protected _buffers: BufferRegion[]; | ||
readonly nodes: FieldNode[]; | ||
readonly length: number; | ||
readonly buffers: BufferRegion[]; | ||
get nodes(): FieldNode[]; | ||
get length(): number; | ||
get buffers(): BufferRegion[]; | ||
constructor(length: Long | number, nodes: FieldNode[], buffers: BufferRegion[]); | ||
@@ -68,8 +68,8 @@ } | ||
protected _data: RecordBatch; | ||
readonly id: number; | ||
readonly data: RecordBatch; | ||
readonly isDelta: boolean; | ||
readonly length: number; | ||
readonly nodes: FieldNode[]; | ||
readonly buffers: BufferRegion[]; | ||
get id(): number; | ||
get data(): RecordBatch; | ||
get isDelta(): boolean; | ||
get length(): number; | ||
get nodes(): FieldNode[]; | ||
get buffers(): BufferRegion[]; | ||
constructor(data: RecordBatch, id: Long | number, isDelta?: boolean); | ||
@@ -76,0 +76,0 @@ } |
@@ -115,5 +115,2 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
export class RecordBatch { | ||
get nodes() { return this._nodes; } | ||
get length() { return this._length; } | ||
get buffers() { return this._buffers; } | ||
constructor(length, nodes, buffers) { | ||
@@ -124,2 +121,5 @@ this._nodes = nodes; | ||
} | ||
get nodes() { return this._nodes; } | ||
get length() { return this._length; } | ||
get buffers() { return this._buffers; } | ||
} | ||
@@ -131,2 +131,7 @@ /** | ||
export class DictionaryBatch { | ||
constructor(data, id, isDelta = false) { | ||
this._data = data; | ||
this._isDelta = isDelta; | ||
this._id = typeof id === 'number' ? id : id.low; | ||
} | ||
get id() { return this._id; } | ||
@@ -138,7 +143,2 @@ get data() { return this._data; } | ||
get buffers() { return this.data.buffers; } | ||
constructor(data, id, isDelta = false) { | ||
this._data = data; | ||
this._isDelta = isDelta; | ||
this._id = typeof id === 'number' ? id : id.low; | ||
} | ||
} | ||
@@ -145,0 +145,0 @@ /** |
@@ -42,9 +42,9 @@ /// <reference types="node" /> | ||
protected constructor(impl: RecordBatchReaderImpls<T>); | ||
readonly closed: boolean; | ||
readonly schema: Schema<T>; | ||
readonly autoDestroy: boolean; | ||
readonly dictionaries: Map<number, Vector<any>>; | ||
readonly numDictionaries: number; | ||
readonly numRecordBatches: number; | ||
readonly footer: Footer | null; | ||
get closed(): boolean; | ||
get schema(): Schema<T>; | ||
get autoDestroy(): boolean; | ||
get dictionaries(): Map<number, Vector<any>>; | ||
get numDictionaries(): number; | ||
get numRecordBatches(): number; | ||
get footer(): Footer | null; | ||
isSync(): this is RecordBatchReaders<T>; | ||
@@ -54,5 +54,5 @@ isAsync(): this is AsyncRecordBatchReaders<T>; | ||
isStream(): this is RecordBatchStreamReaders<T>; | ||
next(): IteratorResult<RecordBatch<T>> | Promise<IteratorResult<RecordBatch<T>>>; | ||
throw(value?: any): IteratorResult<any> | Promise<IteratorResult<any>>; | ||
return(value?: any): IteratorResult<any> | Promise<IteratorResult<any>>; | ||
next(): IteratorReturnResult<any> | IteratorYieldResult<RecordBatch<T>> | Promise<IteratorResult<RecordBatch<T>, any>>; | ||
throw(value?: any): IteratorReturnResult<any> | IteratorYieldResult<any> | Promise<IteratorResult<any, any>>; | ||
return(value?: any): IteratorReturnResult<any> | IteratorYieldResult<any> | Promise<IteratorResult<any, any>>; | ||
cancel(): void | Promise<void>; | ||
@@ -174,3 +174,2 @@ reset(schema?: Schema<T> | null): this; | ||
} = any> extends RecordBatchStreamReader<T> { | ||
footer: Footer; | ||
readRecordBatch(index: number): RecordBatch<T> | null; | ||
@@ -182,3 +181,2 @@ } | ||
} = any> extends AsyncRecordBatchStreamReader<T> { | ||
footer: Footer; | ||
readRecordBatch(index: number): Promise<RecordBatch<T> | null>; | ||
@@ -248,4 +246,4 @@ } | ||
protected _recordBatchIndex: number; | ||
readonly numDictionaries: number; | ||
readonly numRecordBatches: number; | ||
get numDictionaries(): number; | ||
get numRecordBatches(): number; | ||
constructor(dictionaries?: Map<number, Vector<any>>); | ||
@@ -284,5 +282,5 @@ protected _loadRecordBatch(header: metadata.RecordBatch, body: any): RecordBatch<T>; | ||
protected _handle: RandomAccessFile; | ||
readonly footer: Footer; | ||
readonly numDictionaries: number; | ||
readonly numRecordBatches: number; | ||
get footer(): Footer; | ||
get numDictionaries(): number; | ||
get numRecordBatches(): number; | ||
constructor(source: RandomAccessFile | ArrayBufferViewInput, dictionaries?: Map<number, Vector>); | ||
@@ -302,5 +300,5 @@ isSync(): this is RecordBatchReaders<T>; | ||
protected _handle: AsyncRandomAccessFile; | ||
readonly footer: Footer; | ||
readonly numDictionaries: number; | ||
readonly numRecordBatches: number; | ||
get footer(): Footer; | ||
get numDictionaries(): number; | ||
get numRecordBatches(): number; | ||
constructor(source: FileHandle, byteLength?: number, dictionaries?: Map<number, Vector>); | ||
@@ -307,0 +305,0 @@ constructor(source: FileHandle | AsyncRandomAccessFile, dictionaries?: Map<number, Vector>); |
@@ -63,3 +63,3 @@ /// <reference types="node" /> | ||
writeAll(input: PromiseLike<Table<T> | Iterable<RecordBatch<T>>>): Promise<this>; | ||
readonly closed: Promise<void>; | ||
get closed(): Promise<void>; | ||
[Symbol.asyncIterator](): AsyncByteQueue<Uint8Array>; | ||
@@ -66,0 +66,0 @@ toDOMStream(options?: ReadableDOMStreamOptions): ReadableStream<Uint8Array>; |
@@ -270,6 +270,2 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
export class RecordBatchFileWriter extends RecordBatchWriter { | ||
constructor() { | ||
super(); | ||
this._autoDestroy = true; | ||
} | ||
/** @nocollapse */ | ||
@@ -286,2 +282,6 @@ static writeAll(input) { | ||
} | ||
constructor() { | ||
super(); | ||
this._autoDestroy = true; | ||
} | ||
// @ts-ignore | ||
@@ -288,0 +288,0 @@ _writeSchema(schema) { |
{ | ||
"version": "0.17.0", | ||
"version": "2.0.0", | ||
"name": "@apache-arrow/esnext-esm", | ||
@@ -37,3 +37,3 @@ "browser": "Arrow.dom.js", | ||
"text-encoding-utf-8": "^1.0.2", | ||
"tslib": "^1.9.3" | ||
"tslib": "^1.12.0" | ||
}, | ||
@@ -40,0 +40,0 @@ "bin": { |
@@ -125,3 +125,3 @@ <!--- | ||
const table = await Table.from(fetch(("/simple.arrow"))); | ||
const table = await Table.from(fetch("/simple.arrow")); | ||
console.log(table.toString()); | ||
@@ -128,0 +128,0 @@ |
@@ -43,5 +43,5 @@ import { Data } from './data'; | ||
constructor(schema: Schema<T>, data: Data<Struct<T>>, children?: Vector[]); | ||
readonly schema: Schema<any>; | ||
readonly numCols: number; | ||
readonly dictionaries: Map<number, Vector<any>>; | ||
get schema(): Schema<any>; | ||
get numCols(): number; | ||
get dictionaries(): Map<number, Vector<any>>; | ||
select<K extends keyof T = any>(...columnNames: K[]): RecordBatch<{ | ||
@@ -48,0 +48,0 @@ [key: string]: any; |
@@ -38,3 +38,3 @@ import { Data } from './data'; | ||
constructor(fields?: Field[], metadata?: Map<string, string> | null, dictionaries?: Map<number, DataType> | null); | ||
readonly [Symbol.toStringTag]: string; | ||
get [Symbol.toStringTag](): string; | ||
toString(): string; | ||
@@ -66,4 +66,4 @@ compareTo(other?: Schema | null): other is Schema<T>; | ||
constructor(name: string, type: T, nullable?: boolean, metadata?: Map<string, string> | null); | ||
readonly typeId: import("./enum").Type; | ||
readonly [Symbol.toStringTag]: string; | ||
get typeId(): import("./enum").Type; | ||
get [Symbol.toStringTag](): string; | ||
toString(): string; | ||
@@ -70,0 +70,0 @@ compareTo(other?: Field | null): other is Field<T>; |
@@ -147,6 +147,6 @@ import { Data } from './data'; | ||
protected _children?: Column<T[keyof T]>[]; | ||
readonly schema: Schema<T>; | ||
readonly length: number; | ||
readonly chunks: RecordBatch<T>[]; | ||
readonly numCols: number; | ||
get schema(): Schema<T>; | ||
get length(): number; | ||
get chunks(): RecordBatch<T>[]; | ||
get numCols(): number; | ||
getColumn<R extends keyof T>(name: R): Column<T[R]>; | ||
@@ -156,3 +156,3 @@ getColumnAt<R extends DataType = any>(index: number): Column<R> | null; | ||
getChildAt<R extends DataType = any>(index: number): Column<R> | null; | ||
serialize(encoding?: string, stream?: boolean): any; | ||
serialize(encoding?: string, stream?: boolean): Uint8Array; | ||
count(): number; | ||
@@ -159,0 +159,0 @@ select<K extends keyof T = any>(...columnNames: K[]): Table<{ |
@@ -65,3 +65,3 @@ import { Field } from './schema'; | ||
/** @nocollapse */ static isDictionary(x: any): x is Dictionary; | ||
readonly typeId: TType; | ||
get typeId(): TType; | ||
compareTo(other: DataType): other is TypeToDataType<TType>; | ||
@@ -78,3 +78,3 @@ protected static [Symbol.toStringTag]: string; | ||
toString(): string; | ||
readonly typeId: Type.Null; | ||
get typeId(): Type.Null; | ||
protected static [Symbol.toStringTag]: string; | ||
@@ -151,4 +151,4 @@ } | ||
constructor(isSigned: IType[T]['isSigned'], bitWidth: IType[T]['bitWidth']); | ||
readonly typeId: T; | ||
readonly ArrayType: TypedArrayConstructor<IType[T]['TArray']>; | ||
get typeId(): T; | ||
get ArrayType(): TypedArrayConstructor<IType[T]['TArray']>; | ||
toString(): string; | ||
@@ -224,4 +224,4 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(precision: Precision); | ||
readonly typeId: T; | ||
readonly ArrayType: TypedArrayConstructor<FType[T]['TArray']>; | ||
get typeId(): T; | ||
get ArrayType(): TypedArrayConstructor<FType[T]['TArray']>; | ||
toString(): string; | ||
@@ -251,3 +251,3 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(); | ||
readonly typeId: Type.Binary; | ||
get typeId(): Type.Binary; | ||
toString(): string; | ||
@@ -265,3 +265,3 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(); | ||
readonly typeId: Type.Utf8; | ||
get typeId(): Type.Utf8; | ||
toString(): string; | ||
@@ -279,3 +279,3 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(); | ||
readonly typeId: Type.Bool; | ||
get typeId(): Type.Bool; | ||
toString(): string; | ||
@@ -295,3 +295,3 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(scale: number, precision: number); | ||
readonly typeId: Type.Decimal; | ||
get typeId(): Type.Decimal; | ||
toString(): string; | ||
@@ -312,3 +312,3 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(unit: DateUnit); | ||
readonly typeId: T; | ||
get typeId(): T; | ||
toString(): string; | ||
@@ -361,3 +361,3 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(unit: TimesType[T]['unit'], bitWidth: TimeBitWidth); | ||
readonly typeId: T; | ||
get typeId(): T; | ||
toString(): string; | ||
@@ -396,3 +396,3 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(unit: TimeUnit, timezone?: string | null | undefined); | ||
readonly typeId: T; | ||
get typeId(): T; | ||
toString(): string; | ||
@@ -430,3 +430,3 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(unit: IntervalUnit); | ||
readonly typeId: T; | ||
get typeId(): T; | ||
toString(): string; | ||
@@ -457,7 +457,7 @@ protected static [Symbol.toStringTag]: string; | ||
readonly children: Field<T>[]; | ||
readonly typeId: Type.List; | ||
get typeId(): Type.List; | ||
toString(): string; | ||
readonly valueType: T; | ||
readonly valueField: Field<T>; | ||
readonly ArrayType: T['ArrayType']; | ||
get valueType(): T; | ||
get valueField(): Field<T>; | ||
get ArrayType(): T['ArrayType']; | ||
protected static [Symbol.toStringTag]: string; | ||
@@ -479,3 +479,3 @@ } | ||
constructor(children: Field<T[keyof T]>[]); | ||
readonly typeId: Type.Struct; | ||
get typeId(): Type.Struct; | ||
toString(): string; | ||
@@ -501,3 +501,3 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(mode: UnionMode, typeIds: number[] | Int32Array, children: Field<any>[]); | ||
readonly typeId: T; | ||
get typeId(): T; | ||
toString(): string; | ||
@@ -525,3 +525,3 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(byteWidth: number); | ||
readonly typeId: Type.FixedSizeBinary; | ||
get typeId(): Type.FixedSizeBinary; | ||
toString(): string; | ||
@@ -542,6 +542,6 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(listSize: number, child: Field<T>); | ||
readonly typeId: Type.FixedSizeList; | ||
readonly valueType: T; | ||
readonly valueField: Field<T>; | ||
readonly ArrayType: T['ArrayType']; | ||
get typeId(): Type.FixedSizeList; | ||
get valueType(): T; | ||
get valueField(): Field<T>; | ||
get ArrayType(): T['ArrayType']; | ||
toString(): string; | ||
@@ -570,5 +570,5 @@ protected static [Symbol.toStringTag]: string; | ||
}>>[]; | ||
readonly typeId: Type.Map; | ||
readonly keyType: TKey; | ||
readonly valueType: TValue; | ||
get typeId(): Type.Map; | ||
get keyType(): TKey; | ||
get valueType(): TValue; | ||
toString(): string; | ||
@@ -591,6 +591,6 @@ protected static [Symbol.toStringTag]: string; | ||
constructor(dictionary: T, indices: TKey, id?: Long | number | null, isOrdered?: boolean | null); | ||
readonly typeId: Type.Dictionary; | ||
readonly children: Field<any>[]; | ||
readonly valueType: T; | ||
readonly ArrayType: T['ArrayType']; | ||
get typeId(): Type.Dictionary; | ||
get children(): Field<any>[]; | ||
get valueType(): T; | ||
get ArrayType(): T['ArrayType']; | ||
toString(): string; | ||
@@ -597,0 +597,0 @@ protected static [Symbol.toStringTag]: string; |
@@ -138,2 +138,3 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
} | ||
// @ts-ignore | ||
throw new Error(`Unrecognized ${this[Symbol.toStringTag]} type`); | ||
@@ -140,0 +141,0 @@ } |
@@ -5,2 +5,3 @@ import { Field } from '../schema'; | ||
import { DataType } from '../type'; | ||
declare type RecordBatchCtor = typeof import('../recordbatch').RecordBatch; | ||
/** @ignore */ | ||
@@ -19,4 +20,5 @@ export declare const selectArgs: <T>(Ctor: any, vals: any[]) => T[]; | ||
/** @ignore */ | ||
export declare const selectVectorChildrenArgs: <T extends Vector<any>>(Ctor: typeof import("../recordbatch").RecordBatch, vals: any[]) => T[]; | ||
export declare const selectVectorChildrenArgs: <T extends Vector<any>>(Ctor: RecordBatchCtor, vals: any[]) => T[]; | ||
/** @ignore */ | ||
export declare const selectColumnChildrenArgs: <T extends Column<any>>(Ctor: typeof import("../recordbatch").RecordBatch, vals: any[]) => T[]; | ||
export declare const selectColumnChildrenArgs: <T extends Column<any>>(Ctor: RecordBatchCtor, vals: any[]) => T[]; | ||
export {}; |
@@ -12,3 +12,3 @@ /** @ignore */ | ||
/** @ignore */ | ||
export declare function iterateBits<T>(bytes: Uint8Array, begin: number, length: number, context: any, get: (context: any, index: number, byte: number, bit: number) => T): IterableIterator<T>; | ||
export declare function iterateBits<T>(bytes: Uint8Array, begin: number, length: number, context: any, get: (context: any, index: number, byte: number, bit: number) => T): Generator<T, void, unknown>; | ||
/** | ||
@@ -15,0 +15,0 @@ * Compute the population count (the number of bits set to 1) for a range of bits in a Uint8Array. |
@@ -38,2 +38,3 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
} | ||
// @ts-ignore | ||
return bignumToString(this); | ||
@@ -98,5 +99,2 @@ }; | ||
export class BN { | ||
constructor(num, isSigned) { | ||
return BN.new(num, isSigned); | ||
} | ||
/** @nocollapse */ | ||
@@ -132,4 +130,7 @@ static new(num, isSigned) { | ||
} | ||
constructor(num, isSigned) { | ||
return BN.new(num, isSigned); | ||
} | ||
} | ||
//# sourceMappingURL=bn.mjs.map |
@@ -28,25 +28,25 @@ import { flatbuffers } from 'flatbuffers'; | ||
/** @ignore */ | ||
export declare function toArrayBufferViewIterator<T extends TypedArray>(ArrayCtor: TypedArrayConstructor<T>, source: ArrayBufferViewIteratorInput): IterableIterator<T>; | ||
/** @ignore */ export declare const toInt8ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<ArrayBufferViewInput> | null | undefined) => IterableIterator<Int8Array>; | ||
/** @ignore */ export declare const toInt16ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<ArrayBufferViewInput> | null | undefined) => IterableIterator<Int16Array>; | ||
/** @ignore */ export declare const toInt32ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<ArrayBufferViewInput> | null | undefined) => IterableIterator<Int32Array>; | ||
/** @ignore */ export declare const toUint8ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<ArrayBufferViewInput> | null | undefined) => IterableIterator<Uint8Array>; | ||
/** @ignore */ export declare const toUint16ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<ArrayBufferViewInput> | null | undefined) => IterableIterator<Uint16Array>; | ||
/** @ignore */ export declare const toUint32ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<ArrayBufferViewInput> | null | undefined) => IterableIterator<Uint32Array>; | ||
/** @ignore */ export declare const toFloat32ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<ArrayBufferViewInput> | null | undefined) => IterableIterator<Float32Array>; | ||
/** @ignore */ export declare const toFloat64ArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<ArrayBufferViewInput> | null | undefined) => IterableIterator<Float64Array>; | ||
/** @ignore */ export declare const toUint8ClampedArrayIterator: (input: string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | IteratorResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | ReadableStreamReadResult<string | ArrayBuffer | SharedArrayBuffer | ArrayBufferView | ArrayLike<number> | Iterable<number> | flatbuffers.ByteBuffer | null | undefined> | Iterable<ArrayBufferViewInput> | null | undefined) => IterableIterator<Uint8ClampedArray>; | ||
export declare function toArrayBufferViewIterator<T extends TypedArray>(ArrayCtor: TypedArrayConstructor<T>, source: ArrayBufferViewIteratorInput): Generator<T, T, number | undefined>; | ||
/** @ignore */ export declare const toInt8ArrayIterator: (input: ArrayBufferViewIteratorInput) => Generator<Int8Array, Int8Array, number | undefined>; | ||
/** @ignore */ export declare const toInt16ArrayIterator: (input: ArrayBufferViewIteratorInput) => Generator<Int16Array, Int16Array, number | undefined>; | ||
/** @ignore */ export declare const toInt32ArrayIterator: (input: ArrayBufferViewIteratorInput) => Generator<Int32Array, Int32Array, number | undefined>; | ||
/** @ignore */ export declare const toUint8ArrayIterator: (input: ArrayBufferViewIteratorInput) => Generator<Uint8Array, Uint8Array, number | undefined>; | ||
/** @ignore */ export declare const toUint16ArrayIterator: (input: ArrayBufferViewIteratorInput) => Generator<Uint16Array, Uint16Array, number | undefined>; | ||
/** @ignore */ export declare const toUint32ArrayIterator: (input: ArrayBufferViewIteratorInput) => Generator<Uint32Array, Uint32Array, number | undefined>; | ||
/** @ignore */ export declare const toFloat32ArrayIterator: (input: ArrayBufferViewIteratorInput) => Generator<Float32Array, Float32Array, number | undefined>; | ||
/** @ignore */ export declare const toFloat64ArrayIterator: (input: ArrayBufferViewIteratorInput) => Generator<Float64Array, Float64Array, number | undefined>; | ||
/** @ignore */ export declare const toUint8ClampedArrayIterator: (input: ArrayBufferViewIteratorInput) => Generator<Uint8ClampedArray, Uint8ClampedArray, number | undefined>; | ||
/** @ignore */ | ||
declare type ArrayBufferViewAsyncIteratorInput = AsyncIterable<ArrayBufferViewInput> | Iterable<ArrayBufferViewInput> | PromiseLike<ArrayBufferViewInput> | ArrayBufferViewInput; | ||
/** @ignore */ | ||
export declare function toArrayBufferViewAsyncIterator<T extends TypedArray>(ArrayCtor: TypedArrayConstructor<T>, source: ArrayBufferViewAsyncIteratorInput): AsyncIterableIterator<T>; | ||
/** @ignore */ export declare const toInt8ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncIterableIterator<Int8Array>; | ||
/** @ignore */ export declare const toInt16ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncIterableIterator<Int16Array>; | ||
/** @ignore */ export declare const toInt32ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncIterableIterator<Int32Array>; | ||
/** @ignore */ export declare const toUint8ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncIterableIterator<Uint8Array>; | ||
/** @ignore */ export declare const toUint16ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncIterableIterator<Uint16Array>; | ||
/** @ignore */ export declare const toUint32ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncIterableIterator<Uint32Array>; | ||
/** @ignore */ export declare const toFloat32ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncIterableIterator<Float32Array>; | ||
/** @ignore */ export declare const toFloat64ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncIterableIterator<Float64Array>; | ||
/** @ignore */ export declare const toUint8ClampedArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncIterableIterator<Uint8ClampedArray>; | ||
export declare function toArrayBufferViewAsyncIterator<T extends TypedArray>(ArrayCtor: TypedArrayConstructor<T>, source: ArrayBufferViewAsyncIteratorInput): AsyncGenerator<T, T, number | undefined>; | ||
/** @ignore */ export declare const toInt8ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncGenerator<Int8Array, Int8Array, number | undefined>; | ||
/** @ignore */ export declare const toInt16ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncGenerator<Int16Array, Int16Array, number | undefined>; | ||
/** @ignore */ export declare const toInt32ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncGenerator<Int32Array, Int32Array, number | undefined>; | ||
/** @ignore */ export declare const toUint8ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncGenerator<Uint8Array, Uint8Array, number | undefined>; | ||
/** @ignore */ export declare const toUint16ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncGenerator<Uint16Array, Uint16Array, number | undefined>; | ||
/** @ignore */ export declare const toUint32ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncGenerator<Uint32Array, Uint32Array, number | undefined>; | ||
/** @ignore */ export declare const toFloat32ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncGenerator<Float32Array, Float32Array, number | undefined>; | ||
/** @ignore */ export declare const toFloat64ArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncGenerator<Float64Array, Float64Array, number | undefined>; | ||
/** @ignore */ export declare const toUint8ClampedArrayAsyncIterator: (input: ArrayBufferViewAsyncIteratorInput) => AsyncGenerator<Uint8ClampedArray, Uint8ClampedArray, number | undefined>; | ||
/** @ignore */ | ||
@@ -53,0 +53,0 @@ export declare function rebaseValueOffsets(offset: number, length: number, valueOffsets: Int32Array): Int32Array; |
@@ -136,2 +136,3 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
})(buffers[Symbol.iterator]())); | ||
return new ArrayCtor(); | ||
} | ||
@@ -175,2 +176,3 @@ /** @ignore */ export const toInt8ArrayIterator = (input) => toArrayBufferViewIterator(Int8Array, input); | ||
})(buffers[Symbol.asyncIterator]())); | ||
return new ArrayCtor(); | ||
} | ||
@@ -177,0 +179,0 @@ /** @ignore */ export const toInt8ArrayAsyncIterator = (input) => toArrayBufferViewAsyncIterator(Int8Array, input); |
/// <reference types="node" /> | ||
/// <reference types="graceful-fs" /> | ||
import { ArrowJSONLike } from '../io/interfaces'; | ||
@@ -42,3 +43,3 @@ /** @ignore */ | ||
/** @ignore */ | ||
export declare const isIteratorResult: <T = any>(x: any) => x is IteratorResult<T>; | ||
export declare const isIteratorResult: <T = any>(x: any) => x is IteratorResult<T, any>; | ||
/** @ignore */ | ||
@@ -45,0 +46,0 @@ export declare const isUnderlyingSink: <T = any>(x: any) => x is UnderlyingSink<T>; |
/** @ignore */ | ||
export declare const decodeUtf8: (input: ArrayBuffer | SharedArrayBuffer | ArrayBufferView) => string; | ||
export declare const decodeUtf8: (input: ArrayBufferLike | ArrayBufferView) => string; | ||
/** @ignore */ | ||
export declare const encodeUtf8: (value?: string | undefined) => Uint8Array; |
@@ -15,3 +15,3 @@ /** @ignore */ | ||
/** @ignore */ | ||
export declare function createElementComparator(search: any): (value: any) => boolean; | ||
export declare function createElementComparator(search: any): ((value: any) => boolean) | (() => boolean); | ||
export {}; |
@@ -17,3 +17,3 @@ import { Data } from './data'; | ||
} | ||
export interface AbstractVector<T extends DataType = any> extends Clonable<Vector<T>>, Sliceable<Vector<T>>, Applicative<T, Chunked<T>> { | ||
export interface AbstractVector<T extends DataType = any> extends Clonable<AbstractVector<T>>, Sliceable<AbstractVector<T>>, Applicative<T, Chunked<T>> { | ||
readonly TType: T['TType']; | ||
@@ -20,0 +20,0 @@ readonly TArray: T['TArray']; |
@@ -19,4 +19,5 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
} | ||
AbstractVector.prototype.data = null; | ||
export { AbstractVector as Vector }; | ||
//# sourceMappingURL=vector.mjs.map |
@@ -18,16 +18,16 @@ import { Data } from '../data'; | ||
readonly numChildren: number; | ||
readonly type: T; | ||
readonly typeId: T["TType"]; | ||
readonly length: number; | ||
readonly offset: number; | ||
readonly stride: number; | ||
readonly nullCount: number; | ||
readonly byteLength: number; | ||
readonly VectorName: string; | ||
readonly ArrayType: T['ArrayType']; | ||
readonly values: T["TArray"]; | ||
readonly typeIds: T["TArray"]; | ||
readonly nullBitmap: Uint8Array; | ||
readonly valueOffsets: Int32Array; | ||
readonly [Symbol.toStringTag]: string; | ||
get type(): T; | ||
get typeId(): T["TType"]; | ||
get length(): number; | ||
get offset(): number; | ||
get stride(): number; | ||
get nullCount(): number; | ||
get byteLength(): number; | ||
get VectorName(): string; | ||
get ArrayType(): T['ArrayType']; | ||
get values(): T["TArray"]; | ||
get typeIds(): T["TArray"]; | ||
get nullBitmap(): Uint8Array; | ||
get valueOffsets(): Int32Array; | ||
get [Symbol.toStringTag](): string; | ||
isValid(index: number): boolean; | ||
@@ -34,0 +34,0 @@ getChildAt<R extends DataType = any>(index: number): Vector<R> | null; |
@@ -10,4 +10,4 @@ import { Bool } from '../type'; | ||
static from<TNull = any>(input: AsyncIterable<boolean | TNull>): Promise<BoolVector>; | ||
static from<TNull = any>(input: VectorBuilderOptions<Bool, TNull>): Chunked<Bool>; | ||
static from<TNull = any>(input: VectorBuilderOptionsAsync<Bool, TNull>): Promise<Chunked<Bool>>; | ||
static from<TNull = any>(input: VectorBuilderOptions<Bool, boolean | TNull>): Chunked<Bool>; | ||
static from<TNull = any>(input: VectorBuilderOptionsAsync<Bool, boolean | TNull>): Promise<Chunked<Bool>>; | ||
} |
@@ -14,3 +14,3 @@ import { Data } from '../data'; | ||
/** @nocollapse */ | ||
static flatten<T extends DataType>(...vectors: (Vector<T> | Vector<T>[])[]): Vector<T>[]; | ||
static flatten<T extends DataType>(...vectors: (Vector<T> | Vector<T>[])[]): AbstractVector<T>[]; | ||
/** @nocollapse */ | ||
@@ -26,18 +26,18 @@ static concat<T extends DataType>(...vectors: (Vector<T> | Vector<T>[])[]): Chunked<T>; | ||
constructor(type: T, chunks?: Vector<T>[], offsets?: Uint32Array); | ||
readonly type: T; | ||
readonly length: number; | ||
readonly chunks: Vector<T>[]; | ||
readonly typeId: T['TType']; | ||
readonly VectorName: string; | ||
readonly data: Data<T>; | ||
readonly ArrayType: any; | ||
readonly numChildren: number; | ||
readonly stride: number; | ||
readonly byteLength: number; | ||
readonly nullCount: number; | ||
get type(): T; | ||
get length(): number; | ||
get chunks(): AbstractVector<T>[]; | ||
get typeId(): T['TType']; | ||
get VectorName(): string; | ||
get data(): Data<T>; | ||
get ArrayType(): any; | ||
get numChildren(): number; | ||
get stride(): number; | ||
get byteLength(): number; | ||
get nullCount(): number; | ||
protected _indices?: ChunkedKeys<T>; | ||
readonly indices: ChunkedKeys<T> | null; | ||
readonly dictionary: ChunkedDict<T> | null; | ||
get indices(): ChunkedKeys<T> | null; | ||
get dictionary(): ChunkedDict<T> | null; | ||
[Symbol.iterator](): IterableIterator<T['TValue'] | null>; | ||
clone(chunks?: Vector<T>[]): Chunked<T>; | ||
clone(chunks?: AbstractVector<T>[]): Chunked<T>; | ||
concat(...others: Vector<T>[]): Chunked<T>; | ||
@@ -44,0 +44,0 @@ slice(begin?: number, end?: number): Chunked<T>; |
@@ -16,4 +16,4 @@ import { DateUnit } from '../enum'; | ||
static from<T extends Date_, TNull = any>(input: AsyncIterable<Date | TNull>): Promise<V<T>>; | ||
static from<T extends Date_, TNull = any>(input: VectorBuilderOptions<T, TNull>): Chunked<T>; | ||
static from<T extends Date_, TNull = any>(input: VectorBuilderOptionsAsync<T, TNull>): Promise<Chunked<T>>; | ||
static from<T extends Date_, TNull = any>(input: VectorBuilderOptions<T, Date | TNull>): Chunked<T>; | ||
static from<T extends Date_, TNull = any>(input: VectorBuilderOptionsAsync<T, Date | TNull>): Promise<Chunked<T>>; | ||
} | ||
@@ -20,0 +20,0 @@ /** @ignore */ |
@@ -17,3 +17,3 @@ import { Data } from '../data'; | ||
readonly indices: V<TKey>; | ||
readonly dictionary: Vector<T>; | ||
get dictionary(): Vector<T>; | ||
reverseLookup(value: T): number; | ||
@@ -20,0 +20,0 @@ getKey(idx: number): TKey['TValue'] | null; |
@@ -79,3 +79,3 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
const chunks = [...Builder.throughIterable(options)(values)]; | ||
return chunks.length === 1 ? chunks[0] : Chunked.concat(chunks); | ||
return (chunks.length === 1 ? chunks[0] : Chunked.concat(chunks)); | ||
} | ||
@@ -87,3 +87,3 @@ return (async (chunks) => { | ||
} | ||
return chunks.length === 1 ? chunks[0] : Chunked.concat(chunks); | ||
return (chunks.length === 1 ? chunks[0] : Chunked.concat(chunks)); | ||
})([]); | ||
@@ -90,0 +90,0 @@ } |
@@ -47,3 +47,3 @@ import { Chunked } from './chunked'; | ||
private _values64; | ||
readonly values64: BigInt64Array; | ||
get values64(): BigInt64Array; | ||
} | ||
@@ -63,4 +63,4 @@ /** @ignore */ | ||
private _values64; | ||
readonly values64: BigUint64Array; | ||
get values64(): BigUint64Array; | ||
} | ||
export {}; |
@@ -54,4 +54,4 @@ import { Vector } from '../vector'; | ||
constructor(parent: StructVector<T>); | ||
keys(): IterableIterator<keyof T>; | ||
values(): IterableIterator<T[string]["TValue"] | null>; | ||
keys(): Generator<keyof T, void, unknown>; | ||
values(): Generator<T[string]["TValue"] | null, void, unknown>; | ||
getKey(idx: number): keyof T; | ||
@@ -58,0 +58,0 @@ getIndex(key: keyof T): number; |
@@ -5,3 +5,3 @@ import { BaseVector } from './base'; | ||
export declare class UnionVector<T extends Union = Union> extends BaseVector<T> { | ||
readonly typeIdToChildIndex: { | ||
get typeIdToChildIndex(): { | ||
[key: number]: number; | ||
@@ -12,3 +12,3 @@ }; | ||
export declare class DenseUnionVector extends UnionVector<DenseUnion> { | ||
readonly valueOffsets: Int32Array; | ||
get valueOffsets(): Int32Array; | ||
} | ||
@@ -15,0 +15,0 @@ /** @ignore */ |
@@ -10,5 +10,5 @@ import { Chunked } from './chunked'; | ||
static from<TNull = any>(input: AsyncIterable<string | TNull>): Promise<Utf8Vector>; | ||
static from<TNull = any>(input: VectorBuilderOptions<Utf8, TNull>): Chunked<Utf8>; | ||
static from<TNull = any>(input: VectorBuilderOptionsAsync<Utf8, TNull>): Promise<Chunked<Utf8>>; | ||
static from<TNull = any>(input: VectorBuilderOptions<Utf8, string | TNull>): Chunked<Utf8>; | ||
static from<TNull = any>(input: VectorBuilderOptionsAsync<Utf8, string | TNull>): Promise<Chunked<Utf8>>; | ||
asBinary(): import("./binary").BinaryVector; | ||
} |
@@ -216,2 +216,3 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
} | ||
// @ts-ignore | ||
return Type.Int; | ||
@@ -224,2 +225,3 @@ case Type.Float: | ||
} | ||
// @ts-ignore | ||
return Type.Float; | ||
@@ -237,2 +239,3 @@ case Type.Binary: return Type.Binary; | ||
} | ||
// @ts-ignore | ||
return Type.Time; | ||
@@ -246,2 +249,3 @@ case Type.Timestamp: | ||
} | ||
// @ts-ignore | ||
return Type.Timestamp; | ||
@@ -253,2 +257,3 @@ case Type.Date: | ||
} | ||
// @ts-ignore | ||
return Type.Date; | ||
@@ -260,2 +265,3 @@ case Type.Interval: | ||
} | ||
// @ts-ignore | ||
return Type.Interval; | ||
@@ -270,2 +276,3 @@ case Type.Map: return Type.Map; | ||
} | ||
// @ts-ignore | ||
return Type.Union; | ||
@@ -272,0 +279,0 @@ case Type.FixedSizeBinary: return Type.FixedSizeBinary; |
@@ -30,3 +30,3 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
function indexOfNull(vector, fromIndex) { | ||
const { nullBitmap } = vector; | ||
const { nullBitmap } = vector.data; | ||
if (!nullBitmap || vector.nullCount <= 0) { | ||
@@ -33,0 +33,0 @@ return -1; |
@@ -27,3 +27,3 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
const getFn = getVisitor.getVisitFn(vector); | ||
return iterateBits(vector.nullBitmap, vector.offset, vector.length, vector, (vec, idx, nullByte, nullBit) => ((nullByte & 1 << nullBit) !== 0) ? getFn(vec, idx) : null); | ||
return iterateBits(vector.data.nullBitmap, vector.data.offset, vector.length, vector, (vec, idx, nullByte, nullBit) => ((nullByte & 1 << nullBit) !== 0) ? getFn(vec, idx) : null); | ||
} | ||
@@ -42,3 +42,3 @@ /** @ignore */ | ||
(typeId === Type.Float && type.precision > 0 /* Precision.HALF */))) { | ||
return vector.values.subarray(0, length)[Symbol.iterator](); | ||
return vector.data.values.subarray(0, length)[Symbol.iterator](); | ||
} | ||
@@ -45,0 +45,0 @@ // Otherwise, iterate manually |
@@ -10,69 +10,69 @@ import * as type from '../type'; | ||
visitNull<T extends type.Null>({ typeId }: T): { | ||
'name': string; | ||
name: string; | ||
}; | ||
visitInt<T extends type.Int>({ typeId, bitWidth, isSigned }: T): { | ||
'name': string; | ||
'bitWidth': type.IntBitWidth; | ||
'isSigned': boolean; | ||
name: string; | ||
bitWidth: type.IntBitWidth; | ||
isSigned: boolean; | ||
}; | ||
visitFloat<T extends type.Float>({ typeId, precision }: T): { | ||
'name': string; | ||
'precision': string; | ||
name: string; | ||
precision: string; | ||
}; | ||
visitBinary<T extends type.Binary>({ typeId }: T): { | ||
'name': string; | ||
name: string; | ||
}; | ||
visitBool<T extends type.Bool>({ typeId }: T): { | ||
'name': string; | ||
name: string; | ||
}; | ||
visitUtf8<T extends type.Utf8>({ typeId }: T): { | ||
'name': string; | ||
name: string; | ||
}; | ||
visitDecimal<T extends type.Decimal>({ typeId, scale, precision }: T): { | ||
'name': string; | ||
'scale': number; | ||
'precision': number; | ||
name: string; | ||
scale: number; | ||
precision: number; | ||
}; | ||
visitDate<T extends type.Date_>({ typeId, unit }: T): { | ||
'name': string; | ||
'unit': string; | ||
name: string; | ||
unit: string; | ||
}; | ||
visitTime<T extends type.Time>({ typeId, unit, bitWidth }: T): { | ||
'name': string; | ||
'unit': string; | ||
name: string; | ||
unit: string; | ||
bitWidth: type.TimeBitWidth; | ||
}; | ||
visitTimestamp<T extends type.Timestamp>({ typeId, timezone, unit }: T): { | ||
'name': string; | ||
'unit': string; | ||
name: string; | ||
unit: string; | ||
timezone: string | null | undefined; | ||
}; | ||
visitInterval<T extends type.Interval>({ typeId, unit }: T): { | ||
'name': string; | ||
'unit': string; | ||
name: string; | ||
unit: string; | ||
}; | ||
visitList<T extends type.List>({ typeId }: T): { | ||
'name': string; | ||
name: string; | ||
}; | ||
visitStruct<T extends type.Struct>({ typeId }: T): { | ||
'name': string; | ||
name: string; | ||
}; | ||
visitUnion<T extends type.Union>({ typeId, mode, typeIds }: T): { | ||
'name': string; | ||
'mode': string; | ||
'typeIds': number[]; | ||
name: string; | ||
mode: string; | ||
typeIds: number[]; | ||
}; | ||
visitDictionary<T extends type.Dictionary>(node: T): object | undefined; | ||
visitFixedSizeBinary<T extends type.FixedSizeBinary>({ typeId, byteWidth }: T): { | ||
'name': string; | ||
'byteWidth': number; | ||
name: string; | ||
byteWidth: number; | ||
}; | ||
visitFixedSizeList<T extends type.FixedSizeList>({ typeId, listSize }: T): { | ||
'name': string; | ||
'listSize': number; | ||
name: string; | ||
listSize: number; | ||
}; | ||
visitMap<T extends type.Map_>({ typeId, keysSorted }: T): { | ||
'name': string; | ||
'keysSorted': boolean; | ||
name: string; | ||
keysSorted: boolean; | ||
}; | ||
} |
@@ -33,3 +33,3 @@ // Licensed to the Apache Software Foundation (ASF) under one | ||
case Type.Timestamp: | ||
return vector.values.subarray(0, length * stride); | ||
return vector.data.values.subarray(0, length * stride); | ||
} | ||
@@ -36,0 +36,0 @@ // Otherwise if not primitive, slow copy |
@@ -39,6 +39,6 @@ import { Data } from '../data'; | ||
visitDictionary<T extends Dictionary>(vector: V<T>): this; | ||
readonly nodes: FieldNode[]; | ||
readonly buffers: ArrayBufferView[]; | ||
readonly byteLength: number; | ||
readonly bufferRegions: BufferRegion[]; | ||
get nodes(): FieldNode[]; | ||
get buffers(): ArrayBufferView[]; | ||
get byteLength(): number; | ||
get bufferRegions(): BufferRegion[]; | ||
protected _byteLength: number; | ||
@@ -45,0 +45,0 @@ protected _nodes: FieldNode[]; |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
2575956
23106
0
Updatedtslib@^1.12.0