Spaces:
Sleeping
Sleeping
File size: 2,759 Bytes
78c921d |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
import { MessageHeader } from '../enum.js';
import { Message } from './metadata/message.js';
import { ArrayBufferViewInput } from '../util/buffer.js';
import { ByteStream, ReadableSource, AsyncByteStream } from '../io/stream.js';
import { ArrowJSON, ArrowJSONLike, FileHandle } from '../io/interfaces.js';
/** @ignore */
export declare class MessageReader implements IterableIterator<Message> {
protected source: ByteStream;
constructor(source: ByteStream | ArrayBufferViewInput | Iterable<ArrayBufferViewInput>);
[Symbol.iterator](): IterableIterator<Message>;
next(): IteratorResult<Message>;
throw(value?: any): any;
return(value?: any): any;
readMessage<T extends MessageHeader>(type?: T | null): Message<T> | null;
readMessageBody(bodyLength: number): Uint8Array;
readSchema(throwIfNull?: boolean): import("../schema.js").Schema<any> | undefined;
protected readMetadataLength(): IteratorResult<number>;
protected readMetadata(metadataLength: number): IteratorResult<Message>;
}
/** @ignore */
export declare class AsyncMessageReader implements AsyncIterableIterator<Message> {
protected source: AsyncByteStream;
constructor(source: ReadableSource<Uint8Array>);
constructor(source: FileHandle, byteLength?: number);
[Symbol.asyncIterator](): AsyncIterableIterator<Message>;
next(): Promise<IteratorResult<Message>>;
throw(value?: any): Promise<any>;
return(value?: any): Promise<any>;
readMessage<T extends MessageHeader>(type?: T | null): Promise<Message<T> | null>;
readMessageBody(bodyLength: number): Promise<Uint8Array>;
readSchema(throwIfNull?: boolean): Promise<import("../schema.js").Schema<any> | undefined>;
protected readMetadataLength(): Promise<IteratorResult<number>>;
protected readMetadata(metadataLength: number): Promise<IteratorResult<Message>>;
}
/** @ignore */
export declare class JSONMessageReader extends MessageReader {
private _schema;
private _json;
private _body;
private _batchIndex;
private _dictionaryIndex;
constructor(source: ArrowJSON | ArrowJSONLike);
next(): any;
readMessageBody(_bodyLength?: number): any;
readMessage<T extends MessageHeader>(type?: T | null): Message<T> | null;
readSchema(): import("../schema.js").Schema<any>;
}
/** @ignore */
export declare const PADDING = 4;
/** @ignore */
export declare const MAGIC_STR = "ARROW1";
/** @ignore */
export declare const MAGIC: Uint8Array;
/** @ignore */
export declare function checkForMagicArrowString(buffer: Uint8Array, index?: number): boolean;
/** @ignore */
export declare const magicLength: number;
/** @ignore */
export declare const magicAndPadding: number;
/** @ignore */
export declare const magicX2AndPadding: number;
|