Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

@apache-arrow/es2015-esm

Package Overview
Dependencies
Maintainers
5
Versions
45
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@apache-arrow/es2015-esm - npm Package Compare versions

Comparing version 0.17.0 to 2.0.0

66

Arrow.d.ts

@@ -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;
};

2

Arrow.js

@@ -42,4 +42,4 @@ // Licensed to the Apache Software Foundation (ASF) under one

/** @ignore */
export const util = Object.assign({}, util_bn_, util_int_, util_bit_, util_math_, util_buffer_, util_vector_);
export const util = Object.assign(Object.assign(Object.assign(Object.assign(Object.assign(Object.assign({}, util_bn_), util_int_), util_bit_), util_math_), util_buffer_), util_vector_);
//# sourceMappingURL=Arrow.mjs.map

26

bin/arrow2csv.js

@@ -18,3 +18,3 @@ #! /usr/bin/env node

// under the License.
import * as tslib_1 from "tslib";
import { __asyncGenerator, __asyncValues, __await, __awaiter } from "tslib";
/* tslint:disable */

@@ -29,4 +29,4 @@ import * as fs from 'fs';

const files = argv.help ? [] : [...(argv.file || []), ...(argv._unknown || [])].filter(Boolean);
const state = Object.assign({}, argv, { closed: false, maxColWidths: [10] });
(() => tslib_1.__awaiter(this, void 0, void 0, function* () {
const state = Object.assign(Object.assign({}, argv), { closed: false, maxColWidths: [10] });
(() => __awaiter(void 0, void 0, void 0, function* () {
var e_1, _a;

@@ -44,3 +44,3 @@ const sources = argv.help ? [] : [

try {
for (var _b = tslib_1.__asyncValues(recordBatchReaders(source)), _c; _c = yield _b.next(), !_c.done;) {
for (var _b = (e_1 = void 0, __asyncValues(recordBatchReaders(source))), _c; _c = yield _b.next(), !_c.done;) {
reader = _c.value;

@@ -84,3 +84,3 @@ hasReaders = true;

function recordBatchReaders(createSourceStream) {
return tslib_1.__asyncGenerator(this, arguments, function* recordBatchReaders_1() {
return __asyncGenerator(this, arguments, function* recordBatchReaders_1() {
var e_2, _a, e_3, _b;

@@ -98,5 +98,5 @@ let json = new AsyncByteQueue();

try {
for (var _c = tslib_1.__asyncValues(RecordBatchReader.readAll(stream)), _d; _d = yield tslib_1.__await(_c.next()), !_d.done;) {
for (var _c = __asyncValues(RecordBatchReader.readAll(stream)), _d; _d = yield __await(_c.next()), !_d.done;) {
reader = _d.value;
reader && (yield yield tslib_1.__await(reader));
reader && (yield yield __await(reader));
}

@@ -107,3 +107,3 @@ }

try {
if (_d && !_d.done && (_a = _c.return)) yield tslib_1.__await(_a.call(_c));
if (_d && !_d.done && (_a = _c.return)) yield __await(_a.call(_c));
}

@@ -113,3 +113,3 @@ finally { if (e_2) throw e_2.error; }

if (reader)
return yield tslib_1.__await(void 0);
return yield __await(void 0);
}

@@ -120,3 +120,3 @@ catch (e) {

if (!readers) {
yield tslib_1.__await(json.closed);
yield __await(json.closed);
if (source instanceof fs.ReadStream) {

@@ -128,5 +128,5 @@ source.close();

try {
for (var _e = tslib_1.__asyncValues(RecordBatchReader.readAll(bignumJSONParse(yield tslib_1.__await(json.toString())))), _f; _f = yield tslib_1.__await(_e.next()), !_f.done;) {
for (var _e = __asyncValues(RecordBatchReader.readAll(bignumJSONParse(yield __await(json.toString())))), _f; _f = yield __await(_e.next()), !_f.done;) {
reader = _f.value;
reader && (yield yield tslib_1.__await(reader));
reader && (yield yield __await(reader));
}

@@ -137,3 +137,3 @@ }

try {
if (_f && !_f.done && (_b = _e.return)) yield tslib_1.__await(_b.call(_e));
if (_f && !_f.done && (_b = _e.return)) yield __await(_b.call(_e));
}

@@ -140,0 +140,0 @@ finally { if (e_3) throw e_3.error; }

20

builder.d.ts

@@ -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;

12

builder.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __asyncGenerator, __asyncValues, __await } from "tslib";
import { Vector } from './vector';

@@ -416,3 +416,3 @@ import { BufferType } from './enum';

return function (source) {
return tslib_1.__asyncGenerator(this, arguments, function* () {
return __asyncGenerator(this, arguments, function* () {
var e_1, _a;

@@ -422,6 +422,6 @@ let numChunks = 0;

try {
for (var source_1 = tslib_1.__asyncValues(source), source_1_1; source_1_1 = yield tslib_1.__await(source_1.next()), !source_1_1.done;) {
for (var source_1 = __asyncValues(source), source_1_1; source_1_1 = yield __await(source_1.next()), !source_1_1.done;) {
const value = source_1_1.value;
if (builder.append(value)[sizeProperty] >= highWaterMark) {
++numChunks && (yield yield tslib_1.__await(builder.toVector()));
++numChunks && (yield yield __await(builder.toVector()));
}

@@ -433,3 +433,3 @@ }

try {
if (source_1_1 && !source_1_1.done && (_a = source_1.return)) yield tslib_1.__await(_a.call(source_1));
if (source_1_1 && !source_1_1.done && (_a = source_1.return)) yield __await(_a.call(source_1));
}

@@ -439,3 +439,3 @@ finally { if (e_1) throw e_1.error; }

if (builder.finish().length > 0 || numChunks === 0) {
yield yield tslib_1.__await(builder.toVector());
yield yield __await(builder.toVector());
}

@@ -442,0 +442,0 @@ });

2

builder/binary.d.ts

@@ -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;
}

10

builder/buffer.d.ts

@@ -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;

12

builder/dictionary.d.ts

@@ -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;

2

builder/index.js

@@ -56,3 +56,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

const opts = getChildOptions(field, index);
builder.children.push(newBuilder(Object.assign({}, opts, { type })));
builder.children.push(newBuilder(Object.assign(Object.assign({}, opts), { type })));
});

@@ -59,0 +59,0 @@ }

4

builder/int.d.ts

@@ -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;
}

2

builder/run.d.ts

@@ -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;

2

builder/union.d.ts

@@ -11,3 +11,3 @@ import { DataBufferBuilder } from './buffer';

constructor(options: UnionBuilderOptions<T, TNull>);
readonly typeIdToChildIndex: {
get typeIdToChildIndex(): {
[key: number]: number;

@@ -14,0 +14,0 @@ };

2

builder/utf8.d.ts

@@ -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;
}

2

builder/valid.d.ts

@@ -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;

10

column.d.ts

@@ -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;
}

7

column.js

@@ -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] :

10

compute/predicate.d.ts

@@ -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 */

14

data.d.ts

@@ -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>;

180

interfaces.d.ts

@@ -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 {};

20

io/adapters.d.ts
/// <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;

59

io/adapters.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __asyncGenerator, __await, __awaiter } from "tslib";
import { toUint8Array, joinUint8Arrays, toUint8ArrayIterator, toUint8ArrayAsyncIterator } from '../util/buffer';

@@ -83,8 +83,9 @@ /** @ignore */

finally {
(threw === false) && (typeof it.return === 'function') && (it.return());
(threw === false) && (typeof it.return === 'function') && (it.return(null));
}
return null;
}
/** @ignore */
function fromAsyncIterable(source) {
return tslib_1.__asyncGenerator(this, arguments, function* fromAsyncIterable_1() {
return __asyncGenerator(this, arguments, function* fromAsyncIterable_1() {
let done, threw = false;

@@ -101,3 +102,3 @@ let buffers = [], buffer;

// Yield so the caller can inject the read command before creating the source AsyncIterator
({ cmd, size } = yield yield tslib_1.__await(null));
({ cmd, size } = (yield yield __await(null)));
// initialize the iterator

@@ -109,4 +110,4 @@ let it = toUint8ArrayAsyncIterator(source)[Symbol.asyncIterator]();

({ done, value: buffer } = isNaN(size - bufferLength)
? yield tslib_1.__await(it.next(undefined))
: yield tslib_1.__await(it.next(size - bufferLength)));
? yield __await(it.next(undefined))
: yield __await(it.next(size - bufferLength)));
// if chunk is not null or empty, push it onto the queue

@@ -120,3 +121,3 @@ if (!done && buffer.byteLength > 0) {

do {
({ cmd, size } = yield yield tslib_1.__await(byteRange()));
({ cmd, size } = yield yield __await(byteRange()));
} while (size < bufferLength);

@@ -127,7 +128,8 @@ }

catch (e) {
(threw = true) && (typeof it.throw === 'function') && (yield tslib_1.__await(it.throw(e)));
(threw = true) && (typeof it.throw === 'function') && (yield __await(it.throw(e)));
}
finally {
(threw === false) && (typeof it.return === 'function') && (yield tslib_1.__await(it.return()));
(threw === false) && (typeof it.return === 'function') && (yield __await(it.return(new Uint8Array(0))));
}
return yield __await(null);
});

@@ -140,3 +142,3 @@ }

function fromDOMStream(source) {
return tslib_1.__asyncGenerator(this, arguments, function* fromDOMStream_1() {
return __asyncGenerator(this, arguments, function* fromDOMStream_1() {
let done = false, threw = false;

@@ -153,3 +155,3 @@ let buffers = [], buffer;

// Yield so the caller can inject the read command before we establish the ReadableStream lock
({ cmd, size } = yield yield tslib_1.__await(null));
({ cmd, size } = yield yield __await(null));
// initialize the reader and lock the stream

@@ -161,4 +163,4 @@ let it = new AdaptiveByteReader(source);

({ done, value: buffer } = isNaN(size - bufferLength)
? yield tslib_1.__await(it['read'](undefined))
: yield tslib_1.__await(it['read'](size - bufferLength)));
? yield __await(it['read'](undefined))
: yield __await(it['read'](size - bufferLength)));
// if chunk is not null or empty, push it onto the queue

@@ -172,3 +174,3 @@ if (!done && buffer.byteLength > 0) {

do {
({ cmd, size } = yield yield tslib_1.__await(byteRange()));
({ cmd, size } = yield yield __await(byteRange()));
} while (size < bufferLength);

@@ -179,8 +181,9 @@ }

catch (e) {
(threw = true) && (yield tslib_1.__await(it['cancel'](e)));
(threw = true) && (yield __await(it['cancel'](e)));
}
finally {
(threw === false) ? (yield tslib_1.__await(it['cancel']()))
(threw === false) ? (yield __await(it['cancel']()))
: source['locked'] && it.releaseLock();
}
return yield __await(null);
});

@@ -211,3 +214,3 @@ }

cancel(reason) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const { reader, source } = this;

@@ -219,3 +222,3 @@ reader && (yield reader['cancel'](reason).catch(() => { }));

read(size) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (size === 0) {

@@ -264,3 +267,3 @@ return { done: this.reader == null, value: new Uint8Array(0) };

readFromBYOBReader(size) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
return yield readInto(this.getBYOBReader(), new ArrayBuffer(size), 0, size);

@@ -272,3 +275,3 @@ });

function readInto(reader, buffer, offset, size) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (offset >= size) {

@@ -292,3 +295,3 @@ return { done: false, value: new Uint8Array(buffer, 0, size) };

function fromNodeStream(stream) {
return tslib_1.__asyncGenerator(this, arguments, function* fromNodeStream_1() {
return __asyncGenerator(this, arguments, function* fromNodeStream_1() {
let events = [];

@@ -308,6 +311,7 @@ let event = 'error';

// add the listener for the source stream's 'readable' event.
({ cmd, size } = yield yield tslib_1.__await(null));
({ cmd, size } = yield yield __await(null));
// ignore stdin if it's a TTY
if (stream['isTTY']) {
return yield tslib_1.__await(yield yield tslib_1.__await(new Uint8Array(0)));
yield yield __await(new Uint8Array(0));
return yield __await(null);
}

@@ -321,3 +325,3 @@ try {

// wait on the first message event from the stream
[event, err] = yield tslib_1.__await(Promise.race(events.map((x) => x[2])));
[event, err] = yield __await(Promise.race(events.map((x) => x[2])));
// if the stream emitted an Error, rethrow it

@@ -351,3 +355,3 @@ if (event === 'error') {

do {
({ cmd, size } = yield yield tslib_1.__await(byteRange()));
({ cmd, size } = yield yield __await(byteRange()));
} while (size < bufferLength);

@@ -358,7 +362,8 @@ }

finally {
yield tslib_1.__await(cleanup(events, event === 'error' ? err : null));
yield __await(cleanup(events, event === 'error' ? err : null));
}
return yield __await(null);
function cleanup(events, err) {
buffer = buffers = null;
return new Promise((resolve, reject) => tslib_1.__awaiter(this, void 0, void 0, function* () {
return new Promise((resolve, reject) => __awaiter(this, void 0, void 0, function* () {
for (const [evt, fn] of events) {

@@ -365,0 +370,0 @@ stream['off'](evt, fn);

18

io/file.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __awaiter } from "tslib";
import { ByteStream, AsyncByteStream } from './stream';

@@ -67,3 +67,3 @@ import { toUint8Array } from '../util/buffer';

else {
this._pending = (() => tslib_1.__awaiter(this, void 0, void 0, function* () {
this._pending = (() => __awaiter(this, void 0, void 0, function* () {
this.size = (yield file.stat()).size;

@@ -75,3 +75,3 @@ delete this._pending;

readInt32(position) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const { buffer, byteOffset } = yield this.readAt(position, 4);

@@ -82,3 +82,3 @@ return new DataView(buffer, byteOffset).getInt32(0, true);

seek(position) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
this._pending && (yield this._pending);

@@ -90,3 +90,3 @@ this.position = Math.min(position, this.size);

read(nBytes) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
this._pending && (yield this._pending);

@@ -110,3 +110,3 @@ const { _handle: file, size, position } = this;

readAt(position, nBytes) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
this._pending && (yield this._pending);

@@ -123,9 +123,9 @@ const { _handle: file, size } = this;

close() {
return tslib_1.__awaiter(this, void 0, void 0, function* () { const f = this._handle; this._handle = null; f && (yield f.close()); });
return __awaiter(this, void 0, void 0, function* () { const f = this._handle; this._handle = null; f && (yield f.close()); });
}
throw(value) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield this.close(); return { done: true, value }; });
return __awaiter(this, void 0, void 0, function* () { yield this.close(); return { done: true, value }; });
}
return(value) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield this.close(); return { done: true, value }; });
return __awaiter(this, void 0, void 0, function* () { yield this.close(); return { done: true, value }; });
}

@@ -132,0 +132,0 @@ }

8

io/interfaces.d.ts

@@ -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;

12

io/interfaces.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __awaiter } from "tslib";
import streamAdapters from './adapters';

@@ -61,3 +61,3 @@ /** @ignore */

cancel(reason) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield this.return(reason); });
return __awaiter(this, void 0, void 0, function* () { yield this.return(reason); });
}

@@ -100,12 +100,12 @@ write(value) {

throw(_) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield this.abort(_); return ITERATOR_DONE; });
return __awaiter(this, void 0, void 0, function* () { yield this.abort(_); return ITERATOR_DONE; });
}
return(_) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield this.close(); return ITERATOR_DONE; });
return __awaiter(this, void 0, void 0, function* () { yield this.close(); return ITERATOR_DONE; });
}
read(size) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { return (yield this.next(size, 'read')).value; });
return __awaiter(this, void 0, void 0, function* () { return (yield this.next(size, 'read')).value; });
}
peek(size) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { return (yield this.next(size, 'peek')).value; });
return __awaiter(this, void 0, void 0, function* () { return (yield this.next(size, 'peek')).value; });
}

@@ -112,0 +112,0 @@ next(..._args) {

6

io/node/iterable.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __awaiter } from "tslib";
import { Readable } from 'stream';

@@ -80,3 +80,3 @@ import { isIterable, isAsyncIterable } from '../../util/compat';

if (it && !this._pulling && (this._pulling = true)) {
(() => tslib_1.__awaiter(this, void 0, void 0, function* () { return this._pulling = yield this._pull(size, it); }))();
(() => __awaiter(this, void 0, void 0, function* () { return this._pulling = yield this._pull(size, it); }))();
}

@@ -90,3 +90,3 @@ }

_pull(size, it) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const bm = this._bytesMode;

@@ -93,0 +93,0 @@ let r = null;

10

io/node/reader.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __awaiter } from "tslib";
import { Duplex } from 'stream';

@@ -29,3 +29,3 @@ import { AsyncByteQueue } from '../../io/stream';

constructor(options) {
super(Object.assign({ allowHalfOpen: false }, options, { readableObjectMode: true, writableObjectMode: false }));
super(Object.assign(Object.assign({ allowHalfOpen: false }, options), { readableObjectMode: true, writableObjectMode: false }));
this._pulling = false;

@@ -52,3 +52,3 @@ this._autoDestroy = true;

if (aq && !this._pulling && (this._pulling = true)) {
(() => tslib_1.__awaiter(this, void 0, void 0, function* () {
(() => __awaiter(this, void 0, void 0, function* () {
if (!this._reader) {

@@ -69,3 +69,3 @@ this._reader = yield this._open(aq);

_open(source) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
return yield (yield RecordBatchReader.from(source)).open({ autoDestroy: this._autoDestroy });

@@ -75,3 +75,3 @@ });

_pull(size, reader) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
let r = null;

@@ -78,0 +78,0 @@ while (this.readable && !(r = yield reader.next()).done) {

8

io/node/writer.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __awaiter } from "tslib";
import { Duplex } from 'stream';

@@ -28,3 +28,3 @@ import { AsyncByteStream } from '../../io/stream';

constructor(writer, options) {
super(Object.assign({ allowHalfOpen: false }, options, { writableObjectMode: true, readableObjectMode: false }));
super(Object.assign(Object.assign({ allowHalfOpen: false }, options), { writableObjectMode: true, readableObjectMode: false }));
this._pulling = false;

@@ -48,3 +48,3 @@ this._writer = writer;

if (it && !this._pulling && (this._pulling = true)) {
(() => tslib_1.__awaiter(this, void 0, void 0, function* () { return this._pulling = yield this._pull(size, it); }))();
(() => __awaiter(this, void 0, void 0, function* () { return this._pulling = yield this._pull(size, it); }))();
}

@@ -60,3 +60,3 @@ }

_pull(size, reader) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
let r = null;

@@ -63,0 +63,0 @@ while (this.readable && !(r = yield reader.next(size || null)).done) {

6

io/stream.d.ts

@@ -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>;

18

io/stream.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __asyncValues, __awaiter } from "tslib";
import streamAdapters from './adapters';

@@ -37,7 +37,7 @@ import { decodeUtf8 } from '../util/utf8';

toUint8Array(sync = false) {
return sync ? joinUint8Arrays(this._values)[0] : (() => tslib_1.__awaiter(this, void 0, void 0, function* () {
return sync ? joinUint8Arrays(this._values)[0] : (() => __awaiter(this, void 0, void 0, function* () {
var e_1, _a;
let buffers = [], byteLength = 0;
try {
for (var _b = tslib_1.__asyncValues(this), _c; _c = yield _b.next(), !_c.done;) {
for (var _b = __asyncValues(this), _c; _c = yield _b.next(), !_c.done;) {
const chunk = _c.value;

@@ -129,16 +129,16 @@ buffers.push(chunk);

cancel(reason) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield this.return(reason); });
return __awaiter(this, void 0, void 0, function* () { yield this.return(reason); });
}
get closed() { return this._closedPromise; }
read(size) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { return (yield this.next(size, 'read')).value; });
return __awaiter(this, void 0, void 0, function* () { return (yield this.next(size, 'read')).value; });
}
peek(size) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { return (yield this.next(size, 'peek')).value; });
return __awaiter(this, void 0, void 0, function* () { return (yield this.next(size, 'peek')).value; });
}
next(size, cmd = 'read') {
return tslib_1.__awaiter(this, void 0, void 0, function* () { return (yield this.source.next({ cmd, size })); });
return __awaiter(this, void 0, void 0, function* () { return (yield this.source.next({ cmd, size })); });
}
throw(value) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const result = (this.source.throw && (yield this.source.throw(value))) || ITERATOR_DONE;

@@ -151,3 +151,3 @@ this._closedPromiseResolve && this._closedPromiseResolve();

return(value) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const result = (this.source.return && (yield this.source.return(value))) || ITERATOR_DONE;

@@ -154,0 +154,0 @@ this._closedPromiseResolve && this._closedPromiseResolve();

4

io/whatwg/builder.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __rest } from "tslib";
import { Builder } from '../../builder/index';

@@ -31,3 +31,3 @@ /** @ignore */

this._bufferedSize = 0;
const { ['readableStrategy']: readableStrategy, ['writableStrategy']: writableStrategy, ['queueingStrategy']: queueingStrategy = 'count' } = options, builderOptions = tslib_1.__rest(options, ['readableStrategy', 'writableStrategy', 'queueingStrategy']);
const { ['readableStrategy']: readableStrategy, ['writableStrategy']: writableStrategy, ['queueingStrategy']: queueingStrategy = 'count' } = options, builderOptions = __rest(options, ['readableStrategy', 'writableStrategy', 'queueingStrategy']);
this._controller = null;

@@ -34,0 +34,0 @@ this._builder = Builder.new(builderOptions);

15

io/whatwg/iterable.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __awaiter } from "tslib";
import { toUint8Array } from '../../util/buffer';

@@ -37,4 +37,3 @@ import { isIterable, isAsyncIterable } from '../../util/compat';

const hwm = options && options.highWaterMark || (Math.pow(2, 24));
return new ReadableStream(Object.assign({}, options, { start(controller) { next(controller, it || (it = source[Symbol.iterator]())); },
pull(controller) { it ? (next(controller, it)) : controller.close(); },
return new ReadableStream(Object.assign(Object.assign({}, options), { start(controller) { next(controller, it || (it = source[Symbol.iterator]())); }, pull(controller) { it ? (next(controller, it)) : controller.close(); },
cancel() { (it && (it.return && it.return()) || true) && (it = null); } }), Object.assign({ highWaterMark: bm ? hwm : undefined }, options));

@@ -63,13 +62,13 @@ function next(controller, it) {

const hwm = options && options.highWaterMark || (Math.pow(2, 24));
return new ReadableStream(Object.assign({}, options, { start(controller) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield next(controller, it || (it = source[Symbol.asyncIterator]())); });
return new ReadableStream(Object.assign(Object.assign({}, options), { start(controller) {
return __awaiter(this, void 0, void 0, function* () { yield next(controller, it || (it = source[Symbol.asyncIterator]())); });
},
pull(controller) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { it ? (yield next(controller, it)) : controller.close(); });
return __awaiter(this, void 0, void 0, function* () { it ? (yield next(controller, it)) : controller.close(); });
},
cancel() {
return tslib_1.__awaiter(this, void 0, void 0, function* () { (it && (it.return && (yield it.return())) || true) && (it = null); });
return __awaiter(this, void 0, void 0, function* () { (it && (it.return && (yield it.return())) || true) && (it = null); });
} }), Object.assign({ highWaterMark: bm ? hwm : undefined }, options));
function next(controller, it) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
let buf;

@@ -76,0 +75,0 @@ let r = null;

12

io/whatwg/reader.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __awaiter } from "tslib";
import { AsyncByteQueue } from '../../io/stream';

@@ -27,9 +27,9 @@ import { RecordBatchReader } from '../../ipc/reader';

cancel() {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield queue.close(); });
return __awaiter(this, void 0, void 0, function* () { yield queue.close(); });
},
start(controller) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield next(controller, reader || (reader = yield open())); });
return __awaiter(this, void 0, void 0, function* () { yield next(controller, reader || (reader = yield open())); });
},
pull(controller) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { reader ? yield next(controller, reader) : controller.close(); });
return __awaiter(this, void 0, void 0, function* () { reader ? yield next(controller, reader) : controller.close(); });
}

@@ -39,3 +39,3 @@ });

function open() {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
return yield (yield RecordBatchReader.from(queue)).open(readableStrategy);

@@ -45,3 +45,3 @@ });

function next(controller, reader) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
let size = controller.desiredSize;

@@ -48,0 +48,0 @@ let r = null;

10

io/whatwg/writer.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __awaiter } from "tslib";
import { AsyncByteStream } from '../../io/stream';

@@ -27,9 +27,9 @@ /** @ignore */

cancel() {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield reader.cancel(); });
return __awaiter(this, void 0, void 0, function* () { yield reader.cancel(); });
},
pull(controller) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield next(controller); });
return __awaiter(this, void 0, void 0, function* () { yield next(controller); });
},
start(controller) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { yield next(controller); });
return __awaiter(this, void 0, void 0, function* () { yield next(controller); });
},

@@ -39,3 +39,3 @@ }, Object.assign({ 'highWaterMark': Math.pow(2, 14) }, readableStrategy));

function next(controller) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
let buf = null;

@@ -42,0 +42,0 @@ let size = controller.desiredSize;

18

ipc/message.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __awaiter } from "tslib";
import { MessageHeader } from '../enum';

@@ -116,3 +116,3 @@ import { flatbuffers } from 'flatbuffers';

next() {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
let r;

@@ -136,9 +136,9 @@ if ((r = yield this.readMetadataLength()).done) {

throw(value) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { return yield this.source.throw(value); });
return __awaiter(this, void 0, void 0, function* () { return yield this.source.throw(value); });
}
return(value) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { return yield this.source.return(value); });
return __awaiter(this, void 0, void 0, function* () { return yield this.source.return(value); });
}
readMessage(type) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
let r;

@@ -155,3 +155,3 @@ if ((r = yield this.next()).done) {

readMessageBody(bodyLength) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (bodyLength <= 0) {

@@ -171,3 +171,3 @@ return new Uint8Array(0);

readSchema(throwIfNull = false) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const type = MessageHeader.Schema;

@@ -183,3 +183,3 @@ const message = yield this.readMessage(type);

readMetadataLength() {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const buf = yield this.source.read(PADDING);

@@ -192,3 +192,3 @@ const bb = buf && new ByteBuffer(buf);

readMetadata(metadataLength) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const buf = yield this.source.read(metadataLength);

@@ -195,0 +195,0 @@ if (!buf) {

4

ipc/metadata/file.d.ts

@@ -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>;

10

ipc/metadata/file.js

@@ -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

26

ipc/metadata/message.d.ts

@@ -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 @@ }

16

ipc/metadata/message.js

@@ -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 @@ /**

38

ipc/reader.d.ts

@@ -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>);

46

ipc/reader.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __asyncDelegator, __asyncGenerator, __asyncValues, __await, __awaiter } from "tslib";
import { Vector } from '../vector';

@@ -112,3 +112,3 @@ import { MessageHeader } from '../enum';

else if (isPromise(source)) {
return (() => tslib_1.__awaiter(this, void 0, void 0, function* () { return yield RecordBatchReader.from(yield source); }))();
return (() => __awaiter(this, void 0, void 0, function* () { return yield RecordBatchReader.from(yield source); }))();
}

@@ -157,3 +157,3 @@ else if (isFetchResponse(source) || isReadableDOMStream(source) || isReadableNodeStream(source) || isAsyncIterable(source)) {

[Symbol.iterator]() { return this._impl[Symbol.iterator](); }
[Symbol.asyncIterator]() { return tslib_1.__asyncGenerator(this, arguments, function* _a() { yield tslib_1.__await(yield* tslib_1.__asyncDelegator(tslib_1.__asyncValues(this[Symbol.iterator]()))); }); }
[Symbol.asyncIterator]() { return __asyncGenerator(this, arguments, function* _a() { yield __await(yield* __asyncDelegator(__asyncValues(this[Symbol.iterator]()))); }); }
}

@@ -310,3 +310,3 @@ /** @ignore */

cancel() {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (!this.closed && (this.closed = true)) {

@@ -320,3 +320,3 @@ yield this.reset()._reader.return();

open(options) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (!this.closed) {

@@ -332,3 +332,3 @@ this.autoDestroy = shouldAutoDestroy(this, options);

throw(value) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (!this.closed && this.autoDestroy && (this.closed = true)) {

@@ -341,3 +341,3 @@ return yield this.reset()._reader.throw(value);

return(value) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (!this.closed && this.autoDestroy && (this.closed = true)) {

@@ -350,3 +350,3 @@ return yield this.reset()._reader.return(value);

next() {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (this.closed) {

@@ -383,3 +383,3 @@ return ITERATOR_DONE;

_readNextMessageAndValidate(type) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
return yield this._reader.readMessage(type);

@@ -475,3 +475,3 @@ });

});
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (!this.closed && !this._footer) {

@@ -487,3 +487,3 @@ this.schema = (this._footer = yield this._readFooter()).schema;

readRecordBatch(index) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (this.closed) {

@@ -509,3 +509,3 @@ return null;

_readDictionaryBatch(index) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const block = this._footer && this._footer.getDictionaryBatch(index);

@@ -524,3 +524,3 @@ if (block && (yield this._handle.seek(block.offset))) {

_readFooter() {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const { _handle } = this;

@@ -535,3 +535,3 @@ _handle._pending && (yield _handle._pending);

_readNextMessageAndValidate(type) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
if (!this._footer) {

@@ -584,13 +584,13 @@ yield this.open();

function readAllAsync(source) {
return tslib_1.__asyncGenerator(this, arguments, function* readAllAsync_1() {
const reader = yield tslib_1.__await(RecordBatchReader.from(source));
return __asyncGenerator(this, arguments, function* readAllAsync_1() {
const reader = yield __await(RecordBatchReader.from(source));
try {
if (!(yield tslib_1.__await(reader.open({ autoDestroy: false }))).closed) {
if (!(yield __await(reader.open({ autoDestroy: false }))).closed) {
do {
yield yield tslib_1.__await(reader);
} while (!(yield tslib_1.__await(reader.reset().open())).closed);
yield yield __await(reader);
} while (!(yield __await(reader.reset().open())).closed);
}
}
finally {
yield tslib_1.__await(reader.cancel());
yield __await(reader.cancel());
}

@@ -613,3 +613,3 @@ });

function fromAsyncByteStream(source) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const bytes = yield source.peek((magicLength + 7) & ~7);

@@ -619,3 +619,3 @@ return bytes && bytes.byteLength >= 4 ? !checkForMagicArrowString(bytes)

: new RecordBatchFileReader(new RecordBatchFileReaderImpl(yield source.read()))
: new AsyncRecordBatchStreamReader(new AsyncRecordBatchStreamReaderImpl(function () { return tslib_1.__asyncGenerator(this, arguments, function* () { }); }()));
: new AsyncRecordBatchStreamReader(new AsyncRecordBatchStreamReaderImpl(function () { return __asyncGenerator(this, arguments, function* () { }); }()));
});

@@ -625,3 +625,3 @@ }

function fromFileHandle(source) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
const { size } = yield source.stat();

@@ -628,0 +628,0 @@ const file = new AsyncRandomAccessFile(source, size);

2

ipc/writer.d.ts

@@ -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>;

14

ipc/writer.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __asyncValues, __awaiter } from "tslib";
import { Table } from '../table';

@@ -272,6 +272,2 @@ import { MAGIC } from './message';

export class RecordBatchFileWriter extends RecordBatchWriter {
constructor() {
super();
this._autoDestroy = true;
}
/** @nocollapse */

@@ -288,2 +284,6 @@ static writeAll(input) {

}
constructor() {
super();
this._autoDestroy = true;
}
// @ts-ignore

@@ -378,5 +378,5 @@ _writeSchema(schema) {

var e_1, _a;
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
try {
for (batches_1 = tslib_1.__asyncValues(batches); batches_1_1 = yield batches_1.next(), !batches_1_1.done;) {
for (batches_1 = __asyncValues(batches); batches_1_1 = yield batches_1.next(), !batches_1_1.done;) {
const batch = batches_1_1.value;

@@ -383,0 +383,0 @@ writer.write(batch);

4

package.json
{
"version": "0.17.0",
"version": "2.0.0",
"name": "@apache-arrow/es2015-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": {

2

README.md

@@ -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 @@

6

recordbatch.d.ts

@@ -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;

6

schema.d.ts

@@ -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>;

10

table.d.ts

@@ -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<{

10

table.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __asyncValues, __awaiter } from "tslib";
import { Column } from './column';

@@ -61,3 +61,3 @@ import { Schema } from './schema';

if (isPromise(reader)) {
return (() => tslib_1.__awaiter(this, void 0, void 0, function* () { return yield Table.from(yield reader); }))();
return (() => __awaiter(this, void 0, void 0, function* () { return yield Table.from(yield reader); }))();
}

@@ -67,3 +67,3 @@ if (reader.isSync() && (reader = reader.open())) {

}
return ((opening) => tslib_1.__awaiter(this, void 0, void 0, function* () {
return ((opening) => __awaiter(this, void 0, void 0, function* () {
var e_1, _a;

@@ -75,3 +75,3 @@ const reader = yield opening;

try {
for (var reader_1 = tslib_1.__asyncValues(reader), reader_1_1; reader_1_1 = yield reader_1.next(), !reader_1_1.done;) {
for (var reader_1 = __asyncValues(reader), reader_1_1; reader_1_1 = yield reader_1.next(), !reader_1_1.done;) {
let batch = reader_1_1.value;

@@ -95,3 +95,3 @@ batches.push(batch);

static fromAsync(source) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return __awaiter(this, void 0, void 0, function* () {
return yield Table.from(source);

@@ -98,0 +98,0 @@ });

64

type.d.ts

@@ -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;

1

type.js

@@ -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 @@ }

6

util/args.d.ts

@@ -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 {};

2

util/bit.d.ts

@@ -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.

7

util/bn.js

@@ -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

40

util/buffer.d.ts

@@ -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;

22

util/buffer.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __asyncDelegator, __asyncGenerator, __asyncValues, __await } from "tslib";
import { flatbuffers } from 'flatbuffers';

@@ -138,2 +138,3 @@ import { encodeUtf8 } from '../util/utf8';

})(buffers[Symbol.iterator]()));
return new ArrayCtor();
}

@@ -151,11 +152,11 @@ /** @ignore */ export const toInt8ArrayIterator = (input) => toArrayBufferViewIterator(Int8Array, input);

export function toArrayBufferViewAsyncIterator(ArrayCtor, source) {
return tslib_1.__asyncGenerator(this, arguments, function* toArrayBufferViewAsyncIterator_1() {
return __asyncGenerator(this, arguments, function* toArrayBufferViewAsyncIterator_1() {
// if a Promise, unwrap the Promise and iterate the resolved value
if (isPromise(source)) {
return yield tslib_1.__await(yield tslib_1.__await(yield* tslib_1.__asyncDelegator(tslib_1.__asyncValues(toArrayBufferViewAsyncIterator(ArrayCtor, yield tslib_1.__await(source))))));
return yield __await(yield __await(yield* __asyncDelegator(__asyncValues(toArrayBufferViewAsyncIterator(ArrayCtor, yield __await(source))))));
}
const wrap = function (x) { return tslib_1.__asyncGenerator(this, arguments, function* () { yield yield tslib_1.__await(yield tslib_1.__await(x)); }); };
const wrap = function (x) { return __asyncGenerator(this, arguments, function* () { yield yield __await(yield __await(x)); }); };
const emit = function (source) {
return tslib_1.__asyncGenerator(this, arguments, function* () {
yield tslib_1.__await(yield* tslib_1.__asyncDelegator(tslib_1.__asyncValues(pump((function* (it) {
return __asyncGenerator(this, arguments, function* () {
yield __await(yield* __asyncDelegator(__asyncValues(pump((function* (it) {
let r = null;

@@ -175,11 +176,12 @@ do {

: source; // otherwise if AsyncIterable, use it
yield tslib_1.__await(// otherwise if AsyncIterable, use it
yield* tslib_1.__asyncDelegator(tslib_1.__asyncValues(pump((function (it) {
return tslib_1.__asyncGenerator(this, arguments, function* () {
yield __await(// otherwise if AsyncIterable, use it
yield* __asyncDelegator(__asyncValues(pump((function (it) {
return __asyncGenerator(this, arguments, function* () {
let r = null;
do {
r = yield tslib_1.__await(it.next(yield yield tslib_1.__await(toArrayBufferView(ArrayCtor, r))));
r = yield __await(it.next(yield yield __await(toArrayBufferView(ArrayCtor, r))));
} while (!r.done);
});
})(buffers[Symbol.asyncIterator]())))));
return yield __await(new ArrayCtor());
});

@@ -186,0 +188,0 @@ }

3

util/compat.d.ts
/// <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>;

2

util/utf8.d.ts
/** @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;

2

util/vector.d.ts

@@ -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 {};

2

vector.d.ts

@@ -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'];

1

vector.js

@@ -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

28

vector/base.d.ts

@@ -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;

4

vector/bool.d.ts

@@ -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>>;
}

30

vector/chunked.d.ts

@@ -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>;

4

vector/date.d.ts

@@ -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 */

2

vector/dictionary.d.ts

@@ -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;

16

vector/index.js

@@ -17,3 +17,3 @@ // Licensed to the Apache Software Foundation (ASF) under one

// under the License.
import * as tslib_1 from "tslib";
import { __asyncValues, __awaiter, __rest } from "tslib";
export { Vector } from '../vector';

@@ -74,16 +74,16 @@ export { BaseVector } from './base';

return isIterable(values)
? Vector.from(Object.assign({ nullValues }, input, { type }))
: Vector.from(Object.assign({ nullValues }, input, { type }));
? Vector.from(Object.assign(Object.assign({ nullValues }, input), { type }))
: Vector.from(Object.assign(Object.assign({ nullValues }, input), { type }));
}
function vectorFrom(input) {
const _a = Object.assign({ 'nullValues': [null, undefined] }, input), { 'values': values = [] } = _a, options = tslib_1.__rest(_a, ['values']);
const _a = Object.assign({ 'nullValues': [null, undefined] }, input), { 'values': values = [] } = _a, options = __rest(_a, ['values']);
if (isIterable(values)) {
const chunks = [...Builder.throughIterable(options)(values)];
return chunks.length === 1 ? chunks[0] : Chunked.concat(chunks);
return (chunks.length === 1 ? chunks[0] : Chunked.concat(chunks));
}
return ((chunks) => tslib_1.__awaiter(this, void 0, void 0, function* () {
return ((chunks) => __awaiter(this, void 0, void 0, function* () {
var e_1, _b;
const transform = Builder.throughAsyncIterable(options);
try {
for (var _c = tslib_1.__asyncValues(transform(values)), _d; _d = yield _c.next(), !_d.done;) {
for (var _c = __asyncValues(transform(values)), _d; _d = yield _c.next(), !_d.done;) {
const chunk = _d.value;

@@ -100,3 +100,3 @@ chunks.push(chunk);

}
return chunks.length === 1 ? chunks[0] : Chunked.concat(chunks);
return (chunks.length === 1 ? chunks[0] : Chunked.concat(chunks));
}))([]);

@@ -103,0 +103,0 @@ }

4

vector/int.d.ts

@@ -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 {};

4

vector/row.d.ts

@@ -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;

4

vector/union.d.ts

@@ -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 */

4

vector/utf8.d.ts

@@ -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;
}

7

visitor.js

@@ -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;

2

visitor/indexof.js

@@ -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;

4

visitor/iterator.js

@@ -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

62

visitor/jsontypeassembler.d.ts

@@ -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;
};
}

2

visitor/toarray.js

@@ -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

8

visitor/vectorassembler.d.ts

@@ -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[];

Arrow.mjs.map

Sorry, the diff of this file is not supported yet

bin/arrow2csv.js.map

Sorry, the diff of this file is not supported yet

bin/arrow2csv.mjs.map

Sorry, the diff of this file is not supported yet

builder.mjs.map

Sorry, the diff of this file is not supported yet

builder/index.mjs.map

Sorry, the diff of this file is not supported yet

column.mjs.map

Sorry, the diff of this file is not supported yet

data.mjs.map

Sorry, the diff of this file is not supported yet

interfaces.mjs.map

Sorry, the diff of this file is not supported yet

io/adapters.mjs.map

Sorry, the diff of this file is not supported yet

io/file.mjs.map

Sorry, the diff of this file is not supported yet

io/interfaces.mjs.map

Sorry, the diff of this file is not supported yet

io/node/iterable.mjs.map

Sorry, the diff of this file is not supported yet

io/node/reader.mjs.map

Sorry, the diff of this file is not supported yet

io/node/writer.mjs.map

Sorry, the diff of this file is not supported yet

io/stream.mjs.map

Sorry, the diff of this file is not supported yet

io/whatwg/builder.mjs.map

Sorry, the diff of this file is not supported yet

io/whatwg/iterable.mjs.map

Sorry, the diff of this file is not supported yet

io/whatwg/reader.mjs.map

Sorry, the diff of this file is not supported yet

io/whatwg/writer.mjs.map

Sorry, the diff of this file is not supported yet

ipc/message.mjs.map

Sorry, the diff of this file is not supported yet

ipc/metadata/file.mjs.map

Sorry, the diff of this file is not supported yet

ipc/metadata/message.mjs.map

Sorry, the diff of this file is not supported yet

ipc/reader.mjs.map

Sorry, the diff of this file is not supported yet

ipc/writer.mjs.map

Sorry, the diff of this file is not supported yet

LICENSE.txt

Sorry, the diff of this file is too big to display

table.mjs.map

Sorry, the diff of this file is not supported yet

type.mjs.map

Sorry, the diff of this file is not supported yet

util/bn.mjs.map

Sorry, the diff of this file is not supported yet

util/buffer.mjs.map

Sorry, the diff of this file is not supported yet

vector.mjs.map

Sorry, the diff of this file is not supported yet

vector/bool.mjs.map

Sorry, the diff of this file is not supported yet

vector/date.mjs.map

Sorry, the diff of this file is not supported yet

vector/index.mjs.map

Sorry, the diff of this file is not supported yet

vector/utf8.mjs.map

Sorry, the diff of this file is not supported yet

visitor.mjs.map

Sorry, the diff of this file is not supported yet

visitor/indexof.mjs.map

Sorry, the diff of this file is not supported yet

visitor/iterator.mjs.map

Sorry, the diff of this file is not supported yet

visitor/toarray.mjs.map

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc