ExArrow.GenStage.ADBCProducer (ex_arrow v0.7.1)

A GenStage producer that emits ExArrow.RecordBatch values from an ADBC query result stream.

Options

:statement — a pre-built ExArrow.ADBC.Statement.t() (executed with ExArrow.Stream.from_adbc/1).
:connection + :sql — opened with ExArrow.Stream.from_adbc/2.
:stream — a pre-opened ExArrow.Stream.t() (useful for testing).

Summary

Functions

start_link(opts)

Functions

start_link(opts)