A GenStage producer that emits ExArrow.RecordBatch values from a Parquet file or in-memory Parquet binary.

Options

• :path — path to a .parquet file (opened with ExArrow.Stream.from_parquet/1).
• :binary — in-memory Parquet bytes (opened with ExArrow.Stream.from_parquet_binary/1).
• :stream — a pre-opened ExArrow.Stream.t() (useful for testing).

Example

{:ok, producer} =
  ExArrow.GenStage.ParquetProducer.start_link(path: "/data/events.parquet")