@qualithm/arrow-flight-sql-js - v0.4.3
    Preparing search index...

    Function parseFlightData

    • Parse a single FlightData message into a RecordBatch

      Flight sends data in a streaming format where:

      • First message: Schema (dataHeader only, no dataBody)
      • Subsequent messages: RecordBatch (dataHeader + dataBody)

      The dataHeader is a raw flatbuffer Message (without IPC framing). We need to frame it before passing to apache-arrow.

      Parameters

      • dataHeader: Uint8Array

        IPC Message flatbuffer (without continuation/length prefix)

      • dataBody: Uint8Array

        IPC Message body (raw data buffers)

      • schema: Schema

        Schema to use for parsing (from FlightInfo or first message)

      Returns RecordBatch<any> | null