Apache Arrow - v21.1.0
    Preparing search index...

    Class RecordBatchWriter<T>

    Type Parameters

    • T extends TypeMap = any

    Hierarchy

    • ReadableInterop<Uint8Array>
      • RecordBatchWriter
    Index

    Constructors

    constructor

    Accessors

    closed

    Methods

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

    Constructors

    • Type Parameters

      • T extends TypeMap = any

      Parameters

      • Optionaloptions: RecordBatchStreamWriterOptions

      Returns RecordBatchWriter<T>

    Accessors

    • get closed(): Promise<void>

      Returns Promise<void>

    Methods

    • Returns AsyncByteQueue<Uint8Array>

    • Parameters

      • Optionalreason: any

      Returns void

    • Returns void

    • Type Parameters

      • R extends WritableStream

      Parameters

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

      Returns R

    • Type Parameters

      • R extends ReadableStream<any>

      Parameters

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

      Returns ReadableStream<any>

    • Parameters

      • writable: WritableStream<Uint8Array>
      • Optionaloptions: StreamPipeOptions

      Returns Promise<void>

    • Returns [ReadableStream<Uint8Array>, ReadableStream<Uint8Array>]

    • Parameters

      • Optionaloptions: ReadableDOMStreamOptions

      Returns ReadableStream<Uint8Array>

    • Parameters

      • Optionaloptions: ReadableOptions<Readable>

      Returns Readable

    • Returns a string representation of an object.

      Parameters

      • sync: true

      Returns string

    • Parameters

      • Optionalsync: false

      Returns Promise<string>

    • Parameters

      • sync: true

      Returns Uint8Array

    • Parameters

      • Optionalsync: false

      Returns Promise<Uint8Array>

    • Parameters

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

      Returns void

    • Type Parameters

      • T extends TypeMap

      Parameters

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

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

    • Parameters

      • Optionaloptions: DuplexOptions<Duplex> & { autoDestroy: boolean }

      Returns Duplex

    Settings

    Member Visibility

    On This Page

    Constructors
    Accessors
    Methods