Decode a stream of FlightData messages into Arrow RecordBatches.
The first message typically contains the schema. Subsequent messages contain record batches.
Async iterable of FlightData messages
RecordBatch objects
const stream = client.doGetFlightData(ticket)for await (const batch of decodeFlightDataStream(stream)) { console.log(`Received batch with ${batch.numRows} rows`)} Copy
const stream = client.doGetFlightData(ticket)for await (const batch of decodeFlightDataStream(stream)) { console.log(`Received batch with ${batch.numRows} rows`)}
Decode a stream of FlightData messages into Arrow RecordBatches.
The first message typically contains the schema. Subsequent messages contain record batches.