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

    Function encodeRecordBatchesToFlightData

    • Encode Arrow RecordBatches into FlightData messages for upload.

      Produces a stream of FlightData messages suitable for DoPut operations. The first message contains the schema, followed by record batch messages.

      Parameters

      • batches: AsyncIterable<RecordBatch<any>, any, any> | Iterable<RecordBatch<any>, any, any>

        Async iterable of RecordBatch objects to encode

      • schema: Schema

        Arrow Schema for the data

      Returns AsyncGenerator<FlightData>

      FlightData messages

      const batches = [recordBatch1, recordBatch2]
      const flightData = encodeRecordBatchesToFlightData(batches, schema)
      await client.doPut(descriptor, flightData)