@qualithm/arrow-flight-client - v0.1.4
    Preparing search index...

    Function decodeFlightDataToTable

    • Decode a stream of FlightData messages into an Arrow Table.

      Collects all record batches from the stream and combines them into a single table.

      Type Parameters

      • T extends TypeMap = TypeMap

      Parameters

      • stream: AsyncIterable<FlightData>

        Async iterable of FlightData messages

      Returns Promise<Table<T>>

      Arrow Table containing all data from the stream

      const stream = client.doGetFlightData(ticket)
      const table = await decodeFlightDataToTable(stream)
      console.log(`Received table with ${table.numRows} rows`)