ExArrow. GenStage. FlightProducer
(ex_arrow v0.7.1)
View Source
A GenStage producer that emits ExArrow.RecordBatch values from a Flight
do_get stream.
Options
:client+:ticket— opened withExArrow.Stream.from_flight/2.:stream— a pre-openedExArrow.Stream.t()(useful for testing).