Class RecordBatchWriter<T>

Type Parameters

  • T extends TypeMap = any

Hierarchy

  • ReadableInterop<Uint8Array>
    • RecordBatchWriter

Implements

  • Writable<RecordBatch<T>>

Constructors

  • Type Parameters

    • T extends TypeMap = any

    Parameters

    • Optional options: RecordBatchStreamWriterOptions

    Returns RecordBatchWriter<T>

Accessors

  • get closed(): Promise<void>
  • Returns Promise<void>

Methods

  • Returns AsyncByteQueue<Uint8Array>

  • Parameters

    • Optional reason: any

    Returns void

  • Returns void

  • Type Parameters

    • R extends WritableStream<R>

    Parameters

    • writable: R
    • Optional options: {
          end?: boolean;
      }
      • Optional end?: boolean

    Returns R

  • Type Parameters

    • R extends ReadableStream<any, R>

    Parameters

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

    Returns ReadableStream<any>

  • Parameters

    • writable: WritableStream<Uint8Array>
    • Optional options: StreamPipeOptions

    Returns Promise<void>

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

  • Parameters

    • Optional options: ReadableDOMStreamOptions

    Returns ReadableStream<Uint8Array>

  • Parameters

    • Optional options: ReadableOptions

    Returns Readable

  • Parameters

    • sync: true

    Returns string

  • Parameters

    • Optional sync: false

    Returns Promise<string>

  • Parameters

    • sync: true

    Returns Uint8Array

  • Parameters

    • Optional sync: false

    Returns Promise<Uint8Array>

  • Parameters

    • Optional payload: null | RecordBatch<T> | Table<T> | Iterable<RecordBatch<T>>

    Returns void

  • Type Parameters

    • T extends TypeMap

    Parameters

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

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

    • readable: ReadableStream<Uint8Array>
    • writable: WritableStream<RecordBatch<T> | Table<T>>

    Nocollapse

  • Parameters

    • Optional options: DuplexOptions & {
          autoDestroy: boolean;
      }

    Returns Duplex

    Nocollapse

Generated using TypeDoc