Apache Arrow - v21.1.0
    正在准备搜索索引...

    RecordBatchWriter<T> 类

    类型参数

    • T extends TypeMap = any

    继承

    • ReadableInterop<Uint8Array>
      • RecordBatchWriter
    索引

    构造函数

    • 类型参数

      • T extends TypeMap = any

      参数

      • 可选options: RecordBatchStreamWriterOptions

      返回 RecordBatchWriter<T>

    访问器

    • get closed(): Promise<void>

      返回 Promise<void>

    方法

    • 返回 AsyncByteQueue<Uint8Array>

    • 参数

      • 可选reason: any

      返回 void

    • 类型参数

      • R extends WritableStream

      参数

      • writable: R
      • 可选options: { end?: boolean }

      返回 R

    • 类型参数

      • R extends ReadableStream<any>

      参数

      • duplex: { readable: R; writable: WritableStream<Uint8Array> }
      • 可选options: StreamPipeOptions

      返回 ReadableStream<any>

    • 参数

      • writable: WritableStream<Uint8Array>
      • 可选options: StreamPipeOptions

      返回 Promise<void>

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

    • 参数

      • 可选options: ReadableDOMStreamOptions

      返回 ReadableStream<Uint8Array>

    • 参数

      • 可选options: ReadableOptions<Readable>

      返回 Readable

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

      参数

      • sync: true

      返回 string

    • 参数

      • 可选sync: false

      返回 Promise<string>

    • 参数

      • sync: true

      返回 Uint8Array

    • 参数

      • 可选sync: false

      返回 Promise<Uint8Array>

    • 参数

      • 可选payload: null | RecordBatch<T> | Table<T> | Iterable<RecordBatch<T>>

      返回 void

    • 类型参数

      • T extends TypeMap

      参数

      • 可选writableStrategy: QueuingStrategy<RecordBatch<T>> & { autoDestroy: boolean }
      • 可选readableStrategy: { highWaterMark?: number; size?: any }

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

    • 参数

      • 可选options: DuplexOptions<Duplex> & { autoDestroy: boolean }

      返回 Duplex