类 RecordBatchWriter<T>

类型参数

  • T extends TypeMap = any

层级关系

  • ReadableInterop<Uint8Array>
    • RecordBatchWriter

实现

  • Writable<RecordBatch<T>>

构造函数

constructor

访问器

closed

方法

[asyncIterator] abort close finish pipe pipeThrough pipeTo reset tee toDOMStream toNodeStream toString toUint8Array write writeAll throughDOM throughNode

构造函数

constructor

  • new RecordBatchWriter<T extends TypeMap = any>(
        options?: RecordBatchStreamWriterOptions,
    ): RecordBatchWriter<T>

    类型参数

    • T extends TypeMap = any

    参数

    • Optionaloptions: RecordBatchStreamWriterOptions

    返回值 RecordBatchWriter<T>

访问器

closed

  • get closed(): Promise<void>

    返回值 Promise<void>

方法

[asyncIterator]

  • "[asyncIterator]"(): AsyncByteQueue<Uint8Array>

    返回值 AsyncByteQueue<Uint8Array>

abort

  • abort(reason?: any): void

    参数

    • Optionalreason: any

    返回值 void

close

  • close(): void

    返回值 void

finish

pipe

  • pipe<R extends WritableStream>(writable: R, options?: { end?: boolean }): R

    类型参数

    • R extends WritableStream

    参数

    • writable: R
    • Optionaloptions: { end?: boolean }

    返回值 R

pipeThrough

  • pipeThrough<R extends ReadableStream<any>>(
        duplex: { readable: R; writable: WritableStream<Uint8Array> },
        options?: StreamPipeOptions,
    ): ReadableStream<any>

    类型参数

    • R extends ReadableStream<any>

    参数

    • duplex: { readable: R; writable: WritableStream<Uint8Array> }
    • Optionaloptions: StreamPipeOptions

    返回 ReadableStream<any>

pipeTo

  • pipeTo(
        writable: WritableStream<Uint8Array>,
        options?: StreamPipeOptions,
    ): Promise<void>

    参数

    • writable: WritableStream<Uint8Array>
    • Optionaloptions: StreamPipeOptions

    返回值 Promise<void>

reset

  • reset(
        sink?: WritableSink<ArrayBufferViewInput>,
        schema?: null | Schema<T>,
    ): RecordBatchWriter<T>

    参数

    • sink: WritableSink<ArrayBufferViewInput> = ...
    • schema: null | Schema<T> = null

    返回值 RecordBatchWriter<T>

tee

  • tee(): [ReadableStream<Uint8Array>, ReadableStream<Uint8Array>]

    返回 [ReadableStream<Uint8Array>, ReadableStream<Uint8Array>]

toDOMStream

  • toDOMStream(options?: ReadableDOMStreamOptions): ReadableStream<Uint8Array>

    参数

    • Optionaloptions: ReadableDOMStreamOptions

    返回 ReadableStream<Uint8Array>

toNodeStream

  • toNodeStream(options?: ReadableOptions): Readable

    参数

    • Optionaloptions: ReadableOptions

    返回 Readable

toString

  • toString(sync: true): string

    返回对象的字符串表示形式。

    参数

    • sync: true

    返回 string

  • toString(sync?: false): Promise<string>

    参数

    • Optionalsync: false

    返回 Promise<string>

toUint8Array

  • toUint8Array(sync: true): Uint8Array

    参数

    • sync: true

    返回 Uint8Array

  • toUint8Array(sync?: false): Promise<Uint8Array>

    参数

    • Optionalsync: false

    返回 Promise<Uint8Array>

write

  • write(
        payload?: null | RecordBatch<T> | Table<T> | Iterable<RecordBatch<T>>,
    ): void

    参数

    • Optionalpayload: null | RecordBatch<T> | Table<T> | Iterable<RecordBatch<T>>

    返回值 void

writeAll

  • writeAll(input: Table<T> | Iterable<RecordBatch<T>>): this

    参数

    • input: Table<T> | Iterable<RecordBatch<T>>

    返回 this

  • writeAll(input: AsyncIterable<RecordBatch<T>>): Promise<RecordBatchWriter<T>>

    参数

    • input: AsyncIterable<RecordBatch<T>>

    返回 Promise<RecordBatchWriter<T>>

  • writeAll(
        input: PromiseLike<AsyncIterable<RecordBatch<T>>>,
    ): Promise<RecordBatchWriter<T>>

    参数

    • input: PromiseLike<AsyncIterable<RecordBatch<T>>>

    返回 Promise<RecordBatchWriter<T>>

  • writeAll(
        input: PromiseLike<Table<T> | Iterable<RecordBatch<T>>>,
    ): Promise<RecordBatchWriter<T>>

    参数

    • input: PromiseLike<Table<T> | Iterable<RecordBatch<T>>>

    返回 Promise<RecordBatchWriter<T>>

StaticthroughDOM

  • throughDOM<T extends TypeMap>(
        writableStrategy?: QueuingStrategy<RecordBatch<T>> & {
            autoDestroy: boolean;
        },
        readableStrategy?: { highWaterMark?: number; size?: any },
    ): {
        readable: ReadableStream<Uint8Array>;
        writable: WritableStream<RecordBatch<T> | Table<T>>;
    }

    类型参数

    • T extends TypeMap

    参数

    • OptionalwritableStrategy: QueuingStrategy<RecordBatch<T>> & { autoDestroy: boolean }
    • OptionalreadableStrategy: { highWaterMark?: number; size?: any }

    返回 {
        readable: ReadableStream<Uint8Array>;
        writable: WritableStream<RecordBatch<T> | Table<T>>;
    }

    Nocollapse

StaticthroughNode

  • throughNode(options?: DuplexOptions & { autoDestroy: boolean }): Duplex

    参数

    • Optionaloptions: DuplexOptions & { autoDestroy: boolean }

    返回 Duplex

    不折叠

设置

成员可见性

在此页上

构造函数
访问器
方法